From fad3987e8014ede0d61441310207f27c883df5ee Mon Sep 17 00:00:00 2001 From: Oskar Thoren Date: Wed, 9 Jan 2019 08:03:37 -0500 Subject: [PATCH] Introduce random uniform naive latency --- data_sync/sync.py | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/data_sync/sync.py b/data_sync/sync.py index 964911a..8db5230 100644 --- a/data_sync/sync.py +++ b/data_sync/sync.py @@ -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))