Added some featues to the SignalProxy. Now SyncSlaves can request that objects residi...

diff --git a/src/common/signalproxy.cpp b/src/common/signalproxy.cpp
index 841a79f..0af4fdc 100644 (file)
--- a/src/common/signalproxy.cpp
+++ b/src/common/signalproxy.cpp
@@ -51,6 +51,8 @@ public:
   int sigCount() const;
   
 private:
   int sigCount() const;
   
 private:

+  bool isSyncMethod(int i);
+  

   SignalProxy* proxy;
   QObject* caller;
   QMultiHash<int, QByteArray> sigNames;
   SignalProxy* proxy;
   QObject* caller;
   QMultiHash<int, QByteArray> sigNames;


@@ -108,19 +110,33 @@ void SignalRelay::setSynchronize(bool sync) {
   if(!_sync && sync) {
     // enable Sync
     for(int i = 0; i < meta->methodCount(); i++ ) {
   if(!_sync && sync) {
     // enable Sync
     for(int i = 0; i < meta->methodCount(); i++ ) {

-      if(proxy->syncMap(caller).contains(meta->method(i).signature()))
+      if(isSyncMethod(i))

        QMetaObject::connect(caller, i, this, QObject::staticMetaObject.methodCount() + i);
     }
   } else if (_sync && !sync) {
     // disable Sync
     for(int i = 0; i < meta->methodCount(); i++ ) {
        QMetaObject::connect(caller, i, this, QObject::staticMetaObject.methodCount() + i);
     }
   } else if (_sync && !sync) {
     // disable Sync
     for(int i = 0; i < meta->methodCount(); i++ ) {

-      if(proxy->syncMap(caller).contains(meta->method(i).signature()))
+      if(isSyncMethod(i))

        QMetaObject::disconnect(caller, i, this, QObject::staticMetaObject.methodCount() + i);
     }
   }
   _sync = sync;
 }
 
        QMetaObject::disconnect(caller, i, this, QObject::staticMetaObject.methodCount() + i);
     }
   }
   _sync = sync;
 }
 

+bool SignalRelay::isSyncMethod(int i) {
+  QByteArray signature = caller->metaObject()->method(i).signature();
+  if(!proxy->syncMap(caller).contains(signature))
+    return false;
+  
+  if(proxy->proxyMode() == SignalProxy::Server && !signature.startsWith("request"))
+    return true;
+
+  if(proxy->proxyMode() == SignalProxy::Client && signature.startsWith("request"))
+    return true;
+
+  return false;
+}
+

 bool SignalRelay::synchronize() const {
   return _sync;
 }
 bool SignalRelay::synchronize() const {
   return _sync;
 }


@@ -422,39 +438,29 @@ bool SignalProxy::attachSlot(const QByteArray& sigName, QObject* recv, const cha
 }
 
 void SignalProxy::synchronize(QObject *obj) {
 }
 
 void SignalProxy::synchronize(QObject *obj) {

-  if(proxyMode() == Server)
-    return synchronizeAsMaster(obj);
-  else
-    return synchronizeAsSlave(obj);
-}
-
-void SignalProxy::synchronizeAsMaster(QObject *sender) {
-  createClassInfo(sender);
+  createClassInfo(obj);

 
 

+  // attaching all the Signals

   SignalRelay* relay;
   SignalRelay* relay;

-  if(_relayHash.contains(sender))
-    relay = _relayHash[sender];
+  if(_relayHash.contains(obj))
+    relay = _relayHash[obj];

   else
   else

-    relay = _relayHash[sender] = new SignalRelay(this, sender);
+    relay = _relayHash[obj] = new SignalRelay(this, obj);

 
   relay->setSynchronize(true);
 
 
   relay->setSynchronize(true);
 

-  if(sender->metaObject()->indexOfSignal(QMetaObject::normalizedSignature("renameObject(QString, QString)")) != -1)
-    connect(sender, SIGNAL(renameObject(QString, QString)), this, SLOT(objectRenamed(QString, QString)), Qt::DirectConnection);
+  // attaching as slave to receive sync Calls
+  QByteArray className(obj->metaObject()->className());
+  _syncSlave[className][obj->objectName()] = obj;

 
 

-  QByteArray className(sender->metaObject()->className());
-  _syncSlave[className][sender->objectName()] = sender;
+  if(proxyMode() == Server) {
+    if(obj->metaObject()->indexOfSignal(QMetaObject::normalizedSignature("renameObject(QString, QString)")) != -1)
+      connect(obj, SIGNAL(renameObject(QString, QString)), this, SLOT(objectRenamed(QString, QString)), Qt::DirectConnection);

 
 

-  setInitialized(sender);
-}
-
-void SignalProxy::synchronizeAsSlave(QObject *receiver) {
-  QByteArray className(receiver->metaObject()->className());
-  _syncSlave[className][receiver->objectName()] = receiver;
-  
-  createClassInfo(receiver);
-
-  requestInit(receiver);
+    setInitialized(obj);
+  } else {
+    requestInit(obj);
+  }

 }
 
 void SignalProxy::setInitialized(QObject *obj) {
 }
 
 void SignalProxy::setInitialized(QObject *obj) {

diff --git a/src/common/signalproxy.h b/src/common/signalproxy.h
index bf3742d..23dbc9f 100644 (file)
--- a/src/common/signalproxy.h
+++ b/src/common/signalproxy.h
@@ -64,8 +64,6 @@ public:
   bool attachSlot(const QByteArray& sigName, QObject *recv, const char *slot);
 
   void synchronize(QObject *obj);
   bool attachSlot(const QByteArray& sigName, QObject *recv, const char *slot);
 
   void synchronize(QObject *obj);

-  void synchronizeAsMaster(QObject *obj);
-  void synchronizeAsSlave(QObject *obj);

 
   void setInitialized(QObject *obj);
   bool initialized(QObject *obj);
 
   void setInitialized(QObject *obj);
   bool initialized(QObject *obj);