Avoid writing to output feed if it has been closed

Checkin the correct file this time
couchbase · Feb 6, 2015 · 467f1dd · 467f1dd
1 parent 3151afa
commit 467f1dd
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/upr.go b/upr.go
@@ -306,6 +306,11 @@ func (feed *UprFeed) forwardUprEvents(nodeFeed *FeedInfo, killSwitch chan bool,
 				killSwitch <- true
 				return
 			}
+			if feed.outputClosed == true {
+				// someone closed the node feed
+				log.Printf("Node need closed, returning from forwardUprEvent")
+				return
+			}
 			feed.output <- event
 			if event.Status == gomemcached.NOT_MY_VBUCKET {
 				log.Printf(" Got a not my vbucket error !! ")