From 86995e67b6db4133a9e69fb21e6779c442814d78 Mon Sep 17 00:00:00 2001 From: Paul Dix Date: Thu, 20 Mar 2014 10:15:30 -0400 Subject: [PATCH] Make write on cluster server have a buffered channel so we can be sure to read the response. --- src/cluster/cluster_server.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/cluster/cluster_server.go b/src/cluster/cluster_server.go index 07a3b4b04c..a204974de0 100644 --- a/src/cluster/cluster_server.go +++ b/src/cluster/cluster_server.go @@ -103,7 +103,7 @@ func (self *ClusterServer) MakeRequest(request *protocol.Request, responseStream } func (self *ClusterServer) Write(request *protocol.Request) error { - responseChan := make(chan *protocol.Response) + responseChan := make(chan *protocol.Response, 1) err := self.connection.MakeRequest(request, responseChan) if err != nil { return err