From 2aa593395865baab06383d648e091c9960a50fc2 Mon Sep 17 00:00:00 2001 From: Paul Dix Date: Mon, 14 Apr 2014 19:53:17 -0400 Subject: [PATCH] Fix #440. Update protobuf client to clear out heartbeat requests after they've completed --- src/coordinator/protobuf_client.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/coordinator/protobuf_client.go b/src/coordinator/protobuf_client.go index 21426abfcf1..c2642d646a1 100644 --- a/src/coordinator/protobuf_client.go +++ b/src/coordinator/protobuf_client.go @@ -172,7 +172,7 @@ func (self *ProtobufClient) sendResponse(response *protocol.Response) { req, ok := self.requestBuffer[*response.RequestId] self.requestBufferLock.RUnlock() if ok { - if *response.Type == protocol.Response_END_STREAM || *response.Type == protocol.Response_WRITE_OK { + if *response.Type == protocol.Response_END_STREAM || *response.Type == protocol.Response_WRITE_OK || *response.Type == protocol.Response_HEARTBEAT || *response.Type == protocol.Response_ACCESS_DENIED { self.requestBufferLock.Lock() delete(self.requestBuffer, *response.RequestId) self.requestBufferLock.Unlock()