在C语言中打印DBus方法调用的响应

Question

我遇到的问题是使用低级API在C中打印出dbus方法调用的响应。我对C的libdbus不太熟悉，但已经在python-dbus中做了一些工作。

• 我知道如何在Python和CLI中编写dbus方法和方法调用。
• 我可以在互联网上找到调用dbus方法的代码，但它们不会返回或打印出响应。
• 我一直在查看libdbus doxygen api，但无法确定如何提取响应。

我的代码设置方式是运行一个带有我想要调用的方法的python dbus守护程序。其中一些方法返回字符串。我想让一个C程序连接到会话总线，调用该方法，打印出回复并退出。

这是我目前拥有的:

#include <stdio.h>
#include <dbus/dbus.h>

static void send_dbus_message (DBusConnection *connection, const char *msg)
{
DBusMessage *message;
//initialize the message
message = dbus_message_new_signal ("/org/example/foo/bar",
                                    "org.example.foo.bar",
                                    msg);

//send the message
dbus_connection_send (connection, message, NULL);
//deallocate the message
dbus_message_unref (message);
}

int main (int argc, char **argv)
{
DBusConnection *connection;
DBusError error;

//init error message
dbus_error_init (&error);
connection = dbus_bus_get (DBUS_BUS_SESSION, &error);
if (!connection)
{
    printf ("Connection to D-BUS daemon failed: %s", error.message);

    //deallocate error message
    dbus_error_free (&error);
    return 1;
}

send_dbus_message (connection, "HelloWorld");
return 0;
}

可以同步或异步进行。

- NuclearPeon

---

你看过这个教程中的示例了吗？ - user4815162342

谢谢回复，但是那个例子是基于Glib的，而我正在为一个没有X功能的系统编写代码，所以我想避免使用它。 - NuclearPeon

我已经查看了以下网站：http://www.matthew.ath.cx/misc/dbus...该网站确实有一些有用的代码，但在运行他们的“调用方法”部分后仍然没有打印出回复。代码本身没有param变量，因此如果您将其复制/粘贴到c文件中并编译，则会失败。即使有变量，它也不会打印任何内容。 - NuclearPeon

你那边有什么能够响应/org/example/foo/bar/org.example.foo.bar信号的东西吗？此外，你正在发送一个单向信号。虽然在协议级别上可以回复信号（可以发送带有replySerial设置为信号序列的消息），但如果使用的话并不常见。 - Andrey Sidorov

Answer 1

您可以使用http://www.matthew.ath.cx/misc/dbus中提到的方法获取方法回复消息。

获得dbus消息后，您可以使用以下方法提取数据。 要解析dbus消息，您需要一个参数迭代器。将其初始化为读取传入消息的内容即可。

DBusMessageIter MsgIter;
dbus_message_iter_init(msg, &MsgIter);//msg is pointer to dbus message received

在读取消息之前，您必须验证传入消息的签名。或者，您也可以进行逐个参数验证。例如，如果参数类型为字符串

if (DBUS_TYPE_STRING == dbus_message_iter_get_arg_type(&MsgIter)){
    char* str = NULL; 
    dbus_message_iter_get_basic(&MsgIter, &str);//this function is used to read basic dbus types like int, string etc. 
}

对于复杂类型，例如结构体、数组、变量和字典条目，您需要创建相应的子迭代器来解析每个复杂元素的内容。例如，对于DBus签名s(i{ii}i)u，提取过程如下所示：

//Parsing a signature s(i{ii}i)u
DBusMessageIter rootIter;
dbus_message_iter_init(msg, &rootIter);

if (DBUS_TYPE_STRING == dbus_message_iter_get_arg_type(&rootIter))
{
    char* str = NULL; 
    dbus_message_iter_get_basic(&rootIter, &str);//this function is used to read basic dbus types like int, string etc. 
    dbus_message_iter_next(&rootIter);//Go to next argument of root iter

    //Block to enter and read structure
    if (DBUS_TYPE_STRUCT == dbus_message_iter_get_arg_type(&rootIter))
    {
    DBusMessageIter structIter;
    dbus_message_iter_recurse(&rootIter, &structIter);//Initialize iterator for struct

    //Argument 1 is int32
    if (DBUS_TYPE_INT32 == dbus_message_iter_get_arg_type(&structIter))
    {
        int a;
            dbus_message_iter_get_basic(&structIter, &a);//Read integer
        dbus_message_iter_next(&structIter);//Go to next argument of structiter

        if (DDBUS_TYPE_DICT_ENTRY == dbus_message_iter_get_arg_type(&structIter))
        {
           DBusMessageIter dictIter;           
               dbus_message_iter_recurse(&structIter, &dictIter);//Initialize iterator for dictentry
           if (DBUS_TYPE_INT32 == dbus_message_iter_get_arg_type(&dictIter))
           {
            dbus_message_iter_get_basic(&dictIter, &a);//Read integer
            dbus_message_iter_next(&dictIter);//Go to next argument of dictentry
            if (DBUS_TYPE_INT32 == dbus_message_iter_get_arg_type(&dictIter))
            {
               dbus_message_iter_get_basic(&dictIter, &a);//Read integer
            }
           }
        }
        dbus_message_iter_next(&structIter);//Go to next argument of structiter
            if (DBUS_TYPE_INT32 == dbus_message_iter_get_arg_type(&structIter))
        {
           dbus_message_iter_get_basic(&structIter, &a);//Read integer
        }
        }
    }
    dbus_message_iter_next(&rootIter);//Go to next argument of root iterator
    if (DBUS_TYPE_UINT32 == dbus_message_iter_get_arg_type(&rootIter))
    {
    uint32_t b;
    dbus_message_iter_get_basic(&rootIter, &b);//Read integer
    }
}

