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

Switch to dictionary for the network matrices

Browse source
This commit is contained in:
Loic Guegan 2022-06-10 19:49:19 +02:00
parent 94b47ceab5
commit 7540e8290d
26 changed files with 72 additions and 72 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

66
esds.py
View file

@ -190,13 +190,14 @@ class Simulator:
one may not gives accurate results because of missing entries in the nodes received queues.
"""
def __init__(self,B_wlan0,L_wlan0,B_eth0,L_eth0):
self.B_wlan0=B_wlan0
self.L_wlan0=L_wlan0
self.B_eth0=B_eth0
self.L_eth0=L_eth0
def __init__(self,netmat):
"""
Format of netmat: { "wlan0": (BW,L), "eth0": (BW,L) }
Where BW are the bandwidth matrices and L the latency matrices
"""
self.netmat=netmat
self.nodes=list()
self.sharing=np.zeros(len(B_eth0))
self.sharing=np.zeros(len(netmat["eth0"]["bandwidth"]))
self.events=np.empty((0,4),dtype=object)
self.events_dirty=True # For optimization reasons
self.startat=-1
@ -207,44 +208,29 @@ class Simulator:
self.wait_end_nodes=list() # Keep track of nodes that wait for the end of the simulation
self.time_truncated=format(self.time,self.precision) # Truncated version is used in log print
def update_network(self,B_wlan0,L_wlan0,B_eth0,L_eth0):
def update_network(self,netmat):
for event in self.events:
if int(event[0]) == 0:
cur_event=event[2]
ts=float(event[1])
src_id,dst_id,interface, data, datasize,duration, datasize_remaining,start_at=cur_event
if interface == "wlan0":
new_bw=B_wlan0[int(src_id),int(dst_id)]
old_bw=self.B_wlan0[int(src_id),int(dst_id)]
new_lat=L_wlan0[int(src_id),int(dst_id)]
old_lat=self.L_wlan0[int(src_id),int(dst_id)]
if new_bw != old_bw or new_lat != old_lat:
new_datasize_remaining=float(datasize_remaining)*((ts-self.time)/float(duration))
if new_datasize_remaining > 0:
latency_factor=new_datasize_remaining/float(datasize)
new_bw=netmat[interface]["bandwidth"][int(src_id),int(dst_id)]
old_bw=self.netmat[interface]["bandwidth"][int(src_id),int(dst_id)]
new_lat=netmat[interface]["latency"][int(src_id),int(dst_id)]
old_lat=self.netmat[interface]["latency"][int(src_id),int(dst_id)]
if new_bw != old_bw or new_lat != old_lat:
new_datasize_remaining=float(datasize_remaining)*((ts-self.time)/float(duration))
if new_datasize_remaining > 0:
latency_factor=new_datasize_remaining/float(datasize)
if interface == "wlan0":
new_duration=new_datasize_remaining*8/new_bw+new_lat*latency_factor
event[1]=self.time+new_duration
event[2][6]=new_datasize_remaining
event[2][5]=new_duration
else:
new_bw=B_eth0[int(src_id),int(dst_id)]
old_bw=self.B_eth0[int(src_id),int(dst_id)]
new_lat=L_eth0[int(src_id),int(dst_id)]
old_lat=self.L_eth0[int(src_id),int(dst_id)]
if new_bw != old_bw or new_lat != old_lat:
new_datasize_remaining=float(datasize_remaining)*((ts-self.time)/float(duration))
if new_datasize_remaining > 0:
latency_factor=new_datasize_remaining/float(datasize)
else:
new_duration=new_datasize_remaining*8/(new_bw/self.sharing[int(dst_id)])+new_lat*latency_factor
event[1]=self.time+new_duration
event[2][6]=new_datasize_remaining
event[2][5]=new_duration
self.B_wlan0=B_wlan0
self.L_wlan0=L_wlan0
self.B_eth0=B_eth0
self.L_eth0=L_eth0
event[1]=self.time+new_duration
event[2][6]=new_datasize_remaining
event[2][5]=new_duration
self.netmat=netmat
def debug(self):
"""
Log all the informations for debugging
@ -467,7 +453,7 @@ class Simulator:
self.log("Send "+str(datasize)+" bytes on "+interface,node=src)
for dst in self.list_wireless_receivers(nsrc):
if self.nodes[dst]["turned_on"]:
duration=datasize*8/self.B_wlan0[src,dst]+self.L_wlan0[src,dst]
duration=datasize*8/self.netmat["wlan0"]["bandwidth"][src,dst]+self.netmat["wlan0"]["latency"][src,dst]
if src == dst:
self.add_event(0,duration+self.time,(src,dst,interface,data,datasize,duration,datasize,self.time))
elif not self.interferences:
@ -479,7 +465,7 @@ class Simulator:
self.log("Send "+str(datasize)+" bytes to n"+str(dst)+" on "+interface,node=src)
self.update_sharing(dst,1) # Update sharing first
# Note that in the following we send more data than expected to handle bandwidth sharing (datasize*8*sharing):
duration=datasize*8/(self.B_eth0[src,dst]/self.sharing[dst])+self.L_eth0[src,dst]
duration=datasize*8/(self.netmat["eth0"]["bandwidth"][src,dst]/self.sharing[dst])+self.netmat["eth0"]["latency"][src,dst]
self.add_event(0,duration+self.time,(src,dst,interface,data,datasize,duration,datasize,self.time))
else:
nsrc["state"]="request" # Try later when node is on
@ -489,7 +475,7 @@ class Simulator:
"""
Deduce reachable receivers from the bandwidth matrix
"""
selector = self.B_wlan0[node.node_id,] > 0
selector = self.netmat["wlan0"]["bandwidth"][node.node_id,] > 0
return np.arange(0,selector.shape[0])[selector]

2
example/simulator.py
View file

@ -26,7 +26,7 @@ B=np.full((n,n),5) # 5Mbps
L=np.full((n,n),0) # 0s
##### Create the simulator
s=esds.Simulator(B,L,B,L)
s=esds.Simulator({"wlan0":{"bandwidth":B, "latency":L},"eth0":{"bandwidth":B, "latency":L}})
##### Instantiate nodes
uptime=180 # 180s uptime

2
tests/hidden_node_2s1r/simulator.py
View file

@ -13,7 +13,7 @@ B[0,2]=0
B[2,0]=0
L=np.full((3,3),0)
s=esds.Simulator(B,L,B,L)
s=esds.Simulator({"wlan0":{"bandwidth":B, "latency":L},"eth0":{"bandwidth":B, "latency":L}})
s.create_node("sender")
s.create_node("receiver")

6
tests/mobility_eth0_bandwidth_1s1r/simulator.py
View file

@ -26,13 +26,15 @@ import numpy as np
B=np.full((2,2),8)
L=np.full((2,2),0)
s=esds.Simulator(B,L,B,L)
s=esds.Simulator({"wlan0":{"bandwidth":B, "latency":L},"eth0":{"bandwidth":B, "latency":L}})
s.create_node("sender")
s.create_node("receiver")
def callback(simulator):
simulator.log("Network update!")
simulator.update_network(simulator.B_wlan0*2,simulator.L_wlan0,simulator.B_eth0*2,simulator.L_eth0)
new_bw_wlan0=simulator.netmat["wlan0"]["bandwidth"]*2
new_bw_eth0=simulator.netmat["eth0"]["bandwidth"]*2
simulator.update_network({"wlan0":{"bandwidth":new_bw_wlan0, "latency":L},"eth0":{"bandwidth":new_bw_eth0, "latency":L}})
s.run(breakpoints_every=1/2,breakpoint_callback=callback)

6
tests/mobility_eth0_bandwidth_2s1r/simulator.py
View file

