+ detachSignals(obj);
+ detachSlots(obj);
+ stopSync(static_cast<SyncableObject *>(obj));
+}
+
+void SignalProxy::detachSignals(QObject* sender) {
+ if(!_relayHash.contains(sender))
+ return;
+ _relayHash.take(sender)->deleteLater();
+}
+
+void SignalProxy::detachSlots(QObject* receiver) {
+ SlotHash::iterator slotIter = _attachedSlots.begin();
+ while(slotIter != _attachedSlots.end()) {
+ if(slotIter.value().first == receiver) {
+ slotIter = _attachedSlots.erase(slotIter);
+ } else
+ slotIter++;
+ }
+}
+
+void SignalProxy::stopSync(SyncableObject* obj) {
+ if(_relayHash.contains(obj))
+ _relayHash[obj]->setSynchronize(false);
+
+ // we can't use a className here, since it might be effed up, if we receive the call as a result of a decon
+ // gladly the objectName() is still valid. So we have only to iterate over the classes not each instance! *sigh*
+ QHash<QByteArray, ObjectId>::iterator classIter = _syncSlave.begin();
+ while(classIter != _syncSlave.end()) {
+ if(classIter->contains(obj->objectName()) && classIter.value()[obj->objectName()] == obj) {
+ classIter->remove(obj->objectName());
+ break;
+ }
+ classIter++;
+ }
+}
+
+void SignalProxy::dispatchSignal(const RequestType &requestType, const QVariantList ¶ms) {
+ QVariant packedFunc(QVariantList() << (qint16)requestType << params);
+ PeerHash::iterator peer = _peers.begin();
+ while(peer != _peers.end()) {
+ switch((*peer)->type()) {
+ case AbstractPeer::IODevicePeer:
+ {
+ IODevicePeer *ioPeer = static_cast<IODevicePeer *>(*peer);
+ ioPeer->dispatchPackedFunc(packedFunc);
+ }
+ break;
+ case AbstractPeer::SignalProxyPeer:
+ (*peer)->dispatchSignal(requestType, params);
+ break;
+ default:
+ Q_ASSERT(false); // there shouldn't be any peers with wrong / unknown type
+ }
+ peer++;
+ }
+}
+
+void SignalProxy::receivePackedFunc(AbstractPeer *sender, const QVariant &packedFunc) {
+ QVariantList params(packedFunc.toList());
+
+ if(params.isEmpty()) {
+ qWarning() << "SignalProxy::receivePeerSignal(): received incompatible Data:" << packedFunc;
+ return;
+ }
+
+ RequestType requestType = (RequestType)params.takeFirst().value<int>();
+ receivePeerSignal(sender, requestType, params);
+}
+
+void SignalProxy::receivePeerSignal(AbstractPeer *sender, const RequestType &requestType, const QVariantList ¶ms) {
+ switch(requestType) {
+ case RpcCall:
+ if(params.empty())
+ qWarning() << "SignalProxy::receivePeerSignal(): received empty RPC-Call";
+ else
+ handleSignal(params);
+ //handleSignal(params.takeFirst().toByteArray(), params);
+ break;
+
+ case Sync:
+ handleSync(sender, params);
+ break;
+
+ case InitRequest:
+ handleInitRequest(sender, params);
+ break;
+
+ case InitData:
+ handleInitData(sender, params);
+ break;
+
+ case HeartBeat:
+ receiveHeartBeat(sender, params);
+ break;
+
+ case HeartBeatReply:
+ receiveHeartBeatReply(sender, params);
+ break;
+
+ default:
+ qWarning() << "SignalProxy::receivePeerSignal(): received undefined CallType" << requestType << params;
+ }
+}
+
+void SignalProxy::receivePeerSignal(SignalProxy *sender, const RequestType &requestType, const QVariantList ¶ms) {
+ if(!_peers.contains(sender)) {
+ // we output only the pointer value. otherwise Qt would try to pretty print. As the object might already been destroyed, this is not a good idea.
+ qWarning() << "SignalProxy::receivePeerSignal(): received Signal from unknown Proxy" << reinterpret_cast<void *>(sender);
+ return;
+ }
+ receivePeerSignal(_peers[sender], requestType, params);
+}
+
+void SignalProxy::handleSync(AbstractPeer *sender, QVariantList params) {
+ if(params.count() < 3) {
+ qWarning() << "received invalid Sync call" << params;
+ return;
+ }
+
+ QByteArray className = params.takeFirst().toByteArray();
+ QString objectName = params.takeFirst().toString();
+ QByteArray signal = params.takeFirst().toByteArray();
+
+ if(!_syncSlave.contains(className) || !_syncSlave[className].contains(objectName)) {
+ qWarning() << QString("no registered receiver for sync call: %1::%2 (objectName=\"%3\"). Params are:").arg(QString(className)).arg(QString(signal)).arg(objectName)
+ << params;
+ return;
+ }
+
+ SyncableObject *receiver = _syncSlave[className][objectName];
+ if(!syncMap(receiver).contains(signal)) {
+ qWarning() << QString("no matching slot for sync call: %1::%2 (objectName=\"%3\"). Params are:").arg(QString(className)).arg(QString(signal)).arg(objectName)
+ << params;
+ return;
+ }
+
+ int slotId = syncMap(receiver)[signal];
+
+ QVariant returnValue((QVariant::Type)returnType(receiver, slotId));
+ if(!invokeSlot(receiver, slotId, params, returnValue)) {
+ qWarning("SignalProxy::handleSync(): invokeMethod for \"%s\" failed ", methodName(receiver, slotId).constData());
+ return;
+ }
+
+ if(returnValue.type() != QVariant::Invalid && receiveMap(receiver).contains(slotId)) {
+ int receiverId = receiveMap(receiver)[slotId];
+ QVariantList returnParams;
+ returnParams << className
+ << objectName
+ << QByteArray(receiver->metaObject()->method(receiverId).signature());
+ if(argTypes(receiver, receiverId).count() > 1)
+ returnParams << params;
+ returnParams << returnValue;
+ sender->dispatchSignal(Sync, returnParams);
+ }
+
+ // send emit update signal
+ invokeSlot(receiver, updatedRemotelyId(receiver));
+}
+
+void SignalProxy::handleInitRequest(AbstractPeer *sender, const QVariantList ¶ms) {
+ if(params.count() != 2) {
+ qWarning() << "SignalProxy::handleInitRequest() received initRequest with invalid param Count:"
+ << params;
+ return;
+ }
+
+ QByteArray className(params[0].toByteArray());
+ QString objectName(params[1].toString());
+
+ if(!_syncSlave.contains(className)) {
+ qWarning() << "SignalProxy::handleInitRequest() received initRequest for unregistered Class:"
+ << className;
+ return;
+ }
+
+ if(!_syncSlave[className].contains(objectName)) {
+ qWarning() << "SignalProxy::handleInitRequest() received initRequest for unregistered Object:"
+ << className << objectName;
+ return;
+ }
+
+ SyncableObject *obj = _syncSlave[className][objectName];
+
+ QVariantList params_;
+ params_ << className
+ << objectName
+ << initData(obj);
+
+ sender->dispatchSignal(InitData, params_);
+}
+
+void SignalProxy::handleInitData(AbstractPeer *sender, const QVariantList ¶ms) {
+ Q_UNUSED(sender)
+ if(params.count() != 3) {
+ qWarning() << "SignalProxy::handleInitData() received initData with invalid param Count:"
+ << params;
+ return;
+ }
+
+ QByteArray className(params[0].toByteArray());
+ QString objectName(params[1].toString());
+ QVariantMap propertyMap(params[2].toMap());
+
+ if(!_syncSlave.contains(className)) {
+ qWarning() << "SignalProxy::handleInitData() received initData for unregistered Class:"
+ << className;
+ return;
+ }
+
+ if(!_syncSlave[className].contains(objectName)) {
+ qWarning() << "SignalProxy::handleInitData() received initData for unregistered Object:"
+ << className << objectName;
+ return;
+ }
+
+ SyncableObject *obj = _syncSlave[className][objectName];
+ setInitData(obj, propertyMap);
+}
+
+//void SignalProxy::handleSignal(const QByteArray &funcName, const QVariantList ¶ms) {
+void SignalProxy::handleSignal(const QVariantList &data) {
+ QVariantList params = data;
+ QByteArray funcName = params.takeFirst().toByteArray();
+
+ QObject* receiver;
+ int methodId;
+ SlotHash::const_iterator slot = _attachedSlots.constFind(funcName);
+ while(slot != _attachedSlots.constEnd() && slot.key() == funcName) {
+ receiver = (*slot).first;
+ methodId = (*slot).second;
+ if(!invokeSlot(receiver, methodId, params))
+ qWarning("SignalProxy::handleSignal(): invokeMethod for \"%s\" failed ", methodName(receiver, methodId).constData());
+ slot++;
+ }
+}
+
+bool SignalProxy::invokeSlot(QObject *receiver, int methodId, const QVariantList ¶ms, QVariant &returnValue) {
+ const QList<int> args = argTypes(receiver, methodId);
+ const int numArgs = params.count() < args.count()
+ ? params.count()
+ : args.count();
+
+ if(minArgCount(receiver, methodId) > params.count()) {
+ qWarning() << "SignalProxy::invokeSlot(): not enough params to invoke" << methodName(receiver, methodId);
+ return false;