Краткое описание проблемы: qdbusxml2cpp
генерирует QDBusAbstractInterface
подкласс, методы которого выбирают ответы D-Bus асинхронно, но я хочу, чтобы он был синхронным (т.е. он должен блокироваться до получения ответа).
XML вход:
<?xml version="1.0"?>
<!DOCTYPE node PUBLIC "-//freedesktop//DTD D-BUS Object Introspection 1.0//EN" "http://www.freedesktop.org/standards/dbus/1.0/introspect.dtd">
<node>
<interface name="some.interface.Foo">
<method name="GetValues">
<arg name="values" type="a(oa{sv})" direction="out"/>
<annotation name="org.qtproject.QtDBus.QtTypeName.Out0" value="QList<SomeStruct>" />
</method>
</interface>
</node>
С помощью этой команды генерируется заголовок и файл .cpp (не показан):
qdbusxml2cpp-qt5 -c InterfaceFoo -p interface_foo foo.xml
Сгенерированный заголовок:
class InterfaceFoo: public QDBusAbstractInterface
{
Q_OBJECT
public:
static inline const char *staticInterfaceName()
{ return "some.interface.Foo"; }
public:
InterfaceFoo(const QString &service, const QString &path, const QDBusConnection &connection, QObject *parent = 0);
~InterfaceFoo();
public Q_SLOTS: // METHODS
inline QDBusPendingReply<QList<SomeStruct> > GetValues()
{
QList<QVariant> argumentList;
// NOTICE THIS LINE.
return asyncCallWithArgumentList(QStringLiteral("GetValues"), argumentList);
}
Q_SIGNALS: // SIGNALS
};
namespace some {
namespace interface {
typedef ::InterfaceFoo Foo;
}
}
#endif
Как вы можете увидеть метод, сгенерированный asyncCallWithArgumentList()
асинхронный: он ожидает connect()
переход к слоту, который срабатывает при получении ответа по шине D-Bus.
Вместо этого я хочу иметь возможность сделать:
some::interface::Foo *interface = new some::interface::Foo("some::interface", "/Foo", QDBusConnection::systemBus(), this);
// THIS SHOULD block until a reply is received or it times out.
QList<SomeStruct> data = interface->GetValues();
Вы могли бы использовать value()
на возвращаемое значение для блокировки, с GetValues()
как есть:
auto reply = interface->GetValues();
auto data = reply.value<QList<QVariant>>();
Увы, созданный интерфейс должен быть сгенерирован один раз, а затем стать частью ваших источников. Вы должны изменить его, чтобы использовать блокирующий вызов, и добавить преобразование из варианта в конкретный тип:
inline QDBusPendingReply<QList<SomeStruct>> GetValues()
{
QList<QVariant> argumentList;
auto msg = callWithArgumentList(QDBus::Block, QStringLiteral("GetValues"), argumentList);
Q_ASSERT(msg.type() == QDBusMessage::ReplyMessage);
QList<SomeStruct> result;
for (auto const & arg : msg.arguments())
result << arg.value<SomeStruct>();
return result;
}
Наконец, вы, возможно, захотите пересмотреть вопрос о том, чтобы сделать его синхронным: реальный мир асинхронен, поэтому написание кода, как если бы его не было, часто приводит к обратным результатам. Если ваш код работает в главном потоке, и в нем есть графический интерфейс, вы будете плохо работать с пользователем. Если вы перемещаете свой код в рабочий поток, вы тратите впустую весь поток только для поддержки стиля синхронного кодирования. Даже если вы пишете, что составляет неинтерактивную утилиту / службу пакетного типа, вы потенциально увеличиваете задержку, например, не звонить параллельно.
Других решений пока нет …