0

我想使用 PyQt4.QtDBus 对远程 D-Bus 服务中的函数进行非阻塞调用。改编自 Qt 的 C++ 文档，我想出了以下测试程序：

from PyQt4 import QtCore, QtDBus

class DeviceInterface(QtDBus.QDBusAbstractInterface):

    def __init__(self, service, path, connection, parent=None):
        super().__init__(service, path, 'org.freedesktop.UDisks.Device',
                         connection, parent)

    @QtCore.pyqtSlot(QtDBus.QDBusArgument)
    def callFinishedSlot(self, arg):
        print("Got result:", arg)


if __name__ == '__main__':
    import sys
    app = QtCore.QCoreApplication(sys.argv)

    dev = DeviceInterface('org.freedesktop.UDisks',
                          '/org/freedesktop/UDisks/devices/sda1',
                          QtDBus.QDBusConnection.systemBus(), app)

    async = dev.asyncCall("FilesystemListOpenFiles");
    watcher = QtDBus.QDBusPendingCallWatcher(async, dev)
    watcher.finished.connect(dev.callFinishedSlot)
    sys.exit(app.exec_())

它似乎工作。当我运行它时，它会打印：

Got result: <PyQt4.QtDBus.QDBusPendingCallWatcher object at 0xb740c77c>

问题是，我不知道如何将 转换为可以从中提取结果的QDBusPendingCallWatcher东西（例如）。C++ 文档QDBusMessage中的示例执行此操作：

 void MyClass.callFinishedSlot(QDBusPendingCallWatcher *call)
 {
     QDBusPendingReply<QString, QByteArray> reply = *call;
     if (reply.isError()) {
         showError();
     } else {
         QString text = reply.argumentAt<0>();
         QByteArray data = reply.argumentAt<1>();
         showReply(text, data);
     }
     call->deleteLater();
 }

谁能告诉我如何将 C++ 插槽转换为适用于 PyQt4 的东西？（我将 PyQt4.9.1 与 Qt 4.8.1 一起使用。）

4

1 回答 1

0

好的，诀窍似乎是QDBusPendingReply从实例构造一个（非常感谢 Phil Thompson 在PyQt 邮件列表QDBusPendingCallWatcher中指出这一点）。事实证明，同样的技术也适用于 C++。我的原始代码中的 UDisk 对象路径错误，加上其他一些小错别字，所以这里有一个完整的工作示例，供后人参考：

from PyQt4 import QtCore, QtDBus

class DeviceInterface(QtDBus.QDBusAbstractInterface):

    def __init__(self, service, path, connection, parent=None):
        super().__init__(service, path, 'org.freedesktop.UDisks.Device',
                         connection, parent)

    def callFinishedSlot(self, call):
        # Construct a reply object from the QDBusPendingCallWatcher
        reply = QtDBus.QDBusPendingReply(call)
        if reply.isError():
            print(reply.error().message())
        else:
            print("  PID        UID     COMMAND")
            print("-------    -------   ------------------------------------")
            for pid, uid, cmd in reply.argumentAt(0):
                print("{0:>7d}    {1:>7d}   {2}".format(pid, uid, cmd))
        # Important: Tell Qt we are finished processing this message
        call.deleteLater()

if __name__ == '__main__':
    import sys
    import signal
    signal.signal(signal.SIGINT, signal.SIG_DFL)

    app = QtCore.QCoreApplication(sys.argv)

    dev = DeviceInterface('org.freedesktop.UDisks',
                          '/org/freedesktop/UDisks/devices/sda1',
                          QtDBus.QDBusConnection.systemBus(), app)

    async = dev.asyncCall("FilesystemListOpenFiles");
    watcher = QtDBus.QDBusPendingCallWatcher(async, dev)
    watcher.finished.connect(dev.callFinishedSlot)
    sys.exit(app.exec_())

这应该适用于最新的 Linux 发行版，并且是使用 PyQt 调用返回复合类型的 D-Bus 方法的一个很好的例子。

于 2012-08-13T15:48:33.283 回答