diff --git a/mininet_deployer.py b/mininet_deployer.py index 41bb9ce..6c276a2 100755 --- a/mininet_deployer.py +++ b/mininet_deployer.py @@ -243,9 +243,14 @@ def topo(topology): if verbose: print "*** VSs Properties", vss_properties[i] i = i + 1 - + + # Cycle over all nodes and start grpc servers + if parser.path_grpc != "": + net.grpc_path = parser.path_grpc + my_info = net.start() store_overall_info(my_info) + if tf_version == 1: CLI(net) net.stop() diff --git a/mininet_extensions.py b/mininet_extensions.py index c788ea3..fc00210 100644 --- a/mininet_extensions.py +++ b/mininet_extensions.py @@ -109,6 +109,8 @@ def __init__(self, verbose=False): self.node_to_node = {} self.node_to_default_via = {} self.coex = {} + + self.grpc_path = "" self.verbose = verbose @@ -824,6 +826,15 @@ def start(self): vllcfg_file.write(json.dumps(vllcfg, sort_keys=True, indent=4)) vllcfg_file.close() + if self.grpc_path != "": + all_nodes = self.cr_oshis + self.pe_oshis + self.ce_routers + start_server = ["python",self.grpc_path,"&"] + print "Starting grpc servers with %s" % start_server + for node in all_nodes: + node_name = node.name + node.popen(start_server) + print "*** Starting grpc server on %s at %s" % (node_name, node.IP()) + mylog("*** Nodes are running sshd at the following addresses\n") for host in self.hosts: