zeromq / netmq

A 100% native C# implementation of ZeroMQ for .NET
Other
2.94k stars 742 forks source link

NetMQBeacon beacon is not sent on every interval. #1046

Open Muhomorik opened 1 year ago

Muhomorik commented 1 year ago

Environment

NetMQ Version:    4.0.1.10
Operating System:  Win10 x64
.NET Version:  net6.0-windows10.0.20348.0

Expected behaviour

Beacon should be received every second

Actual behaviour

When running slightly trimmed beacon demo it works nice even with 6 instances on local computer. When running sample on 3 computers it also kind of works. When starting on more computers, the beacon interval is random.

10:12:16.3116|BroadcastBus.OnBeaconReady|Beacon received, node exists: 192.168.1.212:61312.
10:12:20.9517|BroadcastBus.OnBeaconReady|Beacon received, node exists: 192.168.1.206:53555.
10:12:25.5577|BroadcastBus.OnBeaconReady|Beacon received, node exists: 192.168.1.52:62698.
10:12:30.3397|BroadcastBus.OnBeaconReady|Beacon received, node exists: 192.168.1.212:61312.
10:12:35.0909|BroadcastBus.OnBeaconReady|Beacon received, node exists: 192.168.1.206:53555.
10:12:39.9936|BroadcastBus.OnBeaconReady|Beacon received, node exists: 192.168.1.52:62698.
10:12:44.8796|BroadcastBus.OnBeaconReady|Beacon received, node exists: 192.168.1.212:61312.
10:12:49.5197|BroadcastBus.OnBeaconReady|Beacon received, node exists: 192.168.1.206:53555.
10:12:54.2253|BroadcastBus.OnBeaconReady|Beacon received, node exists: 192.168.1.52:62698.
10:12:59.8329|BroadcastBus.OnBeaconReady|Beacon received, node exists: 192.168.1.212:61312.
10:12:59.8329|BroadcastBus.ClearDeadNodes|Remove: 192.168.1.206:53555.

10:13:04.5776|BroadcastBus.OnBeaconReady|Beacon received, new beacon: 192.168.1.206:53555.
10:13:09.1762|BroadcastBus.OnBeaconReady|Beacon received, node exists: 192.168.1.52:62698.
10:13:14.5512|BroadcastBus.OnBeaconReady|Beacon received, node exists: 192.168.1.212:61312.
10:13:19.3213|BroadcastBus.OnBeaconReady|Beacon received, node exists: 192.168.1.206:53555.
10:13:23.9271|BroadcastBus.OnBeaconReady|Beacon received, node exists: 192.168.1.52:62698.
10:13:28.6211|BroadcastBus.OnBeaconReady|Beacon received, node exists: 192.168.1.212:61312.
10:13:33.4491|BroadcastBus.OnBeaconReady|Beacon received, node exists: 192.168.1.206:53555.
10:13:38.0595|BroadcastBus.OnBeaconReady|Beacon received, node exists: 192.168.1.52:62698.
10:13:43.4114|BroadcastBus.OnBeaconReady|Beacon received, node exists: 192.168.1.212:61312.
10:13:48.1999|BroadcastBus.OnBeaconReady|Beacon received, node exists: 192.168.1.206:53555.
10:13:53.1099|BroadcastBus.OnBeaconReady|Beacon received, node exists: 192.168.1.52:62698.
10:13:57.8898|BroadcastBus.OnBeaconReady|Beacon received, node exists: 192.168.1.212:61312.
10:14:02.9299|BroadcastBus.OnBeaconReady|Beacon received, node exists: 192.168.1.206:53555.
10:14:07.5410|BroadcastBus.OnBeaconReady|Beacon received, node exists: 192.168.1.52:62698.
10:14:12.3306|BroadcastBus.OnBeaconReady|Beacon received, node exists: 192.168.1.212:61312.
10:14:17.0766|BroadcastBus.OnBeaconReady|Beacon received, node exists: 192.168.1.206:53555.
10:14:21.6806|BroadcastBus.OnBeaconReady|Beacon received, node exists: 192.168.1.52:62698.
10:14:26.3802|BroadcastBus.OnBeaconReady|Beacon received, node exists: 192.168.1.212:61312.
10:14:31.2050|BroadcastBus.OnBeaconReady|Beacon received, node exists: 192.168.1.206:53555.
10:14:35.8048|BroadcastBus.OnBeaconReady|Beacon received, node exists: 192.168.1.52:62698.
10:14:40.7620|BroadcastBus.OnBeaconReady|Beacon received, node exists: 192.168.1.212:61312.
10:14:45.6453|BroadcastBus.OnBeaconReady|Beacon received, node exists: 192.168.1.206:53555.
10:14:50.5555|BroadcastBus.OnBeaconReady|Beacon received, node exists: 192.168.1.52:62698.
10:14:55.6338|BroadcastBus.OnBeaconReady|Beacon received, node exists: 192.168.1.212:61312.
10:15:00.3952|BroadcastBus.OnBeaconReady|Beacon received, node exists: 192.168.1.206:53555.
10:15:05.2943|BroadcastBus.OnBeaconReady|Beacon received, node exists: 192.168.1.52:62698.
10:15:09.9157|BroadcastBus.OnBeaconReady|Beacon received, node exists: 192.168.1.206:53555.

10:15:09.9157|BroadcastBus.ClearDeadNodes|Remove: 192.168.1.212:61312.

10:15:14.8240|BroadcastBus.OnBeaconReady|Beacon received, node exists: 192.168.1.52:62698.
10:15:19.6131|BroadcastBus.OnBeaconReady|Beacon received, new beacon: 192.168.1.212:61312.
10:15:24.3536|BroadcastBus.OnBeaconReady|Beacon received, node exists: 192.168.1.206:53555.
10:15:29.6050|BroadcastBus.OnBeaconReady|Beacon received, node exists: 192.168.1.52:62698.
10:15:35.0090|BroadcastBus.OnBeaconReady|Beacon received, node exists: 192.168.1.212:61312.

10:15:35.0090|BroadcastBus.ClearDeadNodes|Remove: 192.168.1.206:53555.

10:15:39.7036|BroadcastBus.OnBeaconReady|Beacon received, new beacon: 192.168.1.206:53555.
10:15:44.3125|BroadcastBus.OnBeaconReady|Beacon received, node exists: 192.168.1.52:62698.
10:15:49.0556|BroadcastBus.OnBeaconReady|Beacon received, node exists: 192.168.1.212:61312.
10:15:53.8438|BroadcastBus.OnBeaconReady|Beacon received, node exists: 192.168.1.206:53555.
10:15:58.4508|BroadcastBus.OnBeaconReady|Beacon received, node exists: 192.168.1.52:62698.
10:16:03.3624|BroadcastBus.OnBeaconReady|Beacon received, node exists: 192.168.1.206:53555.

10:16:03.3624|BroadcastBus.ClearDeadNodes|Remove: 192.168.1.212:61312.

10:16:08.9724|BroadcastBus.OnBeaconReady|Beacon received, new beacon: 192.168.1.212:61312.
10:16:13.8117|BroadcastBus.OnBeaconReady|Beacon received, node exists: 192.168.1.52:62698.

10:16:13.8117|BroadcastBus.ClearDeadNodes|Remove: 192.168.1.206:53555.

10:16:18.7233|BroadcastBus.OnBeaconReady|Beacon received, new beacon: 192.168.1.206:53555.
10:16:23.5877|BroadcastBus.OnBeaconReady|Beacon received, node exists: 192.168.1.212:61312.
10:16:28.2455|BroadcastBus.OnBeaconReady|Beacon received, node exists: 192.168.1.52:62698.
10:16:33.2162|BroadcastBus.OnBeaconReady|Beacon received, node exists: 192.168.1.212:61312.
10:16:38.0722|BroadcastBus.OnBeaconReady|Beacon received, node exists: 192.168.1.206:53555.
10:16:42.6807|BroadcastBus.OnBeaconReady|Beacon received, node exists: 192.168.1.52:62698.
10:16:47.4484|BroadcastBus.OnBeaconReady|Beacon received, node exists: 192.168.1.212:61312.
10:16:52.2002|BroadcastBus.OnBeaconReady|Beacon received, node exists: 192.168.1.206:53555.
10:16:57.1126|BroadcastBus.OnBeaconReady|Beacon received, node exists: 192.168.1.52:62698.
10:17:01.7311|BroadcastBus.OnBeaconReady|Beacon received, node exists: 192.168.1.206:53555.

Beacon from 192.168.1.206:

10:12:20.9517|BroadcastBus.OnBeaconReady|Beacon received, node exists: 192.168.1.206:53555.
10:12:35.0909|BroadcastBus.OnBeaconReady|Beacon received, node exists: 192.168.1.206:53555.
10:12:49.5197|BroadcastBus.OnBeaconReady|Beacon received, node exists: 192.168.1.206:53555.
10:13:04.5776|BroadcastBus.OnBeaconReady|Beacon received, new beacon: 192.168.1.206:53555.

10:13:19.3213|BroadcastBus.OnBeaconReady|Beacon received, node exists: 192.168.1.206:53555.
10:13:33.4491|BroadcastBus.OnBeaconReady|Beacon received, node exists: 192.168.1.206:53555.
10:13:48.1999|BroadcastBus.OnBeaconReady|Beacon received, node exists: 192.168.1.206:53555.
10:14:02.9299|BroadcastBus.OnBeaconReady|Beacon received, node exists: 192.168.1.206:53555.
10:14:17.0766|BroadcastBus.OnBeaconReady|Beacon received, node exists: 192.168.1.206:53555.
10:14:31.2050|BroadcastBus.OnBeaconReady|Beacon received, node exists: 192.168.1.206:53555.
10:14:45.6453|BroadcastBus.OnBeaconReady|Beacon received, node exists: 192.168.1.206:53555.
10:15:00.3952|BroadcastBus.OnBeaconReady|Beacon received, node exists: 192.168.1.206:53555.
10:15:09.9157|BroadcastBus.OnBeaconReady|Beacon received, node exists: 192.168.1.206:53555.

This is what WireShark shows for incoming requests from notebook (206) to my pc (60). Seems that nothing is sent.

WireShark_206-60_screen

Steps to reproduce the behaviour

Run Beacon demo on as many computers on local network as possible.