Merge pull request #62 from JasonRuonanWang/dataman

Removed while loop in helloDataManReader_nompi.cpp to prevent deadlock

examples/hello/datamanReader/helloDataManReader.cpp

@@ -51,11 +51,11 @@ int main(int argc, char *argv[])
             // if not defined by user, we can change the default settings
             datamanSettings.SetEngine("DataManReader");
             datamanSettings.SetParameters("peer-to-peer=yes");
-            datamanSettings.AddTransport("Mdtm", "localIP=128.0.0.0.1",
-                                         "remoteIP=128.0.0.0.2",
+            datamanSettings.AddTransport("Mdtm", "localIP=127.0.0.1",
+                                         "remoteIP=127.0.0.1",
                                          "tolerances=1,2,3");
-            // datamanSettings.AddTransport( "ZeroMQ", "localIP=128.0.0.0.1.1",
-            // "remoteIP=128.0.0.0.2.1", "tolerances=1,2,3" ); not yet supported
+            // datamanSettings.AddTransport( "ZeroMQ", "localIP=127.0.0.1",
+            // "remoteIP=127.0.0.1", "tolerances=1,2,3" ); not yet supported
             // ,
             // will throw an exception
         }

examples/hello/datamanReader/helloDataManReader_nompi.cpp

@@ -43,14 +43,12 @@ int main(int argc, char *argv[])
         {
             // if not defined by user, we can change the default settings
             datamanSettings.SetEngine("DataManReader");
-            datamanSettings.SetParameters(
-                "real_time=yes", "method_type=stream", "method=zmq",
-                "local_ip=127.0.0.1", "remote_ip=127.0.0.1", "local_port=12307",
-                "remote_port=12306");
-            // datamanSettings.AddTransport( "Mdtm", "localIP=128.0.0.0.1",
-            // "remoteIP=128.0.0.0.2", "tolerances=1,2,3" );
-            // datamanSettings.AddTransport( "ZeroMQ", "localIP=128.0.0.0.1.1",
-            // "remoteIP=128.0.0.0.2.1", "tolerances=1,2,3" ); not yet supported
+            datamanSettings.SetParameters("real_time=yes", "method_type=stream",
+                                          "method=dump");
+            // datamanSettings.AddTransport( "Mdtm", "localIP=127.0.0.1",
+            // "remoteIP=127.0.0.1", "tolerances=1,2,3" );
+            // datamanSettings.AddTransport( "ZeroMQ", "localIP=127.0.0.1",
+            // "remoteIP=127.0.0.1", "tolerances=1,2,3" ); not yet supported
             // ,
             // will throw an exception
         }
@@ -67,8 +65,9 @@ int main(int argc, char *argv[])
 
         datamanReader->SetCallBack(getcb);
 
-        while (1)
+        for (int i = 0; i < 3; i++)
         {
+            std::this_thread::sleep_for(std::chrono::milliseconds(1000));
         }
 
         adios::Variable<double> *ioMyDoubles =

examples/hello/datamanWriter/helloDataManWriter_nompi.cpp

@@ -52,10 +52,10 @@ int main(int argc, char *argv[])
                 "real_time=yes", "method_type=stream", "method=dump",
                 "monitoring=yes", "local_ip=127.0.0.1", "remote_ip=127.0.0.1",
                 "local_port=12306", "remote_port=12307");
-            // datamanSettings.AddTransport( "Mdtm", "localIP=128.0.0.0.1",
-            // "remoteIP=128.0.0.0.2", "tolerances=1,2,3" );
-            // datamanSettings.AddTransport( "ZeroMQ", "localIP=128.0.0.0.1.1",
-            // "remoteIP=128.0.0.0.2.1", "tolerances=1,2,3" ); not yet supported
+            // datamanSettings.AddTransport( "Mdtm", "localIP=127.0.0.1",
+            // "remoteIP=127.0.0.1", "tolerances=1,2,3" );
+            // datamanSettings.AddTransport( "ZeroMQ", "localIP=127.0.0.1",
+            // "remoteIP=127.0.0.1", "tolerances=1,2,3" ); not yet supported
             // ,
             // will throw an exception
         }

source/utilities/realtime/dataman/DataMan.cpp

@@ -38,7 +38,7 @@ void DataMan::add_file(std::string p_method) {}
 void DataMan::add_stream(json p_jmsg)
 {
 
-    std::string method = "zmq";
+    std::string method;
 
     if (p_jmsg["method"] != nullptr)
         method = p_jmsg["method"];