DBus-1-TQt  1.0
TQT_DBusConnectionPrivate Class Reference

#include <tqdbusconnection_p.h>

+ Inheritance diagram for TQT_DBusConnectionPrivate:
+ Collaboration diagram for TQT_DBusConnectionPrivate:

Classes

struct  TQT_DBusPendingCall
 
struct  Watcher
 

Public Types

enum  ConnectionMode { InvalidMode, ServerMode, ClientMode }
 
typedef TQValueList< WatcherWatcherList
 
typedef TQMap< int, WatcherListWatcherHash
 
typedef TQMap< int, DBusTimeout * > TimeoutHash
 
typedef TQMap< TQString, TQT_DBusObjectBase * > ObjectMap
 
typedef TQMap< DBusPendingCall *, TQT_DBusPendingCall * > PendingCallMap
 
typedef TQValueList< TQT_DBusMessagePendingMessagesForEmit
 

Public Slots

void socketRead (int)
 
void socketWrite (int)
 
void objectDestroyed (TQObject *object)
 
void purgeRemovedWatches ()
 
void scheduleDispatch ()
 
void dispatch ()
 

Signals

void dbusSignal (const TQT_DBusMessage &message)
 
void dbusPendingCallReply (const TQT_DBusMessage &message)
 

Public Member Functions

 TQT_DBusConnectionPrivate (TQObject *parent=0)
 
 ~TQT_DBusConnectionPrivate ()
 
void bindToApplication ()
 
void setConnection (DBusConnection *connection)
 
void setServer (DBusServer *server)
 
void closeConnection ()
 
void timerEvent (TQTimerEvent *e)
 
bool handleSignal (DBusMessage *msg)
 
bool handleObjectCall (DBusMessage *message)
 
bool handleError ()
 
void emitPendingCallReply (const TQT_DBusMessage &message)
 
int sendWithReplyAsync (const TQT_DBusMessage &message, TQObject *receiver, const char *method)
 
void flush ()
 
void newMethodInResultEmissionQueue ()
 

Static Public Member Functions

static int registerMessageMetaType ()
 

Public Attributes

DBusError error
 
TQT_DBusError lastError
 
Atomic ref
 
ConnectionMode mode
 
DBusConnection * connection
 
DBusServer * server
 
TQTimer * dispatcher
 
WatcherList removedWatches
 
WatcherHash watchers
 
TimeoutHash timeouts
 
ObjectMap registeredObjects
 
TQValueList< DBusTimeout * > pendingTimeouts
 
PendingCallMap pendingCalls
 
PendingMessagesForEmit pendingMessages
 
bool inDispatch
 
TQT_DBusResultInfoList m_resultEmissionQueue
 

Static Public Attributes

static int messageMetaType = 0
 

Private Slots

void transmitResultEmissionQueue ()
 
void transmitMessageEmissionQueue ()
 

Private Attributes

TQTimer * m_resultEmissionQueueTimer
 
TQTimer * m_messageEmissionQueueTimer
 

Detailed Description

Definition at line 69 of file tqdbusconnection_p.h.

Member Typedef Documentation

◆ ObjectMap

Definition at line 144 of file tqdbusconnection_p.h.

◆ PendingCallMap

Definition at line 155 of file tqdbusconnection_p.h.

◆ PendingMessagesForEmit

◆ TimeoutHash

typedef TQMap<int, DBusTimeout*> TQT_DBusConnectionPrivate::TimeoutHash

Definition at line 141 of file tqdbusconnection_p.h.

◆ WatcherHash

Definition at line 137 of file tqdbusconnection_p.h.

◆ WatcherList

Member Enumeration Documentation

◆ ConnectionMode

Enumerator
InvalidMode 
ServerMode 
ClientMode 

Definition at line 111 of file tqdbusconnection_p.h.

Constructor & Destructor Documentation

◆ TQT_DBusConnectionPrivate()

TQT_DBusConnectionPrivate::TQT_DBusConnectionPrivate ( TQObject *  parent = 0)

Definition at line 274 of file tqdbusintegrator.cpp.

