From 90e439a40b2106a814da848c5336bf5abf9e3458 Mon Sep 17 00:00:00 2001
From: Rishi Sharma <rishi.sharma@epfl.ch>
Date: Sun, 9 Jan 2022 09:32:38 +0100
Subject: [PATCH] Debug TCP
---
src/decentralizepy/sharing/Sharing.py | 8 +++++---
1 file changed, 5 insertions(+), 3 deletions(-)
diff --git a/src/decentralizepy/sharing/Sharing.py b/src/decentralizepy/sharing/Sharing.py
index 8f8eb6a..ed63f85 100644
--- a/src/decentralizepy/sharing/Sharing.py
+++ b/src/decentralizepy/sharing/Sharing.py
@@ -124,7 +124,7 @@ class Sharing:
iteration = data["iteration"]
del data["degree"]
del data["iteration"]
- self.peer_deques[sender].append((degree, data))
+ self.peer_deques[sender].append((degree, iteration, data))
logging.info(
"Deserialized received model from {} of iteration {}".format(
sender, iteration
@@ -135,8 +135,10 @@ class Sharing:
total = dict()
weight_total = 0
for i, n in enumerate(self.peer_deques):
- logging.debug("Averaging model from neighbor {}".format(i))
- degree, data = self.peer_deques[n].popleft()
+ degree, iteration, data = self.peer_deques[n].popleft()
+ logging.debug(
+ "Averaging model from neighbor {} of iteration {}".format(i, iteration)
+ )
data = self.deserialized_model(data)
weight = 1 / (max(len(self.peer_deques), degree) + 1) # Metro-Hastings
weight_total += weight
--
GitLab