Skip to content
Snippets Groups Projects
Unverified Commit 148a7d23 authored by Luca Moser's avatar Luca Moser Committed by GitHub
Browse files

increases send queue and ignore sending if connection is closed (#232)

parent a707057a
No related branches found
No related tags found
No related merge requests found
...@@ -174,7 +174,7 @@ func (m *Manager) send(b []byte, to ...peer.ID) { ...@@ -174,7 +174,7 @@ func (m *Manager) send(b []byte, to ...peer.ID) {
for _, nbr := range neighbors { for _, nbr := range neighbors {
if _, err := nbr.Write(b); err != nil { if _, err := nbr.Write(b); err != nil {
m.log.Warnw("send error", "err", err) m.log.Warnw("send error", "err", err, "neighbor", nbr.Peer.Address())
} }
} }
} }
......
...@@ -19,7 +19,7 @@ var ( ...@@ -19,7 +19,7 @@ var (
) )
const ( const (
neighborQueueSize = 1000 neighborQueueSize = 5000
maxNumReadErrors = 10 maxNumReadErrors = 10
) )
...@@ -99,8 +99,9 @@ func (n *Neighbor) writeLoop() { ...@@ -99,8 +99,9 @@ func (n *Neighbor) writeLoop() {
continue continue
} }
if _, err := n.BufferedConnection.Write(msg); err != nil { if _, err := n.BufferedConnection.Write(msg); err != nil {
// ignore write errors
n.log.Warn("Write error", "err", err) n.log.Warn("Write error", "err", err)
_ = n.BufferedConnection.Close()
return
} }
case <-n.closing: case <-n.closing:
return return
...@@ -146,6 +147,8 @@ func (n *Neighbor) Write(b []byte) (int, error) { ...@@ -146,6 +147,8 @@ func (n *Neighbor) Write(b []byte) (int, error) {
select { select {
case n.queue <- b: case n.queue <- b:
return l, nil return l, nil
case <-n.closing:
return 0, nil
default: default:
return 0, ErrNeighborQueueFull return 0, ErrNeighborQueueFull
} }
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment