From a0380a0a91bbda8d90382ea2a2fb9b42806d158b Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E8=82=96=E8=B4=9D=E8=B4=9D?= <xbsura@gmail.com>
Date: Sat, 16 May 2020 14:19:52 +0800
Subject: [PATCH] fix: fix vmagent multi queue may become one because sync bug
 (#484)

Co-authored-by: xiaobeibei <xiaobeibei@bigo.sg>
---
 lib/persistentqueue/fastqueue.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/lib/persistentqueue/fastqueue.go b/lib/persistentqueue/fastqueue.go
index 898ef9d9d..5d7f464d0 100644
--- a/lib/persistentqueue/fastqueue.go
+++ b/lib/persistentqueue/fastqueue.go
@@ -120,7 +120,7 @@ func (fq *FastQueue) MustWriteBlock(block []byte) {
 	bb.B = append(bb.B[:0], block...)
 	fq.ch <- bb
 	fq.pendingInmemoryBytes += uint64(len(block))
-	if len(fq.ch) == 1 {
+	if len(fq.ch) >= 1 {
 		// Notify potentially blocked reader
 		fq.cond.Signal()
 	}