#include <tqdbusconnection_p.h>
Definition at line 69 of file tqdbusconnection_p.h.
◆ ObjectMap
◆ PendingCallMap
◆ PendingMessagesForEmit
◆ TimeoutHash
◆ WatcherHash
◆ WatcherList
◆ ConnectionMode
◆ TQT_DBusConnectionPrivate()
| TQT_DBusConnectionPrivate::TQT_DBusConnectionPrivate |
( |
TQObject * |
parent = 0 | ) |
|
◆ ~TQT_DBusConnectionPrivate()
| TQT_DBusConnectionPrivate::~TQT_DBusConnectionPrivate |
( |
| ) |
|
◆ bindToApplication()
| void TQT_DBusConnectionPrivate::bindToApplication |
( |
| ) |
|
◆ closeConnection()
| void TQT_DBusConnectionPrivate::closeConnection |
( |
| ) |
|
◆ dbusPendingCallReply
| void TQT_DBusConnectionPrivate::dbusPendingCallReply |
( |
const TQT_DBusMessage & |
message | ) |
|
|
signal |
◆ dbusSignal
| void TQT_DBusConnectionPrivate::dbusSignal |
( |
const TQT_DBusMessage & |
message | ) |
|
|
signal |
◆ dispatch
| void TQT_DBusConnectionPrivate::dispatch |
( |
| ) |
|
|
slot |
◆ emitPendingCallReply()
| void TQT_DBusConnectionPrivate::emitPendingCallReply |
( |
const TQT_DBusMessage & |
message | ) |
|
◆ flush()
| void TQT_DBusConnectionPrivate::flush |
( |
| ) |
|
◆ handleError()
| bool TQT_DBusConnectionPrivate::handleError |
( |
| ) |
|
◆ handleObjectCall()
| bool TQT_DBusConnectionPrivate::handleObjectCall |
( |
DBusMessage * |
message | ) |
|
◆ handleSignal()
| bool TQT_DBusConnectionPrivate::handleSignal |
( |
DBusMessage * |
msg | ) |
|
◆ newMethodInResultEmissionQueue()
| void TQT_DBusConnectionPrivate::newMethodInResultEmissionQueue |
( |
| ) |
|
◆ objectDestroyed
| void TQT_DBusConnectionPrivate::objectDestroyed |
( |
TQObject * |
object | ) |
|
|
slot |
Definition at line 404 of file tqdbusintegrator.cpp.
409 TQObject* receiver = (TQObject*) it.data()->receiver;
410 if (receiver ==
object || receiver == 0)
412 PendingCallMap::iterator copyIt = it;
415 dbus_pending_call_cancel(copyIt.key());
416 dbus_pending_call_unref(copyIt.key());
417 delete copyIt.data();
References pendingCalls.
◆ purgeRemovedWatches
| void TQT_DBusConnectionPrivate::purgeRemovedWatches |
( |
| ) |
|
|
slot |
Definition at line 425 of file tqdbusintegrator.cpp.
432 delete (*listIt).read;
433 delete (*listIt).write;
438 WatcherHash::iterator it =
watchers.begin();
442 listIt = list.begin();
443 while (listIt != list.end())
445 if (!((*listIt).read) && !((*listIt).write))
447 listIt = list.erase(listIt);
454 WatcherHash::iterator copyIt = it;
References removedWatches, and watchers.
◆ registerMessageMetaType()
| int TQT_DBusConnectionPrivate::registerMessageMetaType |
( |
| ) |
|
|
static |
◆ scheduleDispatch
| void TQT_DBusConnectionPrivate::scheduleDispatch |
( |
| ) |
|
|
slot |
◆ sendWithReplyAsync()
| int TQT_DBusConnectionPrivate::sendWithReplyAsync |
( |
const TQT_DBusMessage & |
message, |
|
|
TQObject * |
receiver, |
|
|
const char * |
method |
|
) |
| |
Definition at line 628 of file tqdbusintegrator.cpp.
631 if (!receiver || !method)
634 if (!TQObject::connect(receiver, TQT_SIGNAL(destroyed(TQObject*)),
643 DBusPendingCall *pending = 0;
644 if (dbus_connection_send_with_reply(
connection, msg, &pending, message.
timeout())) {
645 TQT_DBusPendingCall *pcall =
new TQT_DBusPendingCall;
646 pcall->receiver = receiver;
647 pcall->method = method;
648 pcall->pending = pending;
653 msg_serial = dbus_message_get_serial(msg);
656 dbus_message_unref(msg);
References connection, TQT_DBusConnectionPrivate::TQT_DBusPendingCall::method, objectDestroyed(), TQT_DBusConnectionPrivate::TQT_DBusPendingCall::pending, pendingCalls, qDBusResultReceived(), TQT_DBusConnectionPrivate::TQT_DBusPendingCall::receiver, TQT_DBusMessage::timeout(), and TQT_DBusMessage::toDBusMessage().
◆ setConnection()
| void TQT_DBusConnectionPrivate::setConnection |
( |
DBusConnection * |
connection | ) |
|
Definition at line 553 of file tqdbusintegrator.cpp.
563 dbus_connection_set_exit_on_disconnect(
connection,
false);
577 const char *service = dbus_bus_get_unique_name(
connection);
580 filter +=
"destination='";
590 tqWarning(
"TQT_DBusConnectionPrivate::SetConnection: Unable to get unique name");
References ClientMode, closeConnection(), connection, error, handleError(), mode, qDBusAddTimeout(), qDBusAddWatch(), qDBusRemoveTimeout(), qDBusRemoveWatch(), qDBusSignalFilter(), qDBusToggleTimeout(), and qDBusToggleWatch().
◆ setServer()
| void TQT_DBusConnectionPrivate::setServer |
( |
DBusServer * |
server | ) |
|
Definition at line 530 of file tqdbusintegrator.cpp.
References handleError(), mode, qDBusAddTimeout(), qDBusAddWatch(), qDBusNewConnection(), qDBusRemoveTimeout(), qDBusRemoveWatch(), qDBusToggleTimeout(), qDBusToggleWatch(), server, server_slot, and ServerMode.
◆ socketRead
| void TQT_DBusConnectionPrivate::socketRead |
( |
int |
fd | ) |
|
|
slot |
Definition at line 372 of file tqdbusintegrator.cpp.
375 WatcherHash::const_iterator it =
watchers.find(fd);
378 for (WatcherList::const_iterator wit = list.begin(); wit != list.end(); ++wit) {
379 if ((*wit).read && (*wit).read->isEnabled()) {
380 if (!dbus_watch_handle((*wit).watch, DBUS_WATCH_READABLE))
381 tqDebug(
"OUT OF MEM");
References ClientMode, mode, scheduleDispatch(), and watchers.
◆ socketWrite
| void TQT_DBusConnectionPrivate::socketWrite |
( |
int |
fd | ) |
|
|
slot |
Definition at line 389 of file tqdbusintegrator.cpp.
392 WatcherHash::const_iterator it =
watchers.find(fd);
395 for (WatcherList::const_iterator wit = list.begin(); wit != list.end(); ++wit) {
396 if ((*wit).write && (*wit).write->isEnabled()) {
397 if (!dbus_watch_handle((*wit).watch, DBUS_WATCH_WRITABLE))
398 tqDebug(
"OUT OF MEM");
References watchers.
◆ timerEvent()
| void TQT_DBusConnectionPrivate::timerEvent |
( |
TQTimerEvent * |
e | ) |
|
◆ transmitMessageEmissionQueue
| void TQT_DBusConnectionPrivate::transmitMessageEmissionQueue |
( |
| ) |
|
|
privateslot |
◆ transmitResultEmissionQueue
| void TQT_DBusConnectionPrivate::transmitResultEmissionQueue |
( |
| ) |
|
|
privateslot |
◆ connection
| DBusConnection* TQT_DBusConnectionPrivate::connection |
◆ dispatcher
| TQTimer* TQT_DBusConnectionPrivate::dispatcher |
◆ error
| DBusError TQT_DBusConnectionPrivate::error |
◆ inDispatch
| bool TQT_DBusConnectionPrivate::inDispatch |
◆ lastError
◆ m_messageEmissionQueueTimer
| TQTimer* TQT_DBusConnectionPrivate::m_messageEmissionQueueTimer |
|
private |
◆ m_resultEmissionQueue
◆ m_resultEmissionQueueTimer
| TQTimer* TQT_DBusConnectionPrivate::m_resultEmissionQueueTimer |
|
private |
◆ messageMetaType
| int TQT_DBusConnectionPrivate::messageMetaType = 0 |
|
static |
◆ mode
◆ pendingCalls
◆ pendingMessages
◆ pendingTimeouts
| TQValueList<DBusTimeout *> TQT_DBusConnectionPrivate::pendingTimeouts |
◆ ref
| Atomic TQT_DBusConnectionPrivate::ref |
◆ registeredObjects
| ObjectMap TQT_DBusConnectionPrivate::registeredObjects |
◆ removedWatches
◆ server
| DBusServer* TQT_DBusConnectionPrivate::server |
◆ timeouts
◆ watchers
The documentation for this class was generated from the following files:
Class for transporting D-Bus errors.
DBusConnection * connection
TQValueList< Watcher > WatcherList
DBusMessage * toDBusMessage() const
Creates a raw D-Bus message from this TQt3-bindings message.
static dbus_bool_t qDBusAddTimeout(DBusTimeout *timeout, void *data)
ObjectMap registeredObjects
static void qDBusResultReceived(DBusPendingCall *pending, void *user_data)
int timeout() const
Returns the message's timeout.
TQValueList< DBusTimeout * > pendingTimeouts
static int registerMessageMetaType()
static dbus_bool_t qDBusAddWatch(DBusWatch *watch, void *data)
static void qDBusNewConnection(DBusServer *server, DBusConnection *c, void *data)
static dbus_int32_t server_slot
static void qDBusToggleTimeout(DBusTimeout *timeout, void *data)
static TQT_DBusMessage fromDBusMessage(DBusMessage *dmsg)
Creates a TQt3-bindings message from the given raw D-Bus message.
TQMap< int, WatcherList > WatcherHash
TQTimer * m_messageEmissionQueueTimer
void dbusSignal(const TQT_DBusMessage &message)
void emitPendingCallReply(const TQT_DBusMessage &message)
void transmitMessageEmissionQueue()
static void qDBusToggleWatch(DBusWatch *watch, void *data)
static void qDBusRemoveWatch(DBusWatch *watch, void *data)
bool isValid() const
Returns whether the error object is valid.
PendingMessagesForEmit pendingMessages
static void qDBusRemoveTimeout(DBusTimeout *timeout, void *data)
PendingCallMap pendingCalls
static DBusHandlerResult qDBusSignalFilter(DBusConnection *connection, DBusMessage *message, void *data)
TQT_DBusResultInfoList m_resultEmissionQueue
TQString path() const
Returns the message's object path.
void dbusPendingCallReply(const TQT_DBusMessage &message)
TQTimer * m_resultEmissionQueueTimer
void transmitResultEmissionQueue()
WatcherList removedWatches
A message converts and transports data over D-Bus.
void objectDestroyed(TQObject *object)