#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 |
( |
| ) |
|
Definition at line 292 of file tqdbusintegrator.cpp.
296 PendingCallMap::iterator copyIt = it;
298 dbus_pending_call_cancel(copyIt.key());
299 dbus_pending_call_unref(copyIt.key());
300 delete copyIt.data();
304 if (dbus_error_is_set(&
error))
305 dbus_error_free(&
error);
PendingCallMap pendingCalls
References closeConnection(), error, and pendingCalls.
◆ bindToApplication()
void TQT_DBusConnectionPrivate::bindToApplication |
( |
| ) |
|
Definition at line 370 of file tqdbusintegrator.cpp.
377 for (WatcherHash::const_iterator it = oldWatchers.begin(); it != oldWatchers.end(); ++it)
380 for (WatcherList::const_iterator wit = list.begin(); wit != list.end(); ++wit)
382 if (!(*wit).read && !(*wit).write) {
TQValueList< DBusTimeout * > pendingTimeouts
TQValueList< Watcher > WatcherList
TQMap< int, WatcherList > WatcherHash
static dbus_bool_t qDBusAddWatch(DBusWatch *watch, void *data)
static dbus_bool_t qDBusAddTimeout(DBusTimeout *timeout, void *data)
References pendingTimeouts, qDBusAddTimeout(), qDBusAddWatch(), and watchers.
◆ 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 | ) |
|
◆ handleUnreadMessages()
bool TQT_DBusConnectionPrivate::handleUnreadMessages |
( |
| ) |
|
◆ newMethodInResultEmissionQueue()
void TQT_DBusConnectionPrivate::newMethodInResultEmissionQueue |
( |
| ) |
|
◆ objectDestroyed
void TQT_DBusConnectionPrivate::objectDestroyed |
( |
TQObject * |
object | ) |
|
|
slot |
Definition at line 427 of file tqdbusintegrator.cpp.
432 TQObject* receiver = (TQObject*) it.data()->receiver;
433 if (receiver ==
object || receiver == 0)
435 PendingCallMap::iterator copyIt = it;
438 dbus_pending_call_cancel(copyIt.key());
439 dbus_pending_call_unref(copyIt.key());
440 delete copyIt.data();
References pendingCalls.
◆ purgeRemovedWatches
void TQT_DBusConnectionPrivate::purgeRemovedWatches |
( |
| ) |
|
|
slot |
Definition at line 448 of file tqdbusintegrator.cpp.
455 delete (*listIt).read;
456 delete (*listIt).write;
461 WatcherHash::iterator it =
watchers.begin();
465 listIt = list.begin();
466 while (listIt != list.end())
468 if (!((*listIt).read) && !((*listIt).write))
470 listIt = list.erase(listIt);
477 WatcherHash::iterator copyIt = it;
WatcherList removedWatches
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 649 of file tqdbusintegrator.cpp.
652 if (!receiver || !method)
655 if (!TQObject::connect(receiver, TQ_SIGNAL(destroyed(TQObject*)),
664 DBusPendingCall *pending = 0;
665 if (dbus_connection_send_with_reply(
connection, msg, &pending, message.
timeout())) {
666 TQT_DBusPendingCall *pcall =
new TQT_DBusPendingCall;
667 pcall->receiver = receiver;
668 pcall->method = method;
669 pcall->pending = pending;
674 msg_serial = dbus_message_get_serial(msg);
677 dbus_message_unref(msg);
void objectDestroyed(TQObject *object)
int timeout() const
Returns the message's timeout.
DBusMessage * toDBusMessage() const
Creates a raw D-Bus message from this TQt3-bindings message.
static void qDBusResultReceived(DBusPendingCall *pending, void *user_data)
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 576 of file tqdbusintegrator.cpp.
586 dbus_connection_set_exit_on_disconnect(
connection,
false);
598 const char *service = dbus_bus_get_unique_name(
connection);
601 filter +=
"destination='";
611 tqWarning(
"TQT_DBusConnectionPrivate::SetConnection: Unable to get unique name");
static void qDBusRemoveWatch(DBusWatch *watch, void *data)
static void qDBusToggleTimeout(DBusTimeout *timeout, void *data)
static void qDBusRemoveTimeout(DBusTimeout *timeout, void *data)
static DBusHandlerResult qDBusSignalFilter(DBusConnection *connection, DBusMessage *message, void *data)
static void qDBusToggleWatch(DBusWatch *watch, void *data)
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 553 of file tqdbusintegrator.cpp.
static void qDBusNewConnection(DBusServer *server, DBusConnection *c, void *data)
static dbus_int32_t server_slot
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 395 of file tqdbusintegrator.cpp.
398 WatcherHash::const_iterator it =
watchers.find(fd);
401 for (WatcherList::const_iterator wit = list.begin(); wit != list.end(); ++wit) {
402 if ((*wit).read && (*wit).read->isEnabled()) {
403 if (!dbus_watch_handle((*wit).watch, DBUS_WATCH_READABLE))
404 tqDebug(
"OUT OF MEM");
References ClientMode, mode, scheduleDispatch(), and watchers.
◆ socketWrite
void TQT_DBusConnectionPrivate::socketWrite |
( |
int |
fd | ) |
|
|
slot |
Definition at line 412 of file tqdbusintegrator.cpp.
415 WatcherHash::const_iterator it =
watchers.find(fd);
418 for (WatcherList::const_iterator wit = list.begin(); wit != list.end(); ++wit) {
419 if ((*wit).write && (*wit).write->isEnabled()) {
420 if (!dbus_watch_handle((*wit).watch, DBUS_WATCH_WRITABLE))
421 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: