fix: add flush check logic

Signed-off-by: hlts2 <hiroto.funakoshi.hiroto@gmail.com>
vdaas · Sep 9, 2024 · 50861c7 · 50861c7
1 parent 833ccf7
commit 50861c7
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/pkg/agent/core/ngt/service/ngt.go b/pkg/agent/core/ngt/service/ngt.go
@@ -1941,21 +1941,21 @@ func (n *ngt) gc() {
 }
 
 func (n *ngt) Len() uint64 {
-	if n != nil && n.kvs != nil {
+	if n != nil && n.kvs != nil && !n.IsFlushing() {
 		return n.kvs.Len()
 	}
 	return 0
 }
 
 func (n *ngt) InsertVQueueBufferLen() uint64 {
-	if n != nil && n.vq != nil {
+	if n != nil && n.kvs != nil && !n.IsFlushing() {
 		return uint64(n.vq.IVQLen())
 	}
 	return 0
 }
 
 func (n *ngt) DeleteVQueueBufferLen() uint64 {
-	if n != nil && n.vq != nil {
+	if n != nil && n.kvs != nil && !n.IsFlushing() {
 		return uint64(n.vq.DVQLen())
 	}
 	return 0