vacp2p
/
research
mirror of https://github.com/vacp2p/research.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Introduce random uniform naive latency

This commit is contained in:
Oskar Thoren 2019-01-09 08:03:37 -05:00
parent c485a39fb5
commit fad3987e80
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
data_sync/sync.py
View File

@ -53,13 +53,18 @@ class NetworkSimulator():
n.tick()
self.time += 1
# XXX: This should be normal distribution or Poisson
def latency_uniform_random(self):
latency = random.randint(1,3)
return latency
# NOTE: Direct message, no broadcast etc
def send_message(self, sender_id, receiver_id, message):
#print "*** (network) send_message", sender_id, receiver_id
# XXX: Assuming sender exists
sender = self.peers[sender_id]
receiver = self.peers[receiver_id]
recv_time = self.time + 1
recv_time = self.time + self.latency_uniform_random()
if recv_time not in self.queue:
self.queue[recv_time] = []
self.queue[recv_time].append((sender, receiver, message))