@ -28,7 +28,7 @@ import numpy as np
B=np.full((3,3),8)
L=np.full((3,3),0)
s=esds.Simulator(B,L,B,L)
s=esds.Simulator({"wlan0":{"bandwidth":B, "latency":L},"eth0":{"bandwidth":B, "latency":L}})
s.create_node("sender")
s.create_node("sender")
@ -36,6 +36,8 @@ s.create_node("receiver")
def callback(simulator):
simulator.log("Network update!")
simulator.update_network(simulator.B_wlan0*2,simulator.L_wlan0,simulator.B_eth0*2,simulator.L_eth0)
new_bw_wlan0=simulator.netmat["wlan0"]["bandwidth"]*2
new_bw_eth0=simulator.netmat["eth0"]["bandwidth"]*2
simulator.update_network({"wlan0":{"bandwidth":new_bw_wlan0, "latency":L},"eth0":{"bandwidth":new_bw_eth0, "latency":L}})
s.run(breakpoints_every=1,breakpoint_callback=callback,debug=True)

8
tests/mobility_eth0_latency_1s1r/simulator.py
View file

@ -27,13 +27,15 @@ import numpy as np
B=np.full((2,2),8)
L=np.full((2,2),0)
s=esds.Simulator(B,L,B,L)
s=esds.Simulator({"wlan0":{"bandwidth":B, "latency":L},"eth0":{"bandwidth":B, "latency":L}})
s.create_node("sender")
s.create_node("receiver")
def callback(simulator):
simulator.log("Network update!")
simulator.update_network(simulator.B_wlan0,simulator.L_wlan0+1/2,simulator.B_eth0,simulator.L_eth0+1/2)
new_lat_wlan0=simulator.netmat["wlan0"]["latency"]+1/2
new_lat_eth0=simulator.netmat["eth0"]["latency"]+1/2
simulator.update_network({"wlan0":{"bandwidth":B, "latency":new_lat_wlan0},"eth0":{"bandwidth":B, "latency":new_lat_eth0}})
s.run(breakpoints_every=1/2,breakpoint_callback=callback)

6
tests/mobility_eth0_latency_2s1r/simulator.py
View file

@ -29,7 +29,7 @@ import numpy as np
B=np.full((3,3),8)
L=np.full((3,3),0)
s=esds.Simulator(B,L,B,L)
s=esds.Simulator({"wlan0":{"bandwidth":B, "latency":L},"eth0":{"bandwidth":B, "latency":L}})
s.create_node("sender")
s.create_node("sender")
@ -37,6 +37,8 @@ s.create_node("receiver")
def callback(simulator):
simulator.log("Network update!")
simulator.update_network(simulator.B_wlan0,simulator.L_wlan0+0.5,simulator.B_eth0,simulator.L_eth0+0.5)
new_lat_wlan0=simulator.netmat["wlan0"]["latency"]+1/2
new_lat_eth0=simulator.netmat["eth0"]["latency"]+1/2
simulator.update_network({"wlan0":{"bandwidth":B, "latency":new_lat_wlan0},"eth0":{"bandwidth":B, "latency":new_lat_eth0}})
s.run(breakpoints_every=1,breakpoint_callback=callback,debug=True)

7
tests/mobility_wlan0_bandwidth_1s1r/simulator.py
View file

@ -26,13 +26,16 @@ import numpy as np
B=np.full((2,2),8)
L=np.full((2,2),0)
s=esds.Simulator(B,L,B,L)
s=esds.Simulator({"wlan0":{"bandwidth":B, "latency":L},"eth0":{"bandwidth":B, "latency":L}})
s.create_node("sender")
s.create_node("receiver")
def callback(simulator):
simulator.log("Network update!")
simulator.update_network(simulator.B_wlan0*2,simulator.L_wlan0,simulator.B_eth0*2,simulator.L_eth0)
new_bw_wlan0=simulator.netmat["wlan0"]["bandwidth"]*2
new_bw_eth0=simulator.netmat["eth0"]["bandwidth"]*2
simulator.update_network({"wlan0":{"bandwidth":new_bw_wlan0, "latency":L},"eth0":{"bandwidth":new_bw_eth0, "latency":L}})
s.run(breakpoints_every=1/2,breakpoint_callback=callback)

7
tests/mobility_wlan0_latency_1s1r/simulator.py
View file

