Fix #440. Update protobuf client to clear out heartbeat requests afte…

…r they've completed
influxdata · Apr 14, 2014 · 2aa5933 · 2aa5933
1 parent 75a81e0
commit 2aa5933
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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()