Changeset 20316

Timestamp:

06/21/07 15:30:14 (1 year ago)

Author:

aronb

Message:

Hack to ensure that we don't start listening for connections until we have fully configured all other nodes.

Files:

• juggler/branches/2.0/modules/gadgeteer/gadget/AbstractNetworkManager.cpp (modified) (2 diffs)

juggler/branches/2.0/modules/gadgeteer/gadget/AbstractNetworkManager.cpp

@@ -381 +381 @@
-   }
-
+   struct ElementPred
+   {
+      ElementPred(const std::string& type)
+         : mType(type)
+      {
+         /* Do nothing. */ ;
+      }
+
+      bool operator()(const jccl::ConfigManager::PendingElement& p)
+      {
+         return p.mElement->getID() == mType;
+      }
+
+      const std::string mType;
+   };
+
-   bool AbstractNetworkManager::configAdd(jccl::ConfigElementPtr element)
-   {
@@ -393 +409 @@
-         if (isLocalHost( element->getProperty<std::string>( "host_name" ) ))
-         {
+            // XXX: Hack to ensure that we don't start listening for connections until
+            //      we have fully configured all other nodes.
+            ElementPred pred(getClusterNodeElementType());
+
+            jccl::ConfigManager* cfg_mgr = jccl::ConfigManager::instance();
+            unsigned int num_pending_nodes =
+               std::count_if(cfg_mgr->getPendingBegin(), cfg_mgr->getPendingEnd(), pred);
+
+            if (num_pending_nodes > 1)
+            {
+               vprDEBUG( gadgetDBG_NET_MGR, vprDBG_CONFIG_LVL ) << clrSetBOLD(clrRED)
+                  << clrOutBOLD( clrMAGENTA,"[AbstractNetworkManager]" )
+                  << " Some nodes not configured yet: " << num_pending_nodes
+                  << clrRESET << std::endl << vprDEBUG_FLUSH;
+               return false;
+            }
+
-            // NOTE: Add all machine dependent ConfigElementPtr's here
-            vprASSERT( element->getNum("display_system") == 1