@ -27,13 +27,16 @@ import numpy as np
B=np.full((2,2),8)
L=np.full((2,2),0)
s=esds.Simulator(B,L,B,L)
s=esds.Simulator({"wlan0":{"bandwidth":B, "latency":L},"eth0":{"bandwidth":B, "latency":L}})
s.create_node("sender")
s.create_node("receiver")
def callback(simulator):
simulator.log("Network update!")
simulator.update_network(simulator.B_wlan0,simulator.L_wlan0+1/2,simulator.B_eth0,simulator.L_eth0+1/2)
new_lat_wlan0=simulator.netmat["wlan0"]["latency"]+1/2
new_lat_eth0=simulator.netmat["eth0"]["latency"]+1/2
simulator.update_network({"wlan0":{"bandwidth":B, "latency":new_lat_wlan0},"eth0":{"bandwidth":B, "latency":new_lat_eth0}})
s.run(breakpoints_every=1/2,breakpoint_callback=callback)

2
tests/simple_breakpoints_auto_1n/simulator.py
View file

@ -9,7 +9,7 @@ import numpy as np
n=2
B=np.full((2,2),n)
L=np.full((2,2),0)
s=esds.Simulator(B,L,B,L)
s=esds.Simulator({"wlan0":{"bandwidth":B, "latency":L},"eth0":{"bandwidth":B, "latency":L}})
s.create_node("node")
s.create_node("node")

2
tests/simple_breakpoints_manual_1n/simulator.py
View file

@ -9,7 +9,7 @@ import numpy as np
n=2
B=np.full((n,n),n)
L=np.full((n,n),0)
s=esds.Simulator(B,L,B,L)
s=esds.Simulator({"wlan0":{"bandwidth":B, "latency":L},"eth0":{"bandwidth":B, "latency":L}})
s.create_node("node")
s.create_node("node")

2
tests/simple_breakpoints_manual_no_callback_1n/simulator.py
View file

@ -9,7 +9,7 @@ import numpy as np
n=2
B=np.full((n,n),n)
L=np.full((n,n),0)
s=esds.Simulator(B,L,B,L)
s=esds.Simulator({"wlan0":{"bandwidth":B, "latency":L},"eth0":{"bandwidth":B, "latency":L}})
s.create_node("node")
s.create_node("node")

2
tests/simple_log_5n/simulator.py
View file

@ -8,7 +8,7 @@ import numpy as np
B=np.full((5,5),5)
L=np.full((5,5),0)
s=esds.Simulator(B,L,B,L)
s=esds.Simulator({"wlan0":{"bandwidth":B, "latency":L},"eth0":{"bandwidth":B, "latency":L}})
s.create_node("node")
s.create_node("node")

2
tests/simple_read_clock_2n/simulator.py
View file

@ -8,7 +8,7 @@ import numpy as np
B=np.full((2,2),2)
L=np.full((2,2),0)
s=esds.Simulator(B,L,B,L)
s=esds.Simulator({"wlan0":{"bandwidth":B, "latency":L},"eth0":{"bandwidth":B, "latency":L}})
s.create_node("node")
s.create_node("node")

2
tests/simple_read_eth0_ncom_2s1r/simulator.py
View file

@ -8,7 +8,7 @@ import numpy as np
B=np.full((3,3),3)
L=np.full((3,3),0)
s=esds.Simulator(B,L,B,L)
s=esds.Simulator({"wlan0":{"bandwidth":B, "latency":L},"eth0":{"bandwidth":B, "latency":L}})
s.create_node("sender")
s.create_node("sender")

2
tests/simple_read_wlan0_ncom_2s1r/simulator.py
View file

@ -8,7 +8,7 @@ import numpy as np
B=np.full((3,3),3)
L=np.full((3,3),0)
s=esds.Simulator(B,L,B,L)
s=esds.Simulator({"wlan0":{"bandwidth":B, "latency":L},"eth0":{"bandwidth":B, "latency":L}})
s.create_node("sender")
s.create_node("sender")

2
tests/simple_receivet_eth0_1s1r/simulator.py
View file

@ -8,7 +8,7 @@ import numpy as np
B=np.full((2,2),8)
L=np.full((2,2),0)
s=esds.Simulator(B,L,B,L)
s=esds.Simulator({"wlan0":{"bandwidth":B, "latency":L},"eth0":{"bandwidth":B, "latency":L}})
s.create_node("sender")
s.create_node("receiver")

2
tests/simple_send_eth0_1s1r/simulator.py
View file

@ -8,7 +8,7 @@ import numpy as np
B=np.full((2,2),8)
L=np.full((2,2),0)
s=esds.Simulator(B,L,B,L)
s=esds.Simulator({"wlan0":{"bandwidth":B, "latency":L},"eth0":{"bandwidth":B, "latency":L}})
s.create_node("sender")
s.create_node("receiver")

2
tests/simple_send_eth0_2s1r/simulator.py
View file

@ -8,7 +8,7 @@ import numpy as np
B=np.full((3,3),8)
L=np.full((3,3),0)
s=esds.Simulator(B,L,B,L)
s=esds.Simulator({"wlan0":{"bandwidth":B, "latency":L},"eth0":{"bandwidth":B, "latency":L}})
s.create_node("sender")
s.create_node("sender")

2
tests/simple_send_eth0_3s1r/simulator.py
View file

@ -8,7 +8,7 @@ import numpy as np
B=np.full((4,4),8)
L=np.full((4,4),0)
s=esds.Simulator(B,L,B,L)
s=esds.Simulator({"wlan0":{"bandwidth":B, "latency":L},"eth0":{"bandwidth":B, "latency":L}})
s.create_node("sender")
s.create_node("sender")

2
tests/simple_send_wlan0_1s2r/simulator.py
View file

@ -8,7 +8,7 @@ import numpy as np
B=np.full((3,3),8)
L=np.full((3,3),0)
s=esds.Simulator(B,L,B,L)
s=esds.Simulator({"wlan0":{"bandwidth":B, "latency":L},"eth0":{"bandwidth":B, "latency":L}})
s.create_node("sender")
s.create_node("receiver")

2
tests/simple_send_wlan0_2s1r/simulator.py
View file

@ -8,7 +8,7 @@ import numpy as np
B=np.full((3,3),8)
L=np.full((3,3),0)
s=esds.Simulator(B,L,B,L)
s=esds.Simulator({"wlan0":{"bandwidth":B, "latency":L},"eth0":{"bandwidth":B, "latency":L}})
s.create_node("sender")
s.create_node("sender")

2
tests/simple_sendt_eth0_1s1r/simulator.py
View file

@ -8,7 +8,7 @@ import numpy as np
B=np.full((2,2),8)
L=np.full((2,2),0)
s=esds.Simulator(B,L,B,L)
s=esds.Simulator({"wlan0":{"bandwidth":B, "latency":L},"eth0":{"bandwidth":B, "latency":L}})
s.create_node("sender")
s.create_node("receiver")

2
tests/simple_sendt_wlan0_1s2r/simulator.py
View file

@ -8,7 +8,7 @@ import numpy as np
B=np.full((3,3),8)
L=np.full((3,3),0)
s=esds.Simulator(B,L,B,L)
s=esds.Simulator({"wlan0":{"bandwidth":B, "latency":L},"eth0":{"bandwidth":B, "latency":L}})
s.create_node("sender")
s.create_node("receiver")

2
tests/simple_wait_2n/simulator.py
View file

@ -8,7 +8,7 @@ import numpy as np
B=np.full((2,2),2)
L=np.full((2,2),0)
s=esds.Simulator(B,L,B,L)
s=esds.Simulator({"wlan0":{"bandwidth":B, "latency":L},"eth0":{"bandwidth":B, "latency":L}})
s.create_node("node")
s.create_node("node")

2
tests/simple_wait_end_3n/simulator.py
View file

@ -8,7 +8,7 @@ import numpy as np
B=np.full((3,3),2)
L=np.full((3,3),0)
s=esds.Simulator(B,L,B,L)
s=esds.Simulator({"wlan0":{"bandwidth":B, "latency":L},"eth0":{"bandwidth":B, "latency":L}})
s.create_node("node")
s.create_node("node")