Fix: Buffer gossip messages before passing them to ProtoBuf (#180)
* Use buffered connection for gossip * fix wrong timeout * Encode length in big endian *Improve debug logging
Showing
- packages/gossip/manager.go 7 additions, 5 deletionspackages/gossip/manager.go
- packages/gossip/neighbor.go 28 additions, 22 deletionspackages/gossip/neighbor.go
- packages/gossip/neighbor_test.go 2 additions, 2 deletionspackages/gossip/neighbor_test.go
- packages/netutil/buffconn/buffconn.go 172 additions, 0 deletionspackages/netutil/buffconn/buffconn.go
- packages/netutil/buffconn/buffconn_test.go 136 additions, 0 deletionspackages/netutil/buffconn/buffconn_test.go
- plugins/autopeering/autopeering.go 1 addition, 1 deletionplugins/autopeering/autopeering.go
- plugins/gossip/gossip.go 7 additions, 4 deletionsplugins/gossip/gossip.go
- plugins/tangle/solidifier.go 8 additions, 4 deletionsplugins/tangle/solidifier.go
Loading
Please register or sign in to comment