nsqd: fix testcase concurrency issue in pull request #575

detail: https://travis-ci.org/bitly/nsq/jobs/60022415
nsqio · Apr 25, 2015 · c5b9fa0 · c5b9fa0
1 parent d4d006e
commit c5b9fa0
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/nsqd/nsqd_test.go b/nsqd/nsqd_test.go
@@ -242,9 +242,13 @@ func TestPauseMetadata(t *testing.T) {
 	_, _, nsqd := mustStartNSQD(opts)
 	defer nsqd.Exit()
 
+	// avoid concurrency issue of async PersistMetadata() calls
+	nsqd.setFlag(flagLoading, true)
 	topicName := "pause_metadata" + strconv.Itoa(int(time.Now().Unix()))
 	topic := nsqd.GetTopic(topicName)
 	channel := topic.GetChannel("ch")
+	nsqd.setFlag(flagLoading, false)
+	nsqd.PersistMetadata()
 
 	b, _ := metadataForChannel(nsqd, 0, 0).Get("paused").Bool()
 	equal(t, b, false)