logging.exception("RPC error.")
return ex.message
- # setup the rate measurement for a vnf interface
- def monitor_setup_rate_measurement(self, vnf_name, vnf_interface, metric):
- logging.debug("RPC CALL: get rate")
- try:
- c = self.net.monitor_agent.setup_rate_measurement(vnf_name, vnf_interface, metric)
- return c
- except Exception as ex:
- logging.exception("RPC error.")
- return ex.message
-
- # get egress(default) or ingress rate of a vnf
- def monitor_get_rate(self, vnf_name, vnf_interface, metric):
- logging.debug("RPC CALL: get rate")
- try:
- c = self.net.monitor_agent.get_rate(vnf_name, vnf_interface, metric)
- return c
- except Exception as ex:
- logging.exception("RPC error.")
- return ex.message
-
-
This class is used by topology definition scripts.
"""
- def __init__(self, controller=RemoteController,
+ def __init__(self, controller=RemoteController, monitor=True,
dc_emulation_max_cpu=1.0, # fraction of overall CPU time for emulation
dc_emulation_max_mem=512, # emulation max mem in MB
**kwargs):
self.DCNetwork_graph = nx.MultiDiGraph()
# monitoring agent
- self.monitor_agent = DCNetworkMonitor(self)
+ if monitor:
+ self.monitor_agent = DCNetworkMonitor(self)
+ else:
+ self.monitor_agent = None
# initialize resource model registrar
self.rm_registrar = ResourceModelRegistrar(
Dockernet.start(self)
def stop(self):
+
# stop the monitor agent
- self.monitor_agent.stop()
+ if self.monitor_agent is not None:
+ self.monitor_agent.stop()
# stop emulator net
Dockernet.stop(self)