瀏覽代碼

buffer the connection response channel

Buffer the channel which the IO goroutine sends the response
back to the stream handler so that the IO goroutine will not
block waiting for a slow stream handler.
Chris Bannister 10 年之前
父節點
當前提交
cd520c7d57
共有 1 個文件被更改,包括 1 次插入1 次删除
  1. 1 1
      conn.go

+ 1 - 1
conn.go

@@ -180,7 +180,7 @@ func Connect(addr string, cfg ConnConfig, errorHandler ConnErrorHandler) (*Conn,
 	}
 
 	for i := 0; i < cfg.NumStreams; i++ {
-		c.calls[i].resp = make(chan error)
+		c.calls[i].resp = make(chan error, 1)
 		c.uniq <- i
 	}