275  : TQObject(parent), ref(1), mode(InvalidMode), connection(0), server(0),
276  dispatcher(0), inDispatch(false)
277 {
278  static const int msgType = registerMessageMetaType();
279  Q_UNUSED(msgType);
280 
281  dbus_error_init(&error);
282 
283  dispatcher = new TQTimer(this);
284  TQObject::connect(dispatcher, TQT_SIGNAL(timeout()), this, TQT_SLOT(dispatch()));
285 
286  m_resultEmissionQueueTimer = new TQTimer(this);
287  TQObject::connect(m_resultEmissionQueueTimer, TQT_SIGNAL(timeout()), this, TQT_SLOT(transmitResultEmissionQueue()));
288  m_messageEmissionQueueTimer = new TQTimer(this);
289  TQObject::connect(m_messageEmissionQueueTimer, TQT_SIGNAL(timeout()), this, TQT_SLOT(transmitMessageEmissionQueue()));
290 }

References dispatch(), dispatcher, error, m_messageEmissionQueueTimer, m_resultEmissionQueueTimer, registerMessageMetaType(), transmitMessageEmissionQueue(), and transmitResultEmissionQueue().

+ Here is the call graph for this function:

◆ ~TQT_DBusConnectionPrivate()

TQT_DBusConnectionPrivate::~TQT_DBusConnectionPrivate ( )

Definition at line 292 of file tqdbusintegrator.cpp.

293 {
294  for (PendingCallMap::iterator it = pendingCalls.begin(); it != pendingCalls.end();)
295  {
296  PendingCallMap::iterator copyIt = it;
297  ++it;
298  dbus_pending_call_cancel(copyIt.key());
299  dbus_pending_call_unref(copyIt.key());
300  delete copyIt.data();
301  pendingCalls.erase(copyIt);
302  }
303 
304  if (dbus_error_is_set(&error))
305  dbus_error_free(&error);
306 
307  closeConnection();
308 }

References closeConnection(), error, and pendingCalls.

+ Here is the call graph for this function:

Member Function Documentation

◆ bindToApplication()

void TQT_DBusConnectionPrivate::bindToApplication ( )

Definition at line 347 of file tqdbusintegrator.cpp.

348 {
349  // Yay, now that we have an application we are in business
350  // Re-add all watchers
351  WatcherHash oldWatchers = watchers;
352  watchers.clear();
353  // FIXME-QT4 TQHashIterator<int, TQT_DBusConnectionPrivate::Watcher> it(oldWatchers);
354  for (WatcherHash::const_iterator it = oldWatchers.begin(); it != oldWatchers.end(); ++it)
355  {
356  const WatcherList& list = *it;
357  for (WatcherList::const_iterator wit = list.begin(); wit != list.end(); ++wit)
358  {
359  if (!(*wit).read && !(*wit).write) {
360  qDBusAddWatch((*wit).watch, this);
361  }
362  }
363  }
364 
365  // Re-add all timeouts
366  while (!pendingTimeouts.isEmpty()) {
367  qDBusAddTimeout(pendingTimeouts.first(), this);
368  pendingTimeouts.pop_front();
369  }
370 }

References pendingTimeouts, qDBusAddTimeout(), qDBusAddWatch(), and watchers.

+ Here is the call graph for this function:
+ Here is the caller graph for this function:

◆ closeConnection()

void TQT_DBusConnectionPrivate::closeConnection ( )

Definition at line 310 of file tqdbusintegrator.cpp.

311 {
312  ConnectionMode oldMode = mode;
313  mode = InvalidMode; // prevent reentrancy
314  if (oldMode == ServerMode) {
315  if (server) {
316  dbus_server_disconnect(server);
317  dbus_server_unref(server);
318  server = 0;
319  }
320  } else if (oldMode == ClientMode) {
321  if (connection) {
322  // closing shared connections is forbidden
323 #if 0
324  dbus_connection_close(connection);
325  // send the "close" message
326  while (dbus_connection_dispatch(connection) == DBUS_DISPATCH_DATA_REMAINS);
327 #endif
328  dbus_connection_unref(connection);
329  connection = 0;
330  }
331  }
332 }

References ClientMode, connection, InvalidMode, mode, server, and ServerMode.

+ Here is the caller graph for this function:

◆ dbusPendingCallReply

void TQT_DBusConnectionPrivate::dbusPendingCallReply ( const TQT_DBusMessage message)
signal
+ Here is the caller graph for this function:

◆ dbusSignal

void TQT_DBusConnectionPrivate::dbusSignal ( const TQT_DBusMessage message)
signal
+ Here is the caller graph for this function:

◆ dispatch

void TQT_DBusConnectionPrivate::dispatch ( )
slot

Definition at line 468 of file tqdbusintegrator.cpp.

469 {
470  // dbus_connection_dispatch will hang if called recursively
471  if (inDispatch) {
472  printf("[dbus-1-tqt] WARNING: Attempt to call dispatch() recursively was silently ignored to prevent lockup!\n\r"); fflush(stdout);
473  return;
474  }
475  inDispatch = true;
476 
477  if (mode == ClientMode)
478  {
479  if (dbus_connection_dispatch(connection) != DBUS_DISPATCH_DATA_REMAINS)
480  {
481  // stop dispatch timer
482  dispatcher->stop();
483  }
484  }
485 
486  inDispatch = false;
487 }

References ClientMode, connection, dispatcher, inDispatch, and mode.

+ Here is the caller graph for this function:

◆ emitPendingCallReply()

void TQT_DBusConnectionPrivate::emitPendingCallReply ( const TQT_DBusMessage message)

Definition at line 342 of file tqdbusintegrator.cpp.

343 {
344  emit dbusPendingCallReply(message);
345 }

References dbusPendingCallReply().

+ Here is the caller graph for this function:

◆ flush()

void TQT_DBusConnectionPrivate::flush ( )

Definition at line 660 of file tqdbusintegrator.cpp.

661 {
662  if (!connection) return;
663 
664  dbus_connection_flush(connection);
665 }

References connection.

+ Here is the caller graph for this function:

◆ handleError()

bool TQT_DBusConnectionPrivate::handleError ( )

Definition at line 334 of file tqdbusintegrator.cpp.

335 {
337  if (dbus_error_is_set(&error))
338  dbus_error_free(&error);
339  return lastError.isValid();
340 }

References error, TQT_DBusError::isValid(), and lastError.

+ Here is the call graph for this function:
+ Here is the caller graph for this function:

◆ handleObjectCall()

bool TQT_DBusConnectionPrivate::handleObjectCall ( DBusMessage *  message)

Definition at line 500 of file tqdbusintegrator.cpp.

501 {
503 
504  ObjectMap::iterator it = registeredObjects.find(msg.path());
505  if (it == registeredObjects.end())
506  return false;
507 
508  return it.data()->handleMethodCall(msg);
509 }

References TQT_DBusMessage::fromDBusMessage(), TQT_DBusMessage::path(), and registeredObjects.

+ Here is the call graph for this function:
+ Here is the caller graph for this function:

◆ handleSignal()

bool TQT_DBusConnectionPrivate::handleSignal ( DBusMessage *  msg)

Definition at line 511 of file tqdbusintegrator.cpp.

512 {
514 
515  // yes, it is a single "|" below...
516  // FIXME-QT4
517  //return handleSignal(TQString(), msg) | handleSignal(msg.path(), msg);
518 
519  // If dbusSignal(msg) were called here, it could easily cause a lockup as it would enter the TQt3 event loop,
520  // which could result in arbitrary methods being called while still inside dbus_connection_dispatch.
521  // Instead, I enqueue the messages here for TQt3 event loop transmission after dbus_connection_dispatch is finished.
522  pendingMessages.append(msg);
523  if (!m_messageEmissionQueueTimer->isActive()) m_messageEmissionQueueTimer->start(0, TRUE);
524 
525  return true;
526 }

References TQT_DBusMessage::fromDBusMessage(), m_messageEmissionQueueTimer, and pendingMessages.

+ Here is the call graph for this function:
+ Here is the caller graph for this function:

◆ newMethodInResultEmissionQueue()

void TQT_DBusConnectionPrivate::newMethodInResultEmissionQueue ( )

Definition at line 667 of file tqdbusintegrator.cpp.

668 {
669  if (!m_resultEmissionQueueTimer->isActive()) m_resultEmissionQueueTimer->start(0, TRUE);
670 }

References m_resultEmissionQueueTimer.

+ Here is the caller graph for this function:

◆ objectDestroyed

void TQT_DBusConnectionPrivate::objectDestroyed ( TQObject *  object)
slot

