Make protobuf client reconnect on error.

2014-02-25 15:14:28 -05:00 · 2014-02-25 15:14:28 -05:00 · 90335f790c
parent da2b3e5946
commit 90335f790c
1 changed files with 1 additions and 0 deletions
--- a/src/coordinator/protobuf_client.go
+++ b/src/coordinator/protobuf_client.go
@ -123,6 +123,7 @@ func (self *ProtobufClient) MakeRequest(request *protocol.Request, responseStrea
 	self.requestBufferLock.Lock()
 	delete(self.requestBuffer, *request.Id)
 	self.requestBufferLock.Unlock()
+	self.reconnect()
 	return err
 }