QDBusPendingCallPrivate Class Reference

#include <qdbuspendingcall_p.h>

Inheritance diagram for QDBusPendingCallPrivate:

Public Functions
void	checkReceivedSignature ()
	QDBusPendingCallPrivate (const QDBusMessage &sent, QDBusConnectionPrivate *connection)
void	setMetaTypes (int count, const int *types)
bool	setReplyCallback (QObject *target, const char *member)
void	waitForFinished ()
	~QDBusPendingCallPrivate ()
Public Functions inherited from QSharedData
	QSharedData ()
	Constructs a QSharedData object with a reference count of 0. More...
	QSharedData (const QSharedData &)
	Constructs a QSharedData object with reference count 0. More...

Static Public Functions
static QDBusPendingCall	fromMessage (const QDBusMessage &msg)

Public Variables
QDBusConnectionPrivate *const	connection
int	expectedReplyCount
QString	expectedReplySignature
QList< int >	metaTypes
int	methodIdx
QMutex	mutex
DBusPendingCall *	pending
QPointer< QObject >	receiver
QDBusMessage	replyMessage
const QDBusMessage	sentMessage
QWaitCondition	waitForFinishedCondition
volatile bool	waitingForFinished
QDBusPendingCallWatcherHelper *	watcherHelper
Public Variables inherited from QSharedData
QAtomicInt	ref

Detailed Description

Definition at line 75 of file qdbuspendingcall_p.h.

Constructors and Destructors

QDBusPendingCallPrivate()

QDBusPendingCallPrivate::QDBusPendingCallPrivate ( const QDBusMessage &  sent, QDBusConnectionPrivate *  connection  )

inline

Definition at line 104 of file qdbuspendingcall_p.h.

        : sentMessage(sent), connection(connection), watcherHelper(0), pending(0), waitingForFinished(false)
    { }

~QDBusPendingCallPrivate()

QDBusPendingCallPrivate::~QDBusPendingCallPrivate

(

)

Definition at line 139 of file qdbuspendingcall.cpp.

Referenced by QDBusPendingCallPrivate().

{
    if (pending) {
        q_dbus_pending_call_cancel(pending);
        q_dbus_pending_call_unref(pending);
    }
    delete watcherHelper;
}

Functions

checkReceivedSignature()

void QDBusPendingCallPrivate::checkReceivedSignature

(

)

Definition at line 220 of file qdbuspendingcall.cpp.

Referenced by QDBusConnectionPrivate::processFinishedCall(), QDBusPendingCallPrivate(), and QDBusPendingReplyData::setMetaTypes().

{
    // MUST BE CALLED WITH A LOCKED MUTEX!

    if (replyMessage.type() == QDBusMessage::InvalidMessage)
        return;                 // not yet finished - no message to
                                // validate against
    if (replyMessage.type() == QDBusMessage::ErrorMessage)
        return;                 // we don't have to check the signature of an error reply

    if (expectedReplySignature.isNull())
        return;                 // no signature to validate against

    // can't use startsWith here because a null string doesn't start or end with an empty string
    if (!replyMessage.signature().indexOf(expectedReplySignature) == 0) {
        QString errorMsg = QLatin1String("Unexpected reply signature: got \"%1\", "
                                         "expected \"%2\"");
        replyMessage = QDBusMessage::createError(
            QDBusError::InvalidSignature,
            errorMsg.arg(replyMessage.signature(), expectedReplySignature));

    }
}

fromMessage()

static QDBusPendingCall QDBusPendingCallPrivate::fromMessage ( const QDBusMessage &  msg )

static

Referenced by QDBusPendingCallPrivate().

setMetaTypes()

void QDBusPendingCallPrivate::setMetaTypes	(	int	count,
		const int *	types
	)

Definition at line 198 of file qdbuspendingcall.cpp.

Referenced by QDBusPendingCallPrivate(), and QDBusPendingReplyData::setMetaTypes().

{
    expectedReplyCount = count;
    if (count == 0) {
        expectedReplySignature = QLatin1String(""); // not null
        return;
    }

    QByteArray sig;
    sig.reserve(count + count / 2);
    for (int i = 0; i < count; ++i) {
        const char *typeSig = QDBusMetaType::typeToSignature(types[i]);
        if (!typeSig) {
            qFatal("QDBusPendingReply: type %s is not registered with QtDBus",
                   QMetaType::typeName(types[i]));
        }
        sig += typeSig;
    }

    expectedReplySignature = QString::fromLatin1(sig);
}

setReplyCallback()

bool QDBusPendingCallPrivate::setReplyCallback	(	QObject *	target,
		const char *	member
	)

Definition at line 148 of file qdbuspendingcall.cpp.

Referenced by QDBusPendingCall::operator=(), QDBusPendingCallPrivate(), and QDBusConnectionPrivate::sendWithReplyAsync().

