payload size

Author: ts5-25

examples/rpi_example/triple_example.json

@@ -11,62 +11,61 @@
             "host_name": "pi0",
             "nodes": [
                 {
-		    "node_name": "montreal",
-		    "publisher": [
-		        {"topic_name": "amazon"},
-		        {"topic_name": "nile"},
-		        {"topic_name": "ganges"},
-		        {"topic_name": "danube"}
-		      ]
-	        },
-
-	        {
-		    "node_name": "lyon",
-		    "intermediate": [
-                        {
-                            "subscriber":[
-		        	{"topic_name": "amazon"}
-		      	    ],
-		    	    "publisher": [
-		        	{"topic_name": "tigris"}
-		      	    ]
-                        }
-                    ]
-	        }
+				"node_name": "montreal",
+				"publisher": [
+					{"topic_name": "amazon"},
+					{"topic_name": "nile"},
+					{"topic_name": "ganges"},
+					{"topic_name": "danube"}
+				]
+				},
+				{
+				"node_name": "lyon",
+				"intermediate": [
+					{
+						"subscriber":[
+							{"topic_name": "amazon"}
+						],
+						"publisher": [
+							{"topic_name": "tigris"}
+						]
+					}
+					]
+				}
             ]
         },
         {
             "host_name": "pi1",
             "nodes": [
                 {
-		    "node_name": "hamburg",
-		    "intermediate": [
-                        {
-                            "subscriber":[
-		        	{"topic_name": "nile"},
-		        	{"topic_name": "tigris"},
-		       		{"topic_name": "ganges"},
-		        	{"topic_name": "danube"}
-		      	    ],
-		    	    "publisher": [
-		        	{"topic_name": "parana"}
-		      	    ]
-                        }
-                    ]
-	        },
+				"node_name": "hamburg",
+				"intermediate": [
+					{
+						"subscriber":[
+							{"topic_name": "nile"},
+							{"topic_name": "tigris"},
+							{"topic_name": "ganges"},
+							{"topic_name": "danube"}
+						],
+						"publisher": [
+							{"topic_name": "parana"}
+						]
+					}
+					]
+				},
 
 	        {
 		    "node_name": "osaka",
 		    "intermediate": [
-                        {
-                            "subscriber":[
-		        	{"topic_name": "parana"}
+                {
+                    "subscriber":[
+		        		{"topic_name": "parana"}
 		      	    ],
 		    	    "publisher": [
-		        	{"topic_name": "salween"}
+		        		{"topic_name": "salween"}
 		      	    ]
-                        }
-                    ]
+                 }
+                ]
 	        }
             ]
         },

node_options/src/cli_options.cpp

@@ -54,6 +54,14 @@ void Options::parse(int argc, char ** argv)
             std::cout << "Please specify the topic_name for this node" << std::endl;
             exit(1);
         }
+
+        if (!payload_size.empty() && payload_size.size() == 1 && !topic_names.empty()) {
+            payload_size = std::vector<int>(topic_names.size(), payload_size[0]);
+        }
+        if (!period_ms.empty() && period_ms.size() == 1 && !topic_names.empty()) {
+            period_ms = std::vector<int>(topic_names.size(), period_ms[0]);
+        }
+        
     } catch (const cxxopts::exceptions::exception & e) {
         std::cout << "Error parsing options: " << e.what() << std::endl;
         exit(1);

node_options_intermediate/src/cli_options.cpp

@@ -51,6 +51,13 @@ void Options::parse(int argc, char ** argv)
             exit(1);
         }
 
+        if (!payload_size.empty() && payload_size.size() == 1 && !topic_names_pub.empty()) {
+            payload_size = std::vector<int>(topic_names_pub.size(), payload_size[0]);
+        }
+        if (!period_ms.empty() && period_ms.size() == 1 && !topic_names_pub.empty()) {
+            period_ms = std::vector<int>(topic_names_pub.size(), period_ms[0]);
+        }
+        
         if(result.count("topic_names_pub") == 0 && result.count("topic_names_sub") == 0){
             std::cout << "Please specify the topic_name for this node" << std::endl;
             exit(1);