diff options
Diffstat (limited to 'PluginCommandInterfaceDbus/DbusSend.cpp')
| -rw-r--r-- | PluginCommandInterfaceDbus/DbusSend.cpp | 112 |
1 files changed, 112 insertions, 0 deletions
diff --git a/PluginCommandInterfaceDbus/DbusSend.cpp b/PluginCommandInterfaceDbus/DbusSend.cpp new file mode 100644 index 0000000..7183a95 --- /dev/null +++ b/PluginCommandInterfaceDbus/DbusSend.cpp @@ -0,0 +1,112 @@ +/* + * DbusSend.cpp + * + * Created on: Jul 20, 2011 + * Author: christian + */ + +#include "DbusSend.h" + +DbusSend::DbusSend (DBusConnection* conn, const char* bus_name,const char* path, const char* interface, const char* method) : m_conn(conn) { + m_msg=dbus_message_new_method_call(bus_name,path,interface,method); + if (NULL == m_msg) { + DLT_LOG(DBusPlugin, DLT_LOG_INFO, DLT_STRING("Error while creating DBus message")); + this->~DbusSend(); + } +} + +DbusSend::~DbusSend() { + // TODO Auto-generated destructor stub +} + +void DbusSend::appendString(char* string) { + dbus_message_iter_init_append(m_msg, &m_args); + if (!dbus_message_iter_append_basic(&m_args, DBUS_TYPE_STRING, string)) { + DLT_LOG(DBusPlugin, DLT_LOG_INFO, DLT_STRING("Out of memory")); + this->~DbusSend(); + } +} + +void DbusSend::appendInteger(int integer) { + dbus_message_iter_init_append(m_msg, &m_args); + if (!dbus_message_iter_append_basic(&m_args, DBUS_TYPE_INT32, &integer)) { + DLT_LOG(DBusPlugin, DLT_LOG_INFO, DLT_STRING("Out of memory")); + this->~DbusSend(); + } + +} + +void DbusSend::sendReply(bool* reply) { + + DBusPendingCall* pending; + DBusMessageIter args; + if (!dbus_connection_send_with_reply (m_conn, m_msg, &pending, -1)) { // -1 is default timeout + DLT_LOG(DBusPlugin, DLT_LOG_INFO, DLT_STRING("Out of memory")); + this->~DbusSend(); + } + + if (NULL == pending) { + DLT_LOG(DBusPlugin, DLT_LOG_INFO, DLT_STRING("Pending Call Null")); + this->~DbusSend(); + } + dbus_connection_flush(m_conn); + dbus_message_unref(m_msg); + dbus_pending_call_block(pending); + + DBusMessage* msg=dbus_pending_call_steal_reply(pending); + + if (NULL == msg) { + DLT_LOG(DBusPlugin, DLT_LOG_INFO, DLT_STRING("DBUS reply NULL")); + this->~DbusSend(); + } + + dbus_pending_call_unref(pending); + + if (!dbus_message_iter_init(msg, &args)) { + DLT_LOG(DBusPlugin, DLT_LOG_INFO, DLT_STRING("DBUS Message without arguments")); + } else if (DBUS_TYPE_BOOLEAN != dbus_message_iter_get_arg_type(&args)) { + DLT_LOG(DBusPlugin, DLT_LOG_INFO, DLT_STRING("Argument not boolean")); + } else { + dbus_message_iter_get_basic(&args, reply); + } + + dbus_message_unref(msg); +} + +void DbusSend::sendReply(int* reply) { + + DBusPendingCall* pending; + DBusMessageIter args; + if (!dbus_connection_send_with_reply (m_conn, m_msg, &pending, -1)) { // -1 is default timeout + DLT_LOG(DBusPlugin, DLT_LOG_INFO, DLT_STRING("Out of memory")); + this->~DbusSend(); + } + + if (NULL == pending) { + DLT_LOG(DBusPlugin, DLT_LOG_INFO, DLT_STRING("Pending Call Null")); + this->~DbusSend(); + } + dbus_connection_flush(m_conn); + dbus_message_unref(m_msg); + dbus_pending_call_block(pending); + + DBusMessage* msg=dbus_pending_call_steal_reply(pending); + + if (NULL == msg) { + DLT_LOG(DBusPlugin, DLT_LOG_INFO, DLT_STRING("DBUS reply NULL")); + this->~DbusSend(); + } + + dbus_pending_call_unref(pending); + + if (!dbus_message_iter_init(msg, &args)) { + DLT_LOG(DBusPlugin, DLT_LOG_INFO, DLT_STRING("DBUS Message without arguments")); + } else if (DBUS_TYPE_INT32 != dbus_message_iter_get_arg_type(&args)) { + DLT_LOG(DBusPlugin, DLT_LOG_INFO, DLT_STRING("Argument not integer")); + } else { + dbus_message_iter_get_basic(&args, reply); + } + + dbus_message_unref(msg); +} + |