Definition at line 404 of file tqdbusintegrator.cpp.

405 {
406  //tqDebug("Object destroyed");
407  for (PendingCallMap::iterator it = pendingCalls.begin(); it != pendingCalls.end();)
408  {
409  TQObject* receiver = (TQObject*) it.data()->receiver;
410  if (receiver == object || receiver == 0)
411  {
412  PendingCallMap::iterator copyIt = it;
413  ++it;
414 
415  dbus_pending_call_cancel(copyIt.key());
416  dbus_pending_call_unref(copyIt.key());
417  delete copyIt.data();
418  pendingCalls.erase(copyIt);
419  }
420  else
421  ++it;
422  }
423 }

References pendingCalls.

+ Here is the caller graph for this function:

◆ purgeRemovedWatches

void TQT_DBusConnectionPrivate::purgeRemovedWatches ( )
slot

Definition at line 425 of file tqdbusintegrator.cpp.

426 {
427  if (removedWatches.isEmpty()) return;
428 
429  WatcherList::iterator listIt = removedWatches.begin();
430  for (; listIt != removedWatches.end(); ++listIt)
431  {
432  delete (*listIt).read;
433  delete (*listIt).write;
434  }
435  removedWatches.clear();
436 
437  uint count = 0;
438  WatcherHash::iterator it = watchers.begin();
439  while (it != watchers.end())
440  {
441  WatcherList& list = *it;
442  listIt = list.begin();
443  while (listIt != list.end())
444  {
445  if (!((*listIt).read) && !((*listIt).write))
446  {
447  listIt = list.erase(listIt);
448  ++count;
449  }
450  }
451 
452  if (list.isEmpty())
453  {
454  WatcherHash::iterator copyIt = it;
455  ++it;
456  watchers.erase(copyIt);
457  }
458  else
459  ++it;
460  }
461 }

References removedWatches, and watchers.

◆ registerMessageMetaType()

int TQT_DBusConnectionPrivate::registerMessageMetaType ( )
static

Definition at line 267 of file tqdbusintegrator.cpp.

268 {
269  // FIXME-QT4 int tp = messageMetaType = qRegisterMetaType<TQT_DBusMessage>("TQT_DBusMessage");
270  int tp = 0;
271  return tp;
272 }
+ Here is the caller graph for this function:

◆ scheduleDispatch

void TQT_DBusConnectionPrivate::scheduleDispatch ( )
slot

Definition at line 463 of file tqdbusintegrator.cpp.

464 {
465  dispatcher->start(0);
466 }

References dispatcher.

+ Here is the caller graph for this function:

◆ sendWithReplyAsync()

int TQT_DBusConnectionPrivate::sendWithReplyAsync ( const TQT_DBusMessage message,
TQObject *  receiver,
const char *  method 
)

Definition at line 628 of file tqdbusintegrator.cpp.

630 {
631  if (!receiver || !method)
632  return 0;
633 
634  if (!TQObject::connect(receiver, TQT_SIGNAL(destroyed(TQObject*)),
635  this, TQT_SLOT(objectDestroyed(TQObject*))))
636  return false;
637 
638  DBusMessage *msg = message.toDBusMessage();
639  if (!msg)
640  return 0;
641 
642  int msg_serial = 0;
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;
649  pendingCalls.insert(pcall->pending, pcall);
650 
651  dbus_pending_call_set_notify(pending, qDBusResultReceived, this, 0);
652 
653  msg_serial = dbus_message_get_serial(msg);
654  }
655 
656  dbus_message_unref(msg);
657  return msg_serial;
658 }

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().

+ Here is the call graph for this function:
+ Here is the caller graph for this function:

◆ setConnection()

void TQT_DBusConnectionPrivate::setConnection ( DBusConnection *  connection)

Definition at line 553 of file tqdbusintegrator.cpp.

