loic/esds
1
0
Fork 0
mirror of https://gitlab.com/manzerbredes/esds.git synced 2025-04-06 01:56:27 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

Enable nodes to have multiple interfaces

Browse source
This commit is contained in:
Loic Guegan 2022-06-10 21:19:43 +02:00
parent 7540e8290d
commit 3fef2bbf4b
1 changed files with 6 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
esds.py
View file

@ -5,7 +5,7 @@ import threading,importlib,queue,sys,time
class Node:
available_node_id=0
def __init__(self,src):
def __init__(self,src,interfaces):
"""
"""
@ -16,7 +16,10 @@ class Node:
self.rargs=None # Store the requests arguments
self.plugins=list() # Contains all registered node plugins
self.rqueue=queue.Queue() # Receive simulator acknowledgments
self.chest={"state":"running", "turned_on":True, "request": None, "interfaces":{"wlan0":queue.Queue(), "eth0":queue.Queue()}, "interfaces_queue_size":{"wlan0":0,"eth0":0}}
self.chest={"state":"running", "turned_on":True, "request": None, "interfaces":dict(), "interfaces_queue_size":dict()}
for interface in interfaces:
self.chest["interfaces"][interface]=queue.Queue()
self.chest["interfaces_queue_size"][interface]=0
self.chest_lock=threading.Lock() # To access/modify self.chest
def plugin_register(self,plugin):
@ -266,7 +269,7 @@ class Simulator:
"""
Create a node thread and run it
"""
node=Node(src)
node=Node(src, self.netmat.keys())
self.nodes.append(node)
thread=threading.Thread(target=node.run, daemon=False,args=[args])
thread.start()