From 90335f790cfd847d0ca59953379a7e323e27ead0 Mon Sep 17 00:00:00 2001 From: Paul Dix Date: Tue, 25 Feb 2014 15:14:28 -0500 Subject: [PATCH] Make protobuf client reconnect on error. --- src/coordinator/protobuf_client.go | 1 + 1 file changed, 1 insertion(+) diff --git a/src/coordinator/protobuf_client.go b/src/coordinator/protobuf_client.go index 82c8d0e3ca..750088d7fc 100644 --- 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 }