event: another dirty fix for another data race

Related to #511.
fsouza · Apr 26, 2016 · ca798d0 · ca798d0
1 parent c21dd8b
commit ca798d0
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/event.go b/event.go
@@ -317,10 +317,12 @@ func (c *Client) eventHijack(startTime int64, eventChan chan *APIEvents, errChan
 			var event APIEvents
 			if err = decoder.Decode(&event); err != nil {
 				if err == io.EOF || err == io.ErrUnexpectedEOF {
-					if c.eventMonitor.isEnabled() && c.eventMonitor.C == eventChan {
+					c.eventMonitor.RLock()
+					if c.eventMonitor.enabled && c.eventMonitor.C == eventChan {
 						// Signal that we're exiting.
 						eventChan <- EOFEvent
 					}
+					c.eventMonitor.RUnlock()
 					break
 				}
 				errChan <- err