Merge pull request #259 from mreiferson/persist_race_259

nsqd: race when persisting metadata
nsqio · Aug 21, 2013 · bff79fc · bff79fc
2 parents 7e4bdb0 + de500a0
commit bff79fc
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/nsqd/nsqd.go b/nsqd/nsqd.go
@@ -407,11 +407,11 @@ func (n *NSQd) Notify(v interface{}) {
 	select {
 	case <-n.exitChan:
 	case n.notifyChan <- v:
-		n.RLock()
+		n.Lock()
 		err := n.PersistMetadata()
 		if err != nil {
 			log.Printf("ERROR: failed to persist metadata - %s", err.Error())
 		}
-		n.RUnlock()
+		n.Unlock()
 	}
 }