From c5b42f8c53b943cb084e17ba23bc0ea68e14a55c Mon Sep 17 00:00:00 2001 From: Jeromy Date: Tue, 8 Mar 2016 15:47:25 -0800 Subject: [PATCH] bump yamux backlog setting way up --- swarm.go | 2 +- swarm_listen.go | 5 +++-- 2 files changed, 4 insertions(+), 3 deletions(-) diff --git a/swarm.go b/swarm.go index 0fd7a25..fd66f73 100644 --- a/swarm.go +++ b/swarm.go @@ -38,7 +38,7 @@ func init() { msstpt := psmss.NewBlankTransport() ymxtpt := &yamux.Transport{ - AcceptBacklog: 2048, + AcceptBacklog: 8192, ConnectionWriteTimeout: time.Second * 10, KeepAliveInterval: time.Second * 30, EnableKeepAlive: true, diff --git a/swarm_listen.go b/swarm_listen.go index a4d5e94..b83df45 100644 --- a/swarm_listen.go +++ b/swarm_listen.go @@ -12,8 +12,9 @@ import ( ps "gx/ipfs/QmZK81vcgMhpb2t7GNbozk7qzt6Rj4zFqitpvsWT9mduW8/go-peerstream" context "gx/ipfs/QmZy2y8t9zQH2a1b8q2ZSLKp17ATuJoCNxxyMFG5qFExpt/go-net/context" ma "gx/ipfs/QmcobAGsCjYt5DXoq9et9L8yR8er7o7Cu3DTvpaq12jYSz/go-multiaddr" -) // Open listeners and reuse-dialers for the given addresses +) +// Open listeners and reuse-dialers for the given addresses func (s *Swarm) setupInterfaces(addrs []ma.Multiaddr) error { errs := make([]error, len(addrs)) var succeeded int @@ -152,7 +153,7 @@ func (s *Swarm) connHandler(c *ps.Conn) *Conn { if err != nil { log.Debug(err) log.Event(ctx, "newConnHandlerDisconnect", lgbl.NetConn(c.NetConn()), lgbl.Error(err)) - c.Close() // boom. close it. + c.Close() // boom. close it. return nil } -- GitLab