From e561fd5d5e2564dcb6d5e4358ac7d3b917016ebb Mon Sep 17 00:00:00 2001
From: Alexander Wenzel <Alexander.AW.Wenzel@bmw.de>
Date: Fri, 6 Jun 2014 12:44:27 +0200
Subject: First implementation of DLT DBus adapter.

Signed-off-by: Alexander Wenzel <Alexander.AW.Wenzel@bmw.de>
---
 src/dbus/dlt-dbus.c | 168 ++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 168 insertions(+)
 create mode 100644 src/dbus/dlt-dbus.c

(limited to 'src/dbus/dlt-dbus.c')

diff --git a/src/dbus/dlt-dbus.c b/src/dbus/dlt-dbus.c
new file mode 100644
index 0000000..53eb94c
--- /dev/null
+++ b/src/dbus/dlt-dbus.c
@@ -0,0 +1,168 @@
+/**
+ * @licence app begin@
+ * Copyright (C) 2014  BMW AG
+ *
+ * This file is part of GENIVI Project Dlt - Diagnostic Log and Trace console apps.
+ *
+ * Contributions are licensed to the GENIVI Alliance under one or more
+ * Contribution License Agreements.
+ *
+ * \copyright
+ * This Source Code Form is subject to the terms of the
+ * Mozilla Public License, v. 2.0. If a  copy of the MPL was not distributed with
+ * this file, You can obtain one at http://mozilla.org/MPL/2.0/.
+ *
+ *
+ * \author Alexander Wenzel <alexander.wenzel@bmw.de>
+ *
+ * \file dlt-dbus.c
+ * For further information see http://www.genivi.org/.
+ * @licence end@
+ */
+
+#include "dlt-dbus.h"
+
+#include <stdio.h>
+#include <stdlib.h>
+#include <string.h>
+#include <dbus/dbus.h>
+#include <sys/time.h>
+#include <dlt.h>
+
+#include <time.h>
+
+#ifdef USE_EAVESDROP
+    #define EAVESDROPPING_RULE "eavesdrop=true,"
+#else
+    #define EAVESDROPPING_RULE ""
+#endif
+
+DLT_DECLARE_CONTEXT(dbusContext);
+
+static char dbus_message_buffer[DBUS_MAXIMUM_MESSAGE_LENGTH];
+
+static const char*
+type_to_name (int message_type)
+{
+  switch (message_type)
+    {
+    case DBUS_MESSAGE_TYPE_SIGNAL:
+      return "signal";
+    case DBUS_MESSAGE_TYPE_METHOD_CALL:
+      return "method call";
+    case DBUS_MESSAGE_TYPE_METHOD_RETURN:
+      return "method return";
+    case DBUS_MESSAGE_TYPE_ERROR:
+      return "error";
+    default:
+      return "(unknown message type)";
+    }
+}
+
+static DBusHandlerResult
+filter_func (DBusConnection *con,
+             DBusMessage *message,
+             void *data)
+{
+  DBusMessageIter iter;
+  const char *sender;
+  const char *destination;
+  char **buf;
+  int message_type;
+  char *log_message;
+  int log_type;
+  int len_p;
+
+  buf = (char**)&dbus_message_buffer;
+  if (!dbus_message_marshal(message,
+                            buf,
+                            &len_p))
+  {
+    fprintf (stderr, "Failed to serialize DBus message!\n");
+    return DBUS_HANDLER_RESULT_HANDLED;
+  }
+  //DLT_LOG (dbusContext, DLT_LOG_INFO, DLT_STRING("dbus message"), DLT_RAW ((void *)*buf, len_p));
+  DLT_TRACE_NETWORK_SEGMENTED(dbusContext,DLT_NW_TRACE_IPC,0,0,len_p,(void *)*buf);
+
+  if (dbus_message_is_signal (message,
+                              DBUS_INTERFACE_LOCAL,
+                              "Disconnected"))
+  {
+    DLT_UNREGISTER_CONTEXT (dbusContext);
+    DLT_UNREGISTER_APP ();
+    exit (0);
+  }
+
+
+  /* Conceptually we want this to be
+   * DBUS_HANDLER_RESULT_NOT_YET_HANDLED, but this raises
+   * some problems.  See bug 1719.
+   */
+  return DBUS_HANDLER_RESULT_HANDLED;
+}
+
+int main (int argc, char *argv[])
+{
+  /* DLT initialisation */
+  DLT_REGISTER_APP ("IPC0", "DBus Logging");
+  DLT_REGISTER_CONTEXT(dbusContext, "ALL", "DBus Context for Logging");
+
+  DBusConnection *connection;
+  DBusError error;
+  DBusBusType type = DBUS_BUS_SESSION;
+  //DBusBusType type = DBUS_BUS_SYSTEM;
+
+  dbus_error_init (&error);
+
+  connection = dbus_bus_get (type, &error);
+  if (NULL == connection)
+  {
+    fprintf (stderr, "Failed to open connection to %s: %s\n",
+             DBUS_BUS_SYSTEM,
+             error.message);
+             dbus_error_free (&error);
+             exit (1);
+  }
+
+  dbus_bus_add_match (connection,
+                      EAVESDROPPING_RULE "type='signal'",
+                      &error);
+  if (dbus_error_is_set (&error))
+    goto fail;
+  dbus_bus_add_match (connection,
+                      EAVESDROPPING_RULE "type='method_call'",
+                      &error);
+  if (dbus_error_is_set (&error))
+    goto fail;
+  dbus_bus_add_match (connection,
+                      EAVESDROPPING_RULE "type='method_return'",
+                      &error);
+  if (dbus_error_is_set (&error))
+    goto fail;
+  dbus_bus_add_match (connection,
+                      EAVESDROPPING_RULE "type='error'",
+                      &error);
+  if (dbus_error_is_set (&error))
+    goto fail;
+
+  if (!dbus_connection_add_filter (connection, filter_func, NULL, NULL)) {
+    fprintf (stderr, "Couldn't add filter!\n");
+    exit (1);
+  }
+
+  while (dbus_connection_read_write_dispatch(connection, -1))
+    ;
+
+  DLT_UNREGISTER_CONTEXT (dbusContext);
+  DLT_UNREGISTER_APP ();
+  exit(1);
+
+fail:
+
+  /* fail */
+  fprintf (stderr, "Error: %s\n", error.message);
+  DLT_UNREGISTER_CONTEXT (dbusContext);
+  DLT_UNREGISTER_APP ();
+  exit(1);
+
+}
-- 
cgit v1.2.1