From dce5ac60c4a87e53f8d8a624933d038efdd6e690 Mon Sep 17 00:00:00 2001 From: Todd Gruben Date: Wed, 24 Dec 2014 21:42:53 +0000 Subject: [PATCH] increased buffer --- transport/tcp.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/transport/tcp.go b/transport/tcp.go index fa67dedef..61a1ccaa1 100644 --- a/transport/tcp.go +++ b/transport/tcp.go @@ -40,8 +40,8 @@ func init() { func newConnection(transport *TcpTransport, conn net.Conn, proc *GUID) *connection { p := new(connection) p.transport = transport - p.outbox = make(chan *db.Message, 100) - p.inbox = make(chan *db.Message, 100) + p.outbox = make(chan *db.Message, 2048) + p.inbox = make(chan *db.Message, 2048) p.conn = conn p.process = proc p.exit = make(chan int)