random remote hosts

experiments/simbricks/orchestration/e2e_components.py

@@ -367,7 +367,7 @@ class E2EMsgGenApplication(E2EApplication):
         self.remotes = []
         self.cdf = {0.5: 1, 1.0: 2}
         self.max_msg = 0
-        self.load = 0.5
+        self.load = 0.8
         self.avg_msg_size_pkts = 1.0
 
     def ns3_config(self) -> str:
@@ -394,7 +394,7 @@ class E2EMsgGenApplicationTCP(E2EApplication):
         self.remotes = []
         self.cdf = {0.5: 1, 1.0: 2}
         self.max_msg = 0
-        self.load = 0.5
+        self.load = 0.8
         self.avg_msg_size_pkts = 1.0
 
     def ns3_config(self) -> str:

experiments/simbricks/orchestration/e2e_topologies.py

@@ -322,7 +322,7 @@ def add_contig_bg(topo, subnet='10.42.0.0/16', **kwargs):
 
 def add_homa_bg(topo, subnet='10.2.0.0/16', **kwargs):
     params = {
-        'link_rate': '10Gbps',
+        'link_rate': '20Gbps',
         'link_delay': '500ns',
         'link_queue_size': '512KB',
         'app_stop_time': '60s',
@@ -346,10 +346,15 @@ def add_homa_bg(topo, subnet='10.2.0.0/16', **kwargs):
         s_host.data_rate = params['link_rate']
         s_host.ip = ip + prefix
         s_host.queue_size = params['link_queue_size']
+
+        remotes_to_connect = random.choices(remotes, k=10)
+        # print(remotes_to_connect)
+
         if (params['app_proto'] == 'tcp'):
             s_app = e2e.E2EMsgGenApplicationTCP('msggen')
             s_app.stop_time = params['app_stop_time']
-            s_app.remotes = remotes
+            s_app.remotes = remotes_to_connect
+            # s_app.max_msg = 1
             s_host.add_component(s_app)
             s_probe = e2e.E2EPeriodicSampleProbe('probe', 'Rx')
             s_probe.interval = '500ms'
@@ -359,7 +364,8 @@ def add_homa_bg(topo, subnet='10.2.0.0/16', **kwargs):
         elif(params['app_proto'] == 'homa'):
             s_app = e2e.E2EMsgGenApplication('msggen')
             s_app.stop_time = params['app_stop_time']
-            s_app.remotes = remotes
+            s_app.remotes = remotes_to_connect
+            # s_app.max_msg = 1
             s_host.add_component(s_app)
             s_probe = e2e.E2EPeriodicSampleProbe('probe', 'Rx')
             s_probe.interval = '500ms'