-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);
-
- switch(call.toInt()) {
- case Sync:
- return handleSync(params);
- case InitRequest:
- return handleInitRequest(sender, params);
- case InitData:
- return handleInitData(sender, params);
- default:
- qWarning() << "received undefined CallType" << call.toInt();
- return;
- }
-}
-
-void SignalProxy::handleSync(QVariantList params) {
- if(params.count() < 3) {
- qWarning() << "received invalid Sync call" << params;
- return;
- }
-
- QByteArray className = params.takeFirst().toByteArray();
- QString objectName = params.takeFirst().toString();
- int signalId = params.takeFirst().toInt();
-
- if(!_syncSlave.contains(className) || !_syncSlave[className].contains(objectName)) {
- qWarning() << "no registered receiver:" << className << objectName << "for Sync call" << signalId << params;
- return;
- }
-
- QObject *receiver = _syncSlave[className][objectName];
- if(!syncMap(receiver).contains(signalId)) {
- const QMetaObject *meta = receiver->metaObject();
- QString signalName;
- if(signalId < meta->methodCount())
- signalName = QString(meta->method(signalId).signature());
- else
- signalName = QString::number(signalId);
-
- 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());
-}
-
-void SignalProxy::handleInitRequest(QIODevice *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;
- }
-
- QObject *obj = _syncSlave[className][objectName];
-
- QVariantList params_;
- params_ << obj->metaObject()->className()
- << obj->objectName()
- << initData(obj);
-
- dispatchSignal(sender, (int)InitData, params_);
-}
-
-void SignalProxy::handleInitData(QIODevice *sender, const QVariantList ¶ms) {
- Q_UNUSED(sender)
- if(params.count() != 3) {
- qWarning() << "SignalProxy::handleInitRequest() received initRequest 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::handleInitRequest() received initRequest for unregistered Class:"
- << className;
- return;
- }
-
- if(!_syncSlave[className].contains(objectName)) {
- qWarning() << "SignalProxy::handleInitRequest() received initRequest for unregistered Object:"
- << className << objectName;
- return;
- }
-
- QObject *obj = _syncSlave[className][objectName];
- setInitData(obj, propertyMap);
-}
-
-void SignalProxy::handleSignal(const QByteArray &funcName, const QVariantList ¶ms) {
- 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) {
- int numParams = argTypes(receiver, methodId).count();
- QGenericArgument args[9];
- for(int i = 0; i < numParams; i++)
- args[i] = QGenericArgument(params[i].typeName(), params[i].constData());
- return QMetaObject::invokeMethod(receiver, methodName(receiver, methodId), args[0], args[1], args[2], args[3], args[4], args[5], args[6], args[7], args[8]);
-}
-
-void SignalProxy::dataAvailable() {
- // yet again. it's a private slot. no need for checks.
- QIODevice* ioDev = qobject_cast<QIODevice* >(sender());
- QVariant var;
- while(readDataFromDevice(ioDev, _peerByteCount[ioDev], var))
- receivePeerSignal(ioDev, var);
-}
-
-void SignalProxy::writeDataToDevice(QIODevice *dev, const QVariant &item) {
- QAbstractSocket* sock = qobject_cast<QAbstractSocket*>(dev);
- if(!dev->isOpen() || (sock && sock->state()!=QAbstractSocket::ConnectedState)) {
- qWarning("SignalProxy: Can't call on a closed device");
- return;
- }
- QByteArray block;
- QDataStream out(&block, QIODevice::WriteOnly);
- out.setVersion(QDataStream::Qt_4_2);
- out << (quint32)0 << item;
- out.device()->seek(0);
- out << (quint32)(block.size() - sizeof(quint32));
- dev->write(block);
-}
-
-bool SignalProxy::readDataFromDevice(QIODevice *dev, quint32 &blockSize, QVariant &item) {
- QDataStream in(dev);
- in.setVersion(QDataStream::Qt_4_2);
-
- if(blockSize == 0) {
- if(dev->bytesAvailable() < (int)sizeof(quint32)) return false;
- in >> blockSize;
- }
-
- if(dev->bytesAvailable() < blockSize)
- return false;
- in >> item;
- blockSize = 0;
- return true;