-
- Downloads
Feat: Improve peer selection logic to avoid parallel connections (#101)
* Log failed connection attempts * Only trigger drop event, when a neighbor was removed * Remove unused dropNeighbors * Use only one loop to process channels in selection * Update out neighbors less often * feat: introduce SaltUpdated event * fix: use global parameters * Update salt log messages * fix: do not close public channels to prevent panics during shutdown * fix: assure correct order of events * feat: add selection event tests * Set update interval to 1s and full updat interval to 1m * Use subtests for the protocol tests * fix: send peering drop message only when event is triggered * Update packages/autopeering/selection/manager.go Co-Authored-By:jkrvivian <jkrvivian@gmail.com> Co-authored-by:
jkrvivian <jkrvivian@gmail.com>
Showing
- packages/autopeering/discover/common.go 46 additions, 28 deletionspackages/autopeering/discover/common.go
- packages/autopeering/discover/manager.go 13 additions, 27 deletionspackages/autopeering/discover/manager.go
- packages/autopeering/discover/manager_test.go 1 addition, 1 deletionpackages/autopeering/discover/manager_test.go
- packages/autopeering/discover/protocol.go 4 additions, 4 deletionspackages/autopeering/discover/protocol.go
- packages/autopeering/discover/protocol_test.go 7 additions, 4 deletionspackages/autopeering/discover/protocol_test.go
- packages/autopeering/peer/mapdb.go 3 additions, 3 deletionspackages/autopeering/peer/mapdb.go
- packages/autopeering/peer/mapdb_test.go 13 additions, 22 deletionspackages/autopeering/peer/mapdb_test.go
- packages/autopeering/peer/peerdb.go 3 additions, 3 deletionspackages/autopeering/peer/peerdb.go
- packages/autopeering/salt/salt.go 1 addition, 1 deletionpackages/autopeering/salt/salt.go
- packages/autopeering/selection/common.go 56 additions, 23 deletionspackages/autopeering/selection/common.go
- packages/autopeering/selection/events.go 16 additions, 3 deletionspackages/autopeering/selection/events.go
- packages/autopeering/selection/manager.go 249 additions, 288 deletionspackages/autopeering/selection/manager.go
- packages/autopeering/selection/manager_test.go 169 additions, 70 deletionspackages/autopeering/selection/manager_test.go
- packages/autopeering/selection/neighborhood.go 74 additions, 50 deletionspackages/autopeering/selection/neighborhood.go
- packages/autopeering/selection/neighborhood_test.go 35 additions, 35 deletionspackages/autopeering/selection/neighborhood_test.go
- packages/autopeering/selection/protocol.go 18 additions, 13 deletionspackages/autopeering/selection/protocol.go
- packages/autopeering/selection/protocol_test.go 85 additions, 80 deletionspackages/autopeering/selection/protocol_test.go
- packages/autopeering/selection/selection_test.go 8 additions, 8 deletionspackages/autopeering/selection/selection_test.go
- packages/autopeering/server/server.go 3 additions, 3 deletionspackages/autopeering/server/server.go
- plugins/autopeering/autopeering.go 2 additions, 5 deletionsplugins/autopeering/autopeering.go
Loading
Please register or sign in to comment