一、簡介
DBus的出現(xiàn),使得Linux進程間通信更加便捷,不僅可以和用戶空間應用程序進行通信,而且還可以和內(nèi)核的程序進行通信,DBus使得Linux變得更加智能,更加具有交互性。 DBus分為兩種類型:system bus(系統(tǒng)總線),用于系統(tǒng)(Linux)和用戶程序之間進行通信和消息的傳遞;session bus(回話總線),用于桌面(GNOME, KDE等)用戶程序之間進行通信。
二、詳解之Qt代碼
1、代碼一
(1)test.h
- #ifndef TEST_H
- #define TEST_H
-
- #include <QtCore>
- #include <QTimer>
-
- class Test : public QObject
- {
- Q_OBJECT
- public:
- Test();
-
- public slots:
- QString testStart();
- void changeTest();
-
- signals:
- void stateChange(QString str);
-
- private:
- QTimer *timer;
- };
- #endif /*TEST_H*/
(2)test.cpp
- #include "test.h"
-
- Test::Test()
- {
- qDebug() << "===========test init===========";
- timer = new QTimer;
- connect(timer, SIGNAL(timeout()), this, SLOT(changeTest()));
- }
-
- QString Test::testStart()
- {
- qDebug() << "+++++++QtDBus test++++++++++";
- QString tmp;
- tmp = QString("OFF");
- qDebug() << tmp;
- if (timer->isActive()) {
- timer->stop();
- }
- timer->start(2000);
- return tmp;
- }
-
- void Test::changeTest()
- {
- QString tmp;
- tmp = QString("ON");
- qDebug() << "+++++++++++++++++++" << tmp;
- emit stateChange(tmp);
- }
(3)test_adaptor.h
- #include "test_adaptor.h"
- #include <QtCore>
-
- TestInterfaceAdaptor::TestInterfaceAdaptor(QObject *parent)
- :QDBusAbstractAdaptor(parent)
- {
- qDebug() << "***************TestInterfaceAdaptor::TestInterfaceAdaptor**************";
- setAutoRelaySignals(true); //connection of the signals on the parent
- }
-
- TestInterfaceAdaptor::~TestInterfaceAdaptor()
- {
- }
-
- QString TestInterfaceAdaptor::test()
- {
- QString out;
- QMetaObject::invokeMethod(parent(), "testStart",Q_RETURN_ARG(QString, out));
- qDebug() << "==========" << out;
- return out;
- }
(4)test_adaptor.cpp
- #ifndef TEST_ADAPTOR_H
- #define TEST_ADAPTOR_H
-
- #include <QtCore/QObject>
- #include <QtDBus/QtDBus>
- /****
- **dbus-send --session --print-reply --dest=com.asianux.btagent / com.asianux.btagent.adaptor.test
- **dbus-monitor --session \ "type='signal',interface='com.asianux.btagent.adaptor',member='stateChange'"
- *****/
- class TestInterfaceAdaptor : public QDBusAbstractAdaptor
- {
- Q_OBJECT
- Q_CLASSINFO("D-Bus Interface", "com.asianux.btagent.adaptor")
-
- Q_CLASSINFO("D-Bus Introspection", ""
- " <interface name=\"com.asianux.btagent.adaptor\">\n"
- " <method name=\"test\">\n"
- " <arg name=\"state\" type=\"s\" direction=\"out\"/>\n"
- " </method> \n"
- " <signal name=\"stateChange\"> \n"
- " <arg type=\"s\" direction=\"out\"/>\n"
- " </signal> \n"
- " </interface>\n"
- "")
-
- public:
- TestInterfaceAdaptor(QObject *parent);
- virtual ~TestInterfaceAdaptor();
-
- public:
- public slots:
- QString test();
-
- signals:
- void stateChange(QString str);
- };
-
- #endif /*TEST_ADAPTOR_H*/
(5)main.cpp
- #include <QApplication>
- #include <QtDBus>
- #include <QDebug>
- #include "test_adaptor.h"
- #include "test.h"
-
- int main(int argc,char *argv[])
- {
- QApplication app(argc,argv);
-
- Test *test = new Test();
-
- new TestInterfaceAdaptor(test);
- QDBusConnection conn = QDBusConnection::sessionBus();
- conn.registerObject("/",test);
- conn.registerService("com.asianux.btagent");
-
- return app.exec();
- }
(6)運行
可以在linux終端發(fā)送(dbus-send)和監(jiān)控dbus(dbus-monitor)的信息。 dbus-send調(diào)用遠程方法的一般形式是:$ dbus-send [--system | --session] --type=method_call --print-reply --dest=連接名 對象路徑 接口名.方法名 參數(shù)類型:參數(shù)值 參數(shù)類型:參數(shù)值,dbus-send支持的參數(shù)類型包括:string, int32, uint32, double, byte, boolean。 啟動程序后,先執(zhí)行:dbus-send --session --print-reply --dest=com.asianux.btagent / com.asianux.btagent.adaptor.test,發(fā)送dbus信號,得到輸出結(jié)果:
然后輸入:dbus-monitor --session \ "type='signal',interface='com.asianux.btagent.adaptor',member='stateChange'",監(jiān)控,從應用程序發(fā)出的DBus信號:
也可以通過qt自帶的工具qdbusviewer查看和操作相應的DBus信號:
(7)除了上述方法,也可以使用glib的程序進行DBus通信。 main.c:
- #include <stdio.h>
- #include <stdlib.h>
- #include <glib.h>
- #include <dbus/dbus-glib.h>
- #include <dbus/dbus.h>
-
- static void bt_manager_changed_cb (DBusGProxy *proxy,
- const gchar *state,
- gpointer user_data)
- {
- printf("state = %s\n",state);
- }
-
- int main(int argc,char *argv[])
- {
- GMainLoop *loop = g_main_loop_new(NULL,TRUE);
- g_type_init();
- GError * error = NULL;
-
- DBusGConnection *gconn = dbus_g_bus_get(DBUS_BUS_SESSION, NULL);
- DBusGProxy *m_proxy = dbus_g_proxy_new_for_name(gconn, "com.asianux.btagent","/","com.asianux.btagent.adaptor");
-
- char *str = NULL;
- dbus_g_proxy_call(m_proxy, "test", &error,
- G_TYPE_INVALID,
- G_TYPE_STRING,&str,
- G_TYPE_INVALID);
-
- dbus_g_proxy_add_signal (m_proxy,
- "stateChange",
- G_TYPE_STRING,
- G_TYPE_INVALID);
-
- dbus_g_proxy_connect_signal (m_proxy,
- "stateChange",
- G_CALLBACK (bt_manager_changed_cb),
- NULL,
- NULL);
- printf("str = %s\n",str);
- g_main_loop_run(loop);
-
- }
makefile:
- all:
- gcc -g main.c -o test `pkg-config --cflags --libs dbus-1 gthread-2.0 glib-2.0 dbus-glib-1`
- clean:
- rm -rf *.o test
運行結(jié)果(先啟動最上的服務器qt程序):
2、代碼二
(1)qdbus.h
- #ifndef QDBUS
- #define QDBUS
- #include <QtCore>
- /*dbus-send --session --print-reply --dest=com.asianux.btagent2 / com.asianux.btagent2.interface.slotInterface string:"helloworld"*/
- class DeviceManager : public QObject
- {
- Q_OBJECT
- Q_CLASSINFO("D-Bus Interface", "com.asianux.btagent2.interface")
-
- public:
- // DeviceManager(){}
- // ~DeviceManager(){}
- public slots:
- void slotInterface(QString);
- };
- #endif // QDBUS
(2)main.cpp
- #include <QCoreApplication>
- #include <QObject>
- #include <QtDBus>
- #include "qdbus.h"
-
- void DeviceManager::slotInterface(QString str)
- {
- qDebug() << "D-Bus Interface(com.asianux.btagent2.interface):" << str;
- }
-
- int main(int argc, char *argv[])
- {
- QCoreApplication a(argc, argv);
- QDBusConnection bus = QDBusConnection::sessionBus();
- if(!bus.registerService("com.asianux.btagent2")){
- qDebug() << bus.lastError().message();
- exit(1);
- }
- DeviceManager *deviceManager = new DeviceManager();
- bus.registerObject("/", deviceManager, QDBusConnection::ExportAllSlots);
- return a.exec();
- }
運行結(jié)果:
3、其他網(wǎng)上代碼
D-Bus的QT4綁定
下面,我們通過一個實例來介紹D-Bus的QT4綁定。(參見hotel.pro)
在Session bus上創(chuàng)建一個"com.test.hotel" service,通過這個service可以執(zhí)行check in,check out和query三個動作。
創(chuàng)建Service并且注冊Object:
// 用于建立到session bus的連接 QDBusConnection bus = QDBusConnection::sessionBus();
// 在session bus上注冊名為"com.test.hotel"的service if (!bus.registerService("com.test.hotel")){ qDebug()<< bus.lastError().message(); exit(1); } Hotel my_hotel;
// 注冊名為"/hotel/registry"的object。 // "QDBusConnection::ExportAllSlots"
// 表示把類Hotel的所有Slot都導出為這個Object的method bus.registerObject("/hotel/registry",&my_hotel, QDBusConnection::ExportAllSlots); return a.exec(); }
|
再看一下Hotel類的定義。
class Hotel:public QObject { Q_OBJECT
// 定義Interface名稱為"com.test.hotel.registry" Q_CLASSINFO("D-Bus Interface","com.test.hotel.registry") public: Hotel() { m_rooms = MAX_ROOMS;} public slots: // Check in,參數(shù)為房間數(shù),返回成功拿到的房間數(shù) int checkIn(int num_room); // Check out,參數(shù)為房間數(shù),返回成功退回的房間數(shù) int checkOut(int num_room); // Query,用于查詢目前還剩下的房間數(shù) int query(); private: int m_rooms; QReadWriteLock m_lock; };
|
運行這個程序,我們可以使用qdbusviewer查看和操作這個Object。
通過QDBusMessage訪問Service
在QT4中,用QDBusMessage表示在D-Bus上發(fā)送和接收的Message。(參見checkin.pro)
// 用來構(gòu)造一個在D-Bus上傳遞的Message QDBusMessage m = QDBusMessage::createMethodCall("com.test.hotel", "/hotel/registry", "com.test.hotel.registry", "checkIn"); if (argc== 2){ // 給QDBusMessage增加一個參數(shù); // 這是一種比較友好的寫法,也可以用setArguments來實現(xiàn) m << QString(argv[1]).toInt(); }
// 發(fā)送Message QDBusMessage response = QDBusConnection::sessionBus().call(m); // 判斷Method是否被正確返回 if (response.type()== QDBusMessage::ReplyMessage){ // QDBusMessage的arguments不僅可以用來存儲發(fā)送的參數(shù),也用來存儲返回值; // 這里取得checkIn的返回值 int num_room = response.arguments().takeFirst().toInt(); printf("Got %d %s\n", num_room,(num_room> 1)?"rooms": "room"); } else { fprintf(stderr,"Check In fail!\n"); }
|
通過QDBusInterface 訪問Service
在QT4中,QDBusInterface可以更加方便的訪問Service。(參見checkin2.pro)
// 創(chuàng)建QDBusInterface QDBusInterface iface( "com.test.hotel", "/hotel/registry", "com.test.hotel.registry",
QDBusConnection::sessionBus()); if (!iface.isValid()){ qDebug()<<
qPrintable(QDBusConnection::sessionBus(). lastError().message()); exit(1); }
// 呼叫遠程的checkIn,參數(shù)為num_room QDBusReply<int> reply= iface.call("checkIn", num_room); if (reply.isValid()){ num_room = reply.value(); printf("Got %d %s\n", num_room,(num_room> 1)?"rooms": "room"); } else { fprintf(stderr,"Check In fail!\n"); }
|
看,用QDBusInterface來訪問Service是不是更加方便?
從D-Bus XML自動生成Proxy類
用QDB usInterface訪問Service已經(jīng)非常方便了,但還不夠直觀。還有沒有更直觀的方法,就像訪問本地類成員變量的方式訪問遠程的method?答案是Proxy。
Proxy Object提供了一種更加直觀的方式來訪問Service,就好像調(diào)用本地對象的方法一樣。
概括的說,達成上述目標需要分三步走:
(1)使用工具qdbuscpp2xml從hotel.h生成XML文件;
qdbuscpp2xml -M hotel.h -o com.test.hotel.xml
(2)使用工具qdbusxml2cpp從XML文件生成繼承自QDBusInterface的類;
qdbusxml2cpp com.test.hotel.xml -i hotel.h -p hotelInterface
這條命令會生成兩個文件:hotelInterface.cpp和hotelInterface.h
(3)調(diào)用(2)生成的類來訪問Service。
下面是舉例(參見checkin3.pro ):
// 初始化自動生成的Proxy類com::test::hotel::registry com::test::hotel::registry myHotel("com.test.hotel", "/hotel/registry", QDBusConnection::sessionBus()); // 調(diào)用checkIn QDBusPendingReply<int> reply= myHotel.checkIn(num_room); // qdbusxml2cpp生成的Proxy類是采用異步的方式來傳遞Message, // 所以在此需要調(diào)用waitForFinished來等到Message執(zhí)行完成 reply.waitForFinished(); if (reply.isValid()){ num_room = reply.value(); printf("Got %d %s\n", num_room,(num_room> 1)?"rooms": "room"); } else { fprintf(stderr,"Check In fail!\n"); };
|
使用Adapter注冊Object
如前文所述,我們可以直接把class Hotel注冊為Message Bus上的一個Object,但這種方式并不是QT4所推薦的。QT4推薦使用Adapter來注冊Object。
很多情況下,我們可能只需要把我們定義的類里的方法有選擇的發(fā)布到Message Bus上,使用Adapter可以很方便的實現(xiàn)這種意圖。
以前文中的Hotel為例,假設我們只需要把checkIn和checkOut發(fā)布到Message Bus上,應該怎么辦?
(1)使用工具 qdbuscpp2xml從hotel.h生成XML文件;
qdbuscpp2xml -M hotel.h -o com.test.hotel.xml
(2)編輯com.test.hotel.xml,把其中的query部分去掉;
即去掉以下三條語句: <method name="query">
<arg type="i" direction="out"/>
</method>
(3)使用工具qdbusxml2cpp從XML文件生成繼承自QDBusInterface的類;
qdbusxml2cpp com.test.hotel.xml -i hotel.h -a hotelAdaptor
這條命令會生成兩個文件:hotelAdaptor.cpp和hotelAdaptor.h
(4)調(diào)用(3)生成的類來注冊Object。(參見hotel2.pro)
int main(int argc,char*argv[]) { QCoreApplication a(argc, argv); QDBusConnection bus = QDBusConnection::sessionBus(); Hotel myHotel; // RegistryAdaptor是qdbusxml2cpp生成的Adaptor類 RegistryAdaptor myAdaptor(&myHotel); if (!bus.registerService("com.test.hotel")){ qDebug()<< bus.lastError().message(); exit(1); } bus.registerObject("/hotel/registry",&myHotel); return a.exec(); }
|
運行這個應用程序,我們從qdbusviewer上可以看到,只有checkIn和checkOut兩個method被發(fā)布。
自動啟動Service
D-Bus系統(tǒng)提供了一種機制可以在訪問某個service時,自動把該程序運行起來。
我們需要在/usr/share/dbus-1/services下面建立com.test.hotel.service文件,文件的內(nèi)容如下:
[D-BUS Service]
Name=com.test.hotel
Exec=/path/to/your/hotel
這樣,我們在訪問Hotel的method之前,就不必手動運行該應用程序了。
4、其他細節(jié)
(1)如果想使用system bus(自啟動服務參考上述),需要在/etc/dbus-1/system.d/目錄下創(chuàng)建一個配置文件my.conf:
- <!DOCTYPE busconfig PUBLIC
- "-//freedesktop//DTD D-BUS Bus Configuration 1.0//EN"
- "http://www./standards/dbus/1.0/busconfig.dtd">
- <busconfig>
- <policy context="default">
- <allow own="com.asianux.btagent2"/>
- <allow send_destination="com.asianux.btagent2"/>
- <allow receive_sender="com.asianux.btagent2"/>
- </policy>
- </busconfig>
(2)可以參考通過QDbus實現(xiàn)的Qt檢測U盤的例子:http://download.csdn.net/detail/taiyang1987912/8686677 (3)除了DBus,也可使用SIGHUP信號用于進程間通信,比如重寫了配置文件,又不想重啟程序就讓配置生效,可以往該程序的進程發(fā)送一個SIGHUP信號:killall -HUP <進程名稱>或kill -HUP <進程號>,可能因以前的系統(tǒng)沒有提供用戶自定義信號 SIGUSR1 和 SIGUSR1 ,而對于一個沒有終端的守護進程來說是不可能收到 SIGHUP 信號的,所以就把 SIGHUP 當用戶自定義信號使用。
- #include<stdio.h>
- #include <stdlib.h>
- #include<signal.h>
- char**args;
-
- void exithandle(int sig)
- {
- printf("%s:(%d)sighup received\n", args[0], sig);
- exit(0);
- }
-
- int main(int argc,char **argv)
- {
- args = argv;
- signal(SIGHUP,exithandle);
- while(1) sleep(1);
- return 0;
- }
運行程序,打開另終端發(fā)送killall -HUP ./sighupcode,則會處理SIGHUP信號:
三、詳解之C代碼
1、代碼
使用C語言調(diào)用dbus的底層函數(shù)編寫一個遠程調(diào)用的示例代碼,代碼很簡單,沒使用GObject等一些復雜的庫。 (1)method_send.c
- #include <stdio.h>
- #include <stdlib.h>
- #include <string.h>
- #include <dbus/dbus-glib.h>
- #include <dbus/dbus.h>
- #include <unistd.h>
- /*gcc -o method_send method_send.c -I/usr/include/glib-2.0 -I/usr/include/dbus-1.0 -I/usr/lib64/glib-2.0/include -I/usr/lib64/dbus-1.0/include -lglib-2.0 -ldbus-glib-1*/
- void reply_to_method_call(DBusMessage * msg, DBusConnection * conn)
- {
- DBusMessage * reply;
- DBusMessageIter arg;
- char * param = NULL;
- dbus_bool_t stat = TRUE;
- dbus_uint32_t level = 2010;
- dbus_uint32_t serial = 0;
-
- //從msg中讀取參數(shù),這個在上一次學習中學過
- if(!dbus_message_iter_init(msg,&arg))
- printf("Message has noargs\n");
- else if(dbus_message_iter_get_arg_type(&arg)!= DBUS_TYPE_STRING)
- printf("Arg is notstring!\n");
- else
- dbus_message_iter_get_basic(&arg,& param);
- if(param == NULL) return;
- //創(chuàng)建返回消息reply
- reply = dbus_message_new_method_return(msg);
- //在返回消息中填入兩個參數(shù),和信號加入?yún)?shù)的方式是一樣的。這次我們將加入兩個參數(shù)。
- dbus_message_iter_init_append(reply,&arg);
- if(!dbus_message_iter_append_basic(&arg,DBUS_TYPE_BOOLEAN,&stat)){
- printf("Out ofMemory!\n");
- exit(1);
- }
- if(!dbus_message_iter_append_basic(&arg,DBUS_TYPE_UINT32,&level)){
- printf("Out ofMemory!\n");
- exit(1);
- }
- //發(fā)送返回消息
- if( !dbus_connection_send(conn, reply,&serial)){
- printf("Out of Memory\n");
- exit(1);
- }
- dbus_connection_flush (conn);
- dbus_message_unref (reply);
- }
-
- void listen_dbus()
- {
- DBusMessage * msg;
- DBusMessageIter arg;
- DBusConnection * connection;
- DBusError err;
- int ret;
- char * sigvalue;
- dbus_error_init(&err);
- //創(chuàng)建于session D-Bus的連接
- connection =dbus_bus_get(DBUS_BUS_SESSION, &err);
- if(dbus_error_is_set(&err)){
- fprintf(stderr,"ConnectionError %s\n",err.message);
- dbus_error_free(&err);
- }
- if(connection == NULL)
- return;
- //設置一個BUS name:test.wei.dest
- ret =dbus_bus_request_name(connection,"test.wei.dest",DBUS_NAME_FLAG_REPLACE_EXISTING,&err);
- if(dbus_error_is_set(&err)){
- fprintf(stderr,"Name Error%s\n",err.message);
- dbus_error_free(&err);
- }
- if(ret !=DBUS_REQUEST_NAME_REPLY_PRIMARY_OWNER)
- return;
- //要求監(jiān)聽某個singal:來自接口test.signal.Type的信號
- dbus_bus_add_match(connection,"type='signal',interface='test.signal.Type'",&err);
- dbus_connection_flush(connection);
- if(dbus_error_is_set(&err)){
- fprintf(stderr,"Match Error%s\n",err.message);
- dbus_error_free(&err);
- }
- while(1){
- dbus_connection_read_write(connection,0);
- msg =dbus_connection_pop_message (connection);
-
- if(msg == NULL){
- sleep(1);
- continue;
- }
-
- if(dbus_message_is_signal(msg,"test.signal.Type","Test")){
- if(!dbus_message_iter_init(msg,&arg))
- fprintf(stderr,"Message Has no Param");
- else if(dbus_message_iter_get_arg_type(&arg) != DBUS_TYPE_STRING)
- g_printerr("Param isnot string");
- else
- dbus_message_iter_get_basic(&arg,&sigvalue);
- }else if(dbus_message_is_method_call(msg,"test.method.Type","Method")){
- //我們這里面先比較了接口名字和方法名字,實際上應當現(xiàn)比較路徑
- if(strcmp(dbus_message_get_path(msg),"/test/method/Object") == 0)
- reply_to_method_call(msg,connection);
- }
- dbus_message_unref(msg);
- }
- }
-
- int main( int argc , char ** argv)
- {
- listen_dbus();
- return 0;
- }
(2)method_recv.c
- #include <stdio.h>
- #include <stdlib.h>
- #include <string.h>
- #include <dbus/dbus-glib.h>
- #include <dbus/dbus.h>
- #include <unistd.h>
- /*gcc -o method_recv method_recv.c -I/usr/include/glib-2.0 -I/usr/include/dbus-1.0 -I/usr/lib64/glib-2.0/include -I/usr/lib64/dbus-1.0/include -lglib-2.0 -ldbus-glib-1*/
- //建立與session D-Bus daemo的連接,并設定連接的名字,相關的代碼已經(jīng)多次使用過了
- DBusConnection * connect_dbus()
- {
- DBusError err;
- DBusConnection * connection;
- int ret;
-
- //Step 1: connecting session bus
- dbus_error_init(&err);
-
- connection =dbus_bus_get(DBUS_BUS_SESSION, &err);
- if(dbus_error_is_set(&err)){
- fprintf(stderr,"ConnectionErr : %s\n",err.message);
- dbus_error_free(&err);
- }
- if(connection == NULL)
- return NULL;
- //step 2: 設置BUS name,也即連接的名字。
- ret =dbus_bus_request_name(connection,"test.wei.source",DBUS_NAME_FLAG_REPLACE_EXISTING,&err);
- if(dbus_error_is_set(&err)){
- fprintf(stderr,"Name Err :%s\n",err.message);
- dbus_error_free(&err);
- }
- if(ret !=DBUS_REQUEST_NAME_REPLY_PRIMARY_OWNER)
- return NULL;
-
- return connection;
- }
-
- void send_a_method_call(DBusConnection * connection,char * param)
- {
- DBusError err;
- DBusMessage * msg;
- DBusMessageIter arg;
- DBusPendingCall * pending;
- dbus_bool_t * stat;
- dbus_uint32_t * level;
-
- dbus_error_init(&err);
- //針對目的地地址,請參考圖,創(chuàng)建一個method call消息。Constructs a new message to invoke a method on a remote object.
- msg =dbus_message_new_method_call ("test.wei.dest","/test/method/Object","test.method.Type","Method");
- if(msg == NULL){
- g_printerr("MessageNULL");
- return;
- }
-
- //為消息添加參數(shù)。Appendarguments
- dbus_message_iter_init_append(msg, &arg);
- if(!dbus_message_iter_append_basic(&arg, DBUS_TYPE_STRING,&stat)){
- g_printerr("Out of Memory!");
- exit(1);
- }
-
- //發(fā)送消息并獲得reply的handle。Queues amessage to send, as withdbus_connection_send() , but also returns aDBusPendingCall used to receive a reply to the message.
- if(!dbus_connection_send_with_reply (connection, msg,&pending, -1)){
- g_printerr("Out of Memory!");
- exit(1);
- }
-
- if(pending == NULL){
- g_printerr("Pending CallNULL: connection is disconnected ");
- dbus_message_unref(msg);
- return;
- }
-
- dbus_connection_flush(connection);
- dbus_message_unref(msg);
-
- //waiting a reply,在發(fā)送的時候,已經(jīng)獲取了methodreply的handle,類型為DBusPendingCall。
- // block until we recieve a reply, Block until the pendingcall is completed.
- dbus_pending_call_block (pending);
- //get the reply message,Gets thereply, or returns NULL if none has been received yet.
- msg =dbus_pending_call_steal_reply (pending);
- if (msg == NULL) {
- fprintf(stderr, "ReplyNull\n");
- exit(1);
- }
- // free the pendingmessage handle
- dbus_pending_call_unref(pending);
- // read the parameters
- if(!dbus_message_iter_init(msg, &arg))
- fprintf(stderr, "Message hasno arguments!\n");
- else if (dbus_message_iter_get_arg_type(&arg) != DBUS_TYPE_BOOLEAN)
- fprintf(stderr, "Argument isnot boolean!\n");
- else
- dbus_message_iter_get_basic(&arg, &stat);
-
- if (!dbus_message_iter_next(&arg))
- fprintf(stderr, "Message hastoo few arguments!\n");
- else if (dbus_message_iter_get_arg_type(&arg) != DBUS_TYPE_UINT32 )
- fprintf(stderr, "Argument isnot int!\n");
- else
- dbus_message_iter_get_basic(&arg, &level);
-
- printf("Got Reply: %d,%d\n", stat, level);
- dbus_message_unref(msg);
- }
- int main( int argc , char ** argv)
- {
- DBusConnection * connection;
- connection = connect_dbus();
- if(connection == NULL)
- return -1;
-
- send_a_method_call(connection,"Hello, D-Bus");
- return 0;
- }
(3)編譯運行(先運行method_send) 編譯method_send.c:
編譯method_recv.c(得到運行結(jié)果):
四、總結(jié)
(1)本文僅提供代碼的測試,其他的具體函數(shù)的意義請查閱相應的幫助文檔。 (2)源碼已經(jīng)打包上傳到csdn上,可登錄下載(http://download.csdn.net/detail/taiyang1987912/8687183)。 (3)若有建議,請留言,在此先感謝!
http://blog.csdn.net/taiyang1987912/article/details/45642079
|