github-mirrors/VictoriaMetrics
1
0
Fork 0
mirror of https://github.com/VictoriaMetrics/VictoriaMetrics.git synced 2024-11-21 14:44:00 +00:00
Code Issues Projects Releases Packages Wiki Activity

fix: fix vmagent multi queue may become one because sync bug (#484)

Browse source 
Co-authored-by: xiaobeibei <xiaobeibei@bigo.sg>
This commit is contained in:
肖贝贝 2020-05-16 14:19:52 +08:00 committed by GitHub
parent 3a68c47de0
commit a0380a0a91
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
lib/persistentqueue/fastqueue.go
View file

@ -120,7 +120,7 @@ func (fq *FastQueue) MustWriteBlock(block []byte) {
bb.B = append(bb.B[:0], block...) bb.B = append(bb.B[:0], block...)
fq.ch <- bb fq.ch <- bb
fq.pendingInmemoryBytes += uint64(len(block)) fq.pendingInmemoryBytes += uint64(len(block))
if len(fq.ch) == 1 { if len(fq.ch) >= 1 {
// Notify potentially blocked reader // Notify potentially blocked reader
fq.cond.Signal() fq.cond.Signal()
} }