554 {
555  if (!dbc) {
556  handleError();
557  return;
558  }
559 
560  connection = dbc;
561  mode = ClientMode;
562 
563  dbus_connection_set_exit_on_disconnect(connection, false);
564  dbus_connection_set_watch_functions(connection, qDBusAddWatch, qDBusRemoveWatch,
565  qDBusToggleWatch, this, 0);
566  dbus_connection_set_timeout_functions(connection, qDBusAddTimeout, qDBusRemoveTimeout,
567  qDBusToggleTimeout, this, 0);
568 // dbus_bus_add_match(connection, "type='signal',interface='com.trolltech.dbus.Signal'", &error);
569 // dbus_bus_add_match(connection, "type='signal'", &error);
570 
571  dbus_bus_add_match(connection, "type='signal'", &error);
572  if (handleError()) {
573  closeConnection();
574  return;
575  }
576 
577  const char *service = dbus_bus_get_unique_name(connection);
578  if (service) {
579  TQCString filter;
580  filter += "destination='";
581  filter += service;
582  filter += "\'";
583 
584  dbus_bus_add_match(connection, filter.data(), &error);
585  if (handleError()) {
586  closeConnection();
587  return;
588  }
589  } else {
590  tqWarning("TQT_DBusConnectionPrivate::SetConnection: Unable to get unique name");
591  }
592 
593  dbus_connection_add_filter(connection, qDBusSignalFilter, this, 0);
594 
595  //tqDebug("unique name: %s", service);
596 }

References ClientMode, closeConnection(), connection, error, handleError(), mode, qDBusAddTimeout(), qDBusAddWatch(), qDBusRemoveTimeout(), qDBusRemoveWatch(), qDBusSignalFilter(), qDBusToggleTimeout(), and qDBusToggleWatch().

+ Here is the call graph for this function:
+ Here is the caller graph for this function:

◆ setServer()

void TQT_DBusConnectionPrivate::setServer ( DBusServer *  server)

Definition at line 530 of file tqdbusintegrator.cpp.

531 {
532  if (!server) {
533  handleError();
534  return;
535  }
536 
537  server = s;
538  mode = ServerMode;
539 
540  dbus_server_allocate_data_slot(&server_slot);
541  if (server_slot < 0)
542  return;
543 
544  dbus_server_set_watch_functions(server, qDBusAddWatch, qDBusRemoveWatch,
545  qDBusToggleWatch, this, 0); // ### check return type?
546  dbus_server_set_timeout_functions(server, qDBusAddTimeout, qDBusRemoveTimeout,
547  qDBusToggleTimeout, this, 0);
548  dbus_server_set_new_connection_function(server, qDBusNewConnection, this, 0);
549 
550  dbus_server_set_data(server, server_slot, this, 0);
551 }

References handleError(), mode, qDBusAddTimeout(), qDBusAddWatch(), qDBusNewConnection(), qDBusRemoveTimeout(), qDBusRemoveWatch(), qDBusToggleTimeout(), qDBusToggleWatch(), server, server_slot, and ServerMode.

+ Here is the call graph for this function:
+ Here is the caller graph for this function:

◆ socketRead

void TQT_DBusConnectionPrivate::socketRead ( int  fd)
slot

Definition at line 372 of file tqdbusintegrator.cpp.

373 {
374  // FIXME-QT4 TQHashIterator<int, TQT_DBusConnectionPrivate::Watcher> it(watchers);
375  WatcherHash::const_iterator it = watchers.find(fd);
376  if (it != watchers.end()) {
377  const WatcherList& list = *it;
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");
382  }
383  }
384  }
385  if (mode == ClientMode)
387 }

References ClientMode, mode, scheduleDispatch(), and watchers.

+ Here is the call graph for this function:

◆ socketWrite

void TQT_DBusConnectionPrivate::socketWrite ( int  fd)
slot

Definition at line 389 of file tqdbusintegrator.cpp.

390 {
391  // FIXME-QT4 TQHashIterator<int, TQT_DBusConnectionPrivate::Watcher> it(watchers);
392  WatcherHash::const_iterator it = watchers.find(fd);
393  if (it != watchers.end()) {
394  const WatcherList& list = *it;
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");
399  }
400  }
401  }
402 }

References watchers.

◆ timerEvent()

void TQT_DBusConnectionPrivate::timerEvent ( TQTimerEvent *  e)

Definition at line 246 of file tqdbusconnection.cpp.

247 {
248  DBusTimeout *timeout = timeouts[e->timerId()];
249  dbus_timeout_handle(timeout);
250 }

References timeouts.

◆ transmitMessageEmissionQueue

void TQT_DBusConnectionPrivate::transmitMessageEmissionQueue ( )
privateslot