上面的代码中，我使用了逐个参数检查的方式。你可以使用 dbus_message_iter_get_signature 进行一次性验证。了解更多信息，请参考 libdbus API。
#
根据你的回复，我理解你在连接设置方面遇到了问题，这里有一个完整的示例，其中调用了服务器上的方法，并在第一个参数是字符串时打印结果。
#

#include <stdio.h>
#include <stdlib.h>
#include <dbus/dbus.h>
#include <assert.h>

DBusConnection* conn = NULL;

//Helper function to setup connection
void vsetupconnection();

//Send method call, Returns NULL on failure, else pointer to reply
DBusMessage* sendMethodCall(const char* objectpath, \
        const char* busname, \
        const char* interfacename, \
        const char* methodname);

#define TEST_BUS_NAME               "org.freedesktop.DBus"
#define TEST_OBJ_PATH               "/org/freedesktop/DBus"
#define TEST_INTERFACE_NAME         "org.freedesktop.DBus.Introspectable"
#define TEST_METHOD_NAME            "Introspect"

int main (int argc, char **argv)
{
    vsetupconnection();

    DBusMessage* reply = sendMethodCall(TEST_OBJ_PATH, TEST_BUS_NAME, TEST_INTERFACE_NAME, TEST_METHOD_NAME);
    if(reply != NULL)    {

        DBusMessageIter MsgIter;
        dbus_message_iter_init(reply, &MsgIter);//msg is pointer to dbus message received

        if (DBUS_TYPE_STRING == dbus_message_iter_get_arg_type(&MsgIter)){
            char* str = NULL;
            dbus_message_iter_get_basic(&MsgIter, &str);
            printf("Received string: \n %s \n",str);
        }

        dbus_message_unref(reply);//unref reply
    }
    dbus_connection_close(conn);
    return 0;
}

void vsetupconnection()
{
   DBusError err;
   // initialise the errors
   dbus_error_init(&err);
   // connect to session bus
   conn = dbus_bus_get(DBUS_BUS_SESSION, &err);
   if (dbus_error_is_set(&err)) {
      printf("Connection Error (%s)\n", err.message);
      dbus_error_free(&err);
   }
   if (NULL == conn) {
      exit(1);
   }
   else   {
       printf("Connected to session bus\n");
   }
}

DBusMessage* sendMethodCall(const char* objectpath, const char* busname, const char* interfacename, const char* methodname)
{
    assert(objectpath != NULL); assert(busname != NULL);    assert(interfacename != NULL);
    assert(methodname != NULL); assert(conn != NULL);

    DBusMessage* methodcall = dbus_message_new_method_call(busname,objectpath, interfacename, methodname);

    if (methodcall == NULL)    {
        printf("Cannot allocate DBus message!\n");
    }
    //Now do a sync call
    DBusPendingCall* pending;
    DBusMessage* reply;

    if (!dbus_connection_send_with_reply(conn, methodcall, &pending, -1))//Send and expect reply using pending call object
    {
        printf("failed to send message!\n");
    }
    dbus_connection_flush(conn);
    dbus_message_unref(methodcall);
    methodcall = NULL;

    dbus_pending_call_block(pending);//Now block on the pending call
    reply = dbus_pending_call_steal_reply(pending);//Get the reply message from the queue
    dbus_pending_call_unref(pending);//Free pending call handle
    assert(reply != NULL);

    if(dbus_message_get_type(reply) ==  DBUS_MESSAGE_TYPE_ERROR)    {
        printf("Error : %s",dbus_message_get_error_name(reply));
            dbus_message_unref(reply);
            reply = NULL;
    }

    return reply;
}

- Ranjit Katuri

---

谢谢您的帖子，但我认为它没有涉及到我的问题。首先，您提到了与我在评论@user4815162342中提到的相同链接，我已经查看过了，但没有成功。 我想要的是打印出回复。 我会在有空的时候测试您所写的内容，但我没有看到您的回复中有任何打印消息，所以我不认为它回答了我的问题。 您还初始化了char str，但在您的代码中没有引用它。 - NuclearPeon