mirror of
https://github.com/swift-project/pilotclient.git
synced 2026-03-31 21:15:33 +08:00
59da68da5e
Previously, the DBusconnection had to be set at construction time and could not be changed over the DBusObject life time. Now a new connection can be set anytime and as often as required. The shared ownership is now also properly implemented by shared pointers. ref T291
97 lines
3.5 KiB
C++
97 lines
3.5 KiB
C++
/* Copyright (C) 2018
|
|
* swift project Community / Contributors
|
|
*
|
|
* This file is part of swift project. It is subject to the license terms in the LICENSE file found in the top-level
|
|
* directory of this distribution and at http://www.swift-project.org/license.html. No part of swift project,
|
|
* including this file, may be copied, modified, propagated, or distributed except according to the terms
|
|
* contained in the LICENSE file.
|
|
*/
|
|
|
|
#ifndef BLACKSIM_XSWIFTBUS_DBUSOBJECT_H
|
|
#define BLACKSIM_XSWIFTBUS_DBUSOBJECT_H
|
|
|
|
#include "dbusconnection.h"
|
|
#include <XPLM/XPLMDisplay.h>
|
|
#include <mutex>
|
|
#include <deque>
|
|
|
|
namespace XSwiftBus
|
|
{
|
|
//! DBus base object
|
|
class CDBusObject
|
|
{
|
|
public:
|
|
//! Constructor
|
|
CDBusObject();
|
|
|
|
//! Destructor
|
|
virtual ~CDBusObject();
|
|
|
|
//! Set the assigned DBus connection.
|
|
//! \remark Currently one object can only manage one connection at a time
|
|
void setDBusConnection(const std::shared_ptr<CDBusConnection> &dbusConnection);
|
|
|
|
//! Register itself with interfaceName and objectPath
|
|
//! \warning Before calling this method, make sure that a valid DBus connection was set.
|
|
void registerDBusObjectPath(const std::string &interfaceName, const std::string &objectPath);
|
|
|
|
//! Process DBus messages. Needs to be implemented by deriving classes
|
|
virtual int processDBus() = 0;
|
|
|
|
protected:
|
|
//! DBus message handler
|
|
virtual DBusHandlerResult dbusMessageHandler(const CDBusMessage &message) = 0;
|
|
|
|
//! Send DBus signal
|
|
void sendDBusSignal(const std::string &name);
|
|
|
|
//! Send DBus message
|
|
void sendDBusMessage(const CDBusMessage &message);
|
|
|
|
//! Maybe sends an empty DBus reply (acknowledgement)
|
|
void maybeSendEmptyDBusReply(bool wantsReply, const std::string &destination, dbus_uint32_t serial);
|
|
|
|
//! Send DBus reply
|
|
template <typename T>
|
|
void sendDBusReply(const std::string &destination, dbus_uint32_t serial, const T &argument)
|
|
{
|
|
CDBusMessage reply = CDBusMessage::createReply(destination, serial);
|
|
reply.beginArgumentWrite();
|
|
reply.appendArgument(argument);
|
|
m_dbusConnection->sendMessage(reply);
|
|
}
|
|
|
|
//! Send DBus reply
|
|
template <typename T>
|
|
void sendDBusReply(const std::string &destination, dbus_uint32_t serial, const std::vector<T> &array)
|
|
{
|
|
CDBusMessage reply = CDBusMessage::createReply(destination, serial);
|
|
reply.beginArgumentWrite();
|
|
reply.appendArgument(array);
|
|
m_dbusConnection->sendMessage(reply);
|
|
}
|
|
|
|
//! Queue a DBus call to be executed in a different thread
|
|
void queueDBusCall(const std::function<void()> &func);
|
|
|
|
//! Invoke all pending DBus calls. They will be executed in the calling thread.
|
|
void invokeQueuedDBusCalls();
|
|
|
|
private:
|
|
static void dbusObjectPathUnregisterFunction(DBusConnection *connection, void *data);
|
|
static DBusHandlerResult dbusObjectPathMessageFunction(DBusConnection *connection, DBusMessage *message, void *data);
|
|
|
|
std::shared_ptr<CDBusConnection> m_dbusConnection;
|
|
std::string m_interfaceName;
|
|
std::string m_objectPath;
|
|
|
|
std::mutex m_mutex;
|
|
std::deque<std::function<void()>> m_qeuedDBusCalls;
|
|
|
|
const DBusObjectPathVTable m_dbusObjectPathVTable = { dbusObjectPathUnregisterFunction, dbusObjectPathMessageFunction, nullptr, nullptr, nullptr, nullptr };
|
|
};
|
|
|
|
}
|
|
|
|
#endif // guard
|