{
    receiver = target;
    metaTypes.clear();
    methodIdx = -1;
    if (!target)
        return true;;           // unsetting

    if (!member || !*member) {
        // would not be able to deliver a reply
        qWarning("QDBusPendingCall::setReplyCallback: error: cannot deliver a reply to %s::%s (%s)",
                 target ? target->metaObject()->className() : "(null)",
                 member ? member + 1 : "(null)",
                 target ? qPrintable(target->objectName()) : "no name");
        return false;
    }

    methodIdx = QDBusConnectionPrivate::findSlot(target, member + 1, metaTypes);
    if (methodIdx == -1) {
        QByteArray normalizedName = QMetaObject::normalizedSignature(member + 1);
        methodIdx = QDBusConnectionPrivate::findSlot(target, normalizedName, metaTypes);
    }
    if (methodIdx == -1) {
        // would not be able to deliver a reply
        qWarning("QDBusPendingCall::setReplyCallback: error: cannot deliver a reply to %s::%s (%s)",
                 target->metaObject()->className(),
                 member + 1, qPrintable(target->objectName()));
        return false;
    }

    // success
    // construct the expected signature
    int count = metaTypes.count() - 1;
    if (count == 1 && metaTypes.at(1) == QDBusMetaTypeId::message) {
        // wildcard slot, can receive anything, so don't set the signature
        return true;
    }

    if (metaTypes.at(count) == QDBusMetaTypeId::message)
        --count;

    if (count == 0) {
        setMetaTypes(count, 0);
    } else {
        QVector<int> types = QVector<int>::fromList(metaTypes);
        setMetaTypes(count, types.constData() + 1);
    }
    return true;
}

waitForFinished()

void QDBusPendingCallPrivate::waitForFinished

(

)

Definition at line 244 of file qdbuspendingcall.cpp.

Referenced by QDBusPendingReplyData::argumentAt(), QDBusPendingCall::operator=(), QDBusPendingCallPrivate(), and QDBusPendingCallWatcher::waitForFinished().

{
    QMutexLocker locker(&mutex);

    if (replyMessage.type() != QDBusMessage::InvalidMessage)
        return;                 // already finished

    connection->waitForFinished(this);
}

Properties

connection

QDBusConnectionPrivate* const QDBusPendingCallPrivate::connection

Definition at line 81 of file qdbuspendingcall_p.h.

Referenced by QDBusConnectionPrivate::processFinishedCall().

expectedReplyCount

int QDBusPendingCallPrivate::expectedReplyCount

Definition at line 101 of file qdbuspendingcall_p.h.

expectedReplySignature

QString QDBusPendingCallPrivate::expectedReplySignature

Definition at line 100 of file qdbuspendingcall_p.h.

metaTypes

QList<int> QDBusPendingCallPrivate::metaTypes

Definition at line 85 of file qdbuspendingcall_p.h.

Referenced by QDBusConnectionPrivate::processFinishedCall().

methodIdx

int QDBusPendingCallPrivate::methodIdx

Definition at line 86 of file qdbuspendingcall_p.h.

Referenced by QDBusConnectionPrivate::processFinishedCall().

mutex

QMutex QDBusPendingCallPrivate::mutex

mutable

Definition at line 90 of file qdbuspendingcall_p.h.

Referenced by QDBusPendingCall::operator=(), QDBusConnectionPrivate::processFinishedCall(), QDBusPendingCallWatcher::QDBusPendingCallWatcher(), QDBusPendingReplyData::setMetaTypes(), and QDBusConnectionPrivate::waitForFinished().

pending

DBusPendingCall* QDBusPendingCallPrivate::pending

Definition at line 97 of file qdbuspendingcall_p.h.

Referenced by QDBusConnectionPrivate::processFinishedCall(), qDBusResultReceived(), QDBusConnectionPrivate::sendWithReplyAsync(), and QDBusConnectionPrivate::waitForFinished().

receiver

QPointer<QObject> QDBusPendingCallPrivate::receiver

Definition at line 84 of file qdbuspendingcall_p.h.

Referenced by QDBusConnectionPrivate::processFinishedCall().

replyMessage

QDBusMessage QDBusPendingCallPrivate::replyMessage

Definition at line 96 of file qdbuspendingcall_p.h.

Referenced by QDBusPendingReplyData::argumentAt(), QDBusPendingReplyData::assign(), QDBusPendingCall::fromCompletedCall(), QDBusPendingCall::operator=(), QDBusConnectionPrivate::processFinishedCall(), QDBusPendingCallWatcher::QDBusPendingCallWatcher(), QDBusConnectionPrivate::sendWithReply(), and QDBusConnectionPrivate::sendWithReplyAsync().

sentMessage

const QDBusMessage QDBusPendingCallPrivate::sentMessage

Definition at line 80 of file qdbuspendingcall_p.h.

Referenced by QDBusConnectionPrivate::processFinishedCall().

waitForFinishedCondition

QWaitCondition QDBusPendingCallPrivate::waitForFinishedCondition

Definition at line 91 of file qdbuspendingcall_p.h.

Referenced by QDBusConnectionPrivate::waitForFinished().

waitingForFinished

volatile bool QDBusPendingCallPrivate::waitingForFinished

Definition at line 98 of file qdbuspendingcall_p.h.

Referenced by QDBusConnectionPrivate::processFinishedCall(), and QDBusConnectionPrivate::waitForFinished().

watcherHelper

QDBusPendingCallWatcherHelper* QDBusPendingCallPrivate::watcherHelper

Definition at line 95 of file qdbuspendingcall_p.h.

Referenced by QDBusConnectionPrivate::processFinishedCall(), QDBusPendingCallWatcher::QDBusPendingCallWatcher(), QDBusConnectionPrivate::sendWithReply(), QDBusConnectionPrivate::sendWithReplyAsync(), and QDBusPendingCallWatcher::waitForFinished().

---

The documentation for this class was generated from the following files:

• /src/dbus/qdbuspendingcall_p.h
• /src/dbus/qdbuspendingcall.cpp