Definition at line 489 of file tqdbusintegrator.cpp.

490 {
491  TQT_DBusConnectionPrivate::PendingMessagesForEmit::iterator pmfe;
492  pmfe = pendingMessages.begin();
493  while (pmfe != pendingMessages.end()) {
494  TQT_DBusMessage msg = *pmfe;
495  pmfe = pendingMessages.remove(pmfe);
496  dbusSignal(msg);
497  }
498 }

References dbusSignal(), and pendingMessages.

+ Here is the caller graph for this function:

◆ transmitResultEmissionQueue

void TQT_DBusConnectionPrivate::transmitResultEmissionQueue ( )
privateslot

Definition at line 672 of file tqdbusintegrator.cpp.

673 {
674  if (!m_resultEmissionQueue.isEmpty()) {
675  TQT_DBusResultInfoList::Iterator it;
676  it = m_resultEmissionQueue.begin();
677  while (it != m_resultEmissionQueue.end()) {
678  TQT_DBusResultInfo dbusResult = (*it);
679  m_resultEmissionQueue.remove(it);
680  it = m_resultEmissionQueue.begin();
681 
682  TQObject::connect(this, TQT_SIGNAL(dbusPendingCallReply(const TQT_DBusMessage&)), dbusResult.receiver, dbusResult.method.data());
683  emitPendingCallReply(dbusResult.message);
684  TQObject::disconnect(this, TQT_SIGNAL(dbusPendingCallReply(const TQT_DBusMessage&)), dbusResult.receiver, dbusResult.method.data());
685  }
686  }
687 }

References dbusPendingCallReply(), emitPendingCallReply(), m_resultEmissionQueue, TQT_DBusResultInfo::message, TQT_DBusResultInfo::method, and TQT_DBusResultInfo::receiver.

+ Here is the call graph for this function:
+ Here is the caller graph for this function:

Member Data Documentation

◆ connection

DBusConnection* TQT_DBusConnectionPrivate::connection

Definition at line 116 of file tqdbusconnection_p.h.

◆ dispatcher

TQTimer* TQT_DBusConnectionPrivate::dispatcher

Definition at line 119 of file tqdbusconnection_p.h.

◆ error

DBusError TQT_DBusConnectionPrivate::error

Definition at line 108 of file tqdbusconnection_p.h.

◆ inDispatch

bool TQT_DBusConnectionPrivate::inDispatch

Definition at line 161 of file tqdbusconnection_p.h.

◆ lastError

TQT_DBusError TQT_DBusConnectionPrivate::lastError

Definition at line 109 of file tqdbusconnection_p.h.

◆ m_messageEmissionQueueTimer

TQTimer* TQT_DBusConnectionPrivate::m_messageEmissionQueueTimer
private

Definition at line 174 of file tqdbusconnection_p.h.

◆ m_resultEmissionQueue

TQT_DBusResultInfoList TQT_DBusConnectionPrivate::m_resultEmissionQueue

Definition at line 163 of file tqdbusconnection_p.h.

◆ m_resultEmissionQueueTimer

TQTimer* TQT_DBusConnectionPrivate::m_resultEmissionQueueTimer
private

Definition at line 173 of file tqdbusconnection_p.h.

◆ messageMetaType

int TQT_DBusConnectionPrivate::messageMetaType = 0
static

Definition at line 121 of file tqdbusconnection_p.h.

◆ mode

ConnectionMode TQT_DBusConnectionPrivate::mode

Definition at line 115 of file tqdbusconnection_p.h.

◆ pendingCalls

PendingCallMap TQT_DBusConnectionPrivate::pendingCalls

Definition at line 156 of file tqdbusconnection_p.h.

◆ pendingMessages

PendingMessagesForEmit TQT_DBusConnectionPrivate::pendingMessages

Definition at line 159 of file tqdbusconnection_p.h.

◆ pendingTimeouts

TQValueList<DBusTimeout *> TQT_DBusConnectionPrivate::pendingTimeouts

Definition at line 147 of file tqdbusconnection_p.h.

◆ ref

Atomic TQT_DBusConnectionPrivate::ref

Definition at line 114 of file tqdbusconnection_p.h.

◆ registeredObjects

ObjectMap TQT_DBusConnectionPrivate::registeredObjects

Definition at line 145 of file tqdbusconnection_p.h.

◆ removedWatches

WatcherList TQT_DBusConnectionPrivate::removedWatches

Definition at line 136 of file tqdbusconnection_p.h.

◆ server

DBusServer* TQT_DBusConnectionPrivate::server

Definition at line 117 of file tqdbusconnection_p.h.

◆ timeouts

TimeoutHash TQT_DBusConnectionPrivate::timeouts

Definition at line 142 of file tqdbusconnection_p.h.

◆ watchers

WatcherHash TQT_DBusConnectionPrivate::watchers

Definition at line 138 of file tqdbusconnection_p.h.


The documentation for this class was generated from the following files:
TQT_DBusConnectionPrivate::timeouts
TimeoutHash timeouts
Definition: tqdbusconnection_p.h:142
TQT_DBusError
Class for transporting D-Bus errors.
Definition: tqdbuserror.h:40
TQT_DBusConnectionPrivate::connection
DBusConnection * connection
Definition: tqdbusconnection_p.h:116
TQT_DBusConnectionPrivate::WatcherList
TQValueList< Watcher > WatcherList
Definition: tqdbusconnection_p.h:135
TQT_DBusMessage::toDBusMessage
DBusMessage * toDBusMessage() const
Creates a raw D-Bus message from this TQt3-bindings message.
Definition: tqdbusmessage.cpp:134
TQT_DBusResultInfo::message
TQT_DBusMessage message
Definition: tqdbusconnection_p.h:63
qDBusAddTimeout
static dbus_bool_t qDBusAddTimeout(DBusTimeout *timeout, void *data)
Definition: tqdbusintegrator.cpp:51
TQT_DBusConnectionPrivate::registeredObjects
ObjectMap registeredObjects
Definition: tqdbusconnection_p.h:145
TQT_DBusResultInfo::method
TQCString method
Definition: tqdbusconnection_p.h:65
qDBusResultReceived
static void qDBusResultReceived(DBusPendingCall *pending, void *user_data)
Definition: tqdbusintegrator.cpp:598
TQT_DBusConnectionPrivate::error
DBusError error
Definition: tqdbusconnection_p.h:108
TQT_DBusMessage::timeout
int timeout() const
Returns the message's timeout.
Definition: tqdbusmessage.cpp:212
TQT_DBusConnectionPrivate::closeConnection
void closeConnection()
Definition: tqdbusintegrator.cpp:310
TQT_DBusConnectionPrivate::pendingTimeouts
TQValueList< DBusTimeout * > pendingTimeouts
Definition: tqdbusconnection_p.h:147
TQT_DBusConnectionPrivate::registerMessageMetaType
static int registerMessageMetaType()
Definition: tqdbusintegrator.cpp:267
qDBusAddWatch
static dbus_bool_t qDBusAddWatch(DBusWatch *watch, void *data)
Definition: tqdbusintegrator.cpp:116
qDBusNewConnection
static void qDBusNewConnection(DBusServer *server, DBusConnection *c, void *data)
Definition: tqdbusintegrator.cpp:234
server_slot
static dbus_int32_t server_slot
Definition: tqdbusintegrator.cpp:528
TQT_DBusResultInfo::receiver
TQObject * receiver
Definition: tqdbusconnection_p.h:64
qDBusToggleTimeout
static void qDBusToggleTimeout(DBusTimeout *timeout, void *data)
Definition: tqdbusintegrator.cpp:105
TQT_DBusConnectionPrivate::scheduleDispatch
void scheduleDispatch()
Definition: tqdbusintegrator.cpp:463
TQT_DBusConnectionPrivate::dispatcher
TQTimer * dispatcher
Definition: tqdbusconnection_p.h:119
TQT_DBusConnectionPrivate::server
DBusServer * server
Definition: tqdbusconnection_p.h:117
TQT_DBusConnectionPrivate::ClientMode
Definition: tqdbusconnection_p.h:111
TQT_DBusConnectionPrivate::mode
ConnectionMode mode
Definition: tqdbusconnection_p.h:115
TQT_DBusMessage::fromDBusMessage
static TQT_DBusMessage fromDBusMessage(DBusMessage *dmsg)
Creates a TQt3-bindings message from the given raw D-Bus message.
Definition: tqdbusmessage.cpp:162
TQT_DBusConnectionPrivate::WatcherHash
TQMap< int, WatcherList > WatcherHash
Definition: tqdbusconnection_p.h:137
TQT_DBusConnectionPrivate::m_messageEmissionQueueTimer
TQTimer * m_messageEmissionQueueTimer
Definition: tqdbusconnection_p.h:174
TQT_DBusConnectionPrivate::watchers
WatcherHash watchers
Definition: tqdbusconnection_p.h:138
TQT_DBusConnectionPrivate::dbusSignal
void dbusSignal(const TQT_DBusMessage &message)
TQT_DBusConnectionPrivate::emitPendingCallReply
void emitPendingCallReply(const TQT_DBusMessage &message)
Definition: tqdbusintegrator.cpp:342
TQT_DBusConnectionPrivate::transmitMessageEmissionQueue
void transmitMessageEmissionQueue()
Definition: tqdbusintegrator.cpp:489
qDBusToggleWatch
static void qDBusToggleWatch(DBusWatch *watch, void *data)
Definition: tqdbusintegrator.cpp:200
TQT_DBusConnectionPrivate::inDispatch
bool inDispatch
Definition: tqdbusconnection_p.h:161
TQT_DBusConnectionPrivate::InvalidMode
Definition: tqdbusconnection_p.h:111
qDBusRemoveWatch
static void qDBusRemoveWatch(DBusWatch *watch, void *data)
Definition: tqdbusintegrator.cpp:158
TQT_DBusError::isValid
bool isValid() const
Returns whether the error object is valid.
Definition: tqdbuserror.cpp:137
TQT_DBusConnectionPrivate::dispatch
void dispatch()
Definition: tqdbusintegrator.cpp:468
TQT_DBusConnectionPrivate::pendingMessages
PendingMessagesForEmit pendingMessages
Definition: tqdbusconnection_p.h:159
qDBusRemoveTimeout
static void qDBusRemoveTimeout(DBusTimeout *timeout, void *data)
Definition: tqdbusintegrator.cpp:75
TQT_DBusConnectionPrivate::handleError
bool handleError()
Definition: tqdbusintegrator.cpp:334
TQT_DBusConnectionPrivate::pendingCalls
PendingCallMap pendingCalls
Definition: tqdbusconnection_p.h:156
TQT_DBusConnectionPrivate::lastError
TQT_DBusError lastError
Definition: tqdbusconnection_p.h:109
TQT_DBusConnectionPrivate::ServerMode
Definition: tqdbusconnection_p.h:111
qDBusSignalFilter
static DBusHandlerResult qDBusSignalFilter(DBusConnection *connection, DBusMessage *message, void *data)
Definition: tqdbusintegrator.cpp:241
TQT_DBusConnectionPrivate::m_resultEmissionQueue
TQT_DBusResultInfoList m_resultEmissionQueue
Definition: tqdbusconnection_p.h:163
TQT_DBusConnectionPrivate::ref
Atomic ref
Definition: tqdbusconnection_p.h:114
TQT_DBusMessage::path
TQString path() const
Returns the message's object path.
Definition: tqdbusmessage.cpp:187
TQT_DBusResultInfo
Definition: tqdbusconnection_p.h:60
TQT_DBusConnectionPrivate::dbusPendingCallReply
void dbusPendingCallReply(const TQT_DBusMessage &message)
TQT_DBusConnectionPrivate::ConnectionMode
ConnectionMode
Definition: tqdbusconnection_p.h:111
TQT_DBusConnectionPrivate::m_resultEmissionQueueTimer
TQTimer * m_resultEmissionQueueTimer
Definition: tqdbusconnection_p.h:173
TQT_DBusConnectionPrivate::transmitResultEmissionQueue
void transmitResultEmissionQueue()
Definition: tqdbusintegrator.cpp:672
TQT_DBusConnectionPrivate::removedWatches
WatcherList removedWatches
Definition: tqdbusconnection_p.h:136
TQT_DBusMessage
A message converts and transports data over D-Bus.
Definition: tqdbusmessage.h:115
TQT_DBusConnectionPrivate::objectDestroyed
void objectDestroyed(TQObject *object)
Definition: tqdbusintegrator.cpp:404