"vio": VIOInfraCollector
}
SDN_INFRA_COLLECTORS = {
- "onos": OnosInfraCollector
+ "onosof": OnosInfraCollector,
+ "onos_vpls": OnosInfraCollector
}
processes.append(p)
p.start()
for process in processes:
- process.join(timeout=10)
+ process.join(timeout=20)
+ for process in processes:
+ if process.is_alive():
+ process.terminate()
metrics = []
while not self.queue.empty():
metrics.append(self.queue.get())