scriptoriumadmin/featurebase
1
0
Fork 0
mirror of https://github.com/featurebasedb/featurebase.git synced 2026-08-28 10:54:59 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Use buffered channels for new connections.

Browse source
This commit is contained in:
Cody Soyland 2014-01-17 19:10:23 -06:00
parent a9c1927b8d
commit d604019909
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
transport/tcp.go
View file

@ -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()
}