Influxdata
/
influxdb
mirror of https://github.com/influxdata/influxdb.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Merge pull request #441 from influxdb/fix-440-heartbeat-timeouts 

Fix #440. Update protobuf client to clear out heartbeat requests after t...
pull/429/head
Paul Dix 2014-04-14 19:59:51 -04:00
parent 75a81e0743 2aa5933958
commit 0d29548010
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/coordinator/protobuf_client.go
View File

@ -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()