X-Git-Url: https://git.quassel-irc.org/?p=quassel.git;a=blobdiff_plain;f=src%2Fcommon%2Fsignalproxy.cpp;h=7aab0252543258799c9b5a1549d9836e03fcfa29;hp=a6e16faab47475b642b6151b7d6125d7eee90b79;hb=dcc90a564e00e206f05db224f1654c8907f149f4;hpb=da2eb70e632526088ef0e31cfd52beb563ce31ce diff --git a/src/common/signalproxy.cpp b/src/common/signalproxy.cpp index a6e16faa..7aab0252 100644 --- a/src/common/signalproxy.cpp +++ b/src/common/signalproxy.cpp @@ -247,7 +247,8 @@ void SignalProxy::objectRenamed(QString oldname, QString newname) { } void SignalProxy::objectRenamed(QByteArray classname, QString oldname, QString newname) { - if(_syncSlave.contains(classname) && _syncSlave[classname].contains(oldname)) + QMutexLocker locker(&slaveMutex); + if(_syncSlave.contains(classname) && _syncSlave[classname].contains(oldname) && oldname != newname) _syncSlave[classname][newname] = _syncSlave[classname].take(oldname); } @@ -433,7 +434,7 @@ void SignalProxy::synchronizeAsMaster(QObject *sender) { relay->setSynchronize(true); if(sender->metaObject()->indexOfSignal(QMetaObject::normalizedSignature("renameObject(QString, QString)")) != -1) - connect(sender, SIGNAL(renameObject(QString, QString)), this, SLOT(objectRenamed(QString, QString))); + connect(sender, SIGNAL(renameObject(QString, QString)), this, SLOT(objectRenamed(QString, QString)), Qt::DirectConnection); QByteArray className(sender->metaObject()->className()); _syncSlave[className][sender->objectName()] = sender; @@ -556,14 +557,14 @@ void SignalProxy::dispatchSignal(const QVariant &identifier, const QVariantList void SignalProxy::receivePeerSignal(QIODevice *sender, const QVariant &packedFunc) { QVariantList params(packedFunc.toList()); + QVariant call = params.takeFirst(); + if(call.type() != QVariant::Int) + return handleSignal(call.toByteArray(), params); + // well yes we are locking code here and not only data. // otherwise each handler would have to lock the data anyway. this leaves us on the safe side // unable to forget a lock QMutexLocker locker(&slaveMutex); - - QVariant call = params.takeFirst(); - if(call.type() != QVariant::Int) - return handleSignal(call.toByteArray(), params); switch(call.toInt()) { case Sync: @@ -605,7 +606,8 @@ void SignalProxy::handleSync(QVariantList params) { qWarning() << "received Sync Call for Object" << receiver << "- no matching Slot for Signal:" << signalName; return; - } + } + int slotId = syncMap(receiver)[signalId]; if(!invokeSlot(receiver, slotId, params)) qWarning("SignalProxy::handleSync(): invokeMethod for \"%s\" failed ", methodName(receiver, slotId).constData());