From d6040199091c33388b70864d8812005ddace237f Mon Sep 17 00:00:00 2001 From: Cody Soyland Date: Fri, 17 Jan 2014 19:10:23 -0600 Subject: [PATCH] Use buffered channels for new connections. --- transport/tcp.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/transport/tcp.go b/transport/tcp.go index 1f5e91956..aa1632ad5 100644 --- a/transport/tcp.go +++ b/transport/tcp.go @@ -119,7 +119,7 @@ func (self *TcpTransport) Run() { case env := <-self.outbox: con, ok := self.connections[*(env.host)] if !ok { - con = &connection{self, make(chan *db.Message), make(chan *db.Message), nil, env.host} + con = &connection{self, make(chan *db.Message, 100), make(chan *db.Message, 100), nil, env.host} go con.manage() self.connections[*env.host] = con } @@ -148,7 +148,7 @@ func (self *TcpTransport) listen() { } func (self *TcpTransport) manage(conn *net.Conn) { - con := &connection{self, make(chan *db.Message), make(chan *db.Message), conn, nil} + con := &connection{self, make(chan *db.Message, 100), make(chan *db.Message, 100), conn, nil} con.manage() }