diff --git a/eval/run_xtimes_reddit_rws.sh b/eval/run_xtimes_reddit_rws.sh index b6024de69738a067bd3937eda0c22f599b17d733..c206222a7551f1d960914b8051ca2d8e0a00d935 100755 --- a/eval/run_xtimes_reddit_rws.sh +++ b/eval/run_xtimes_reddit_rws.sh @@ -71,7 +71,7 @@ echo samples per user: $samples_per_user # random_seeds for which to rerun the experiments # random_seeds=("90" "91" "92" "93" "94") -random_seeds=("90" "91" "92") +random_seeds=("92") echo batchsize: $batchsize echo communication rounds per global epoch: $comm_rounds_per_global_epoch # calculating how many batches there are in a global epoch for each user/proc diff --git a/src/decentralizepy/communication/TCPRandomWalkRouting.py b/src/decentralizepy/communication/TCPRandomWalkRouting.py index fd5f6385ec86eb1c27bb4c1bb0ff0ff56f4be47e..14334201af64c0851256e9aa3909104d260284f1 100644 --- a/src/decentralizepy/communication/TCPRandomWalkRouting.py +++ b/src/decentralizepy/communication/TCPRandomWalkRouting.py @@ -427,6 +427,7 @@ class TCPRandomWalkRoutingInternal(TCPRandomWalkBase): if src in self.current_neighbors: logging.info("fw arrived at a neighbour") print("fw arrived at a neighbour") + self.add_neighbors(src, data[1]) else: logging.debug("Received {} from {}".format(data, src)) self.add_neighbors(src, data[1])