fix: nil check bug

Signed-off-by: hlts2 <[email protected]>
vdaas · Sep 9, 2024 · f8b76c6 · f8b76c6
1 parent 50861c7
commit f8b76c6
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/pkg/agent/core/ngt/service/ngt.go b/pkg/agent/core/ngt/service/ngt.go
@@ -1948,14 +1948,14 @@ func (n *ngt) Len() uint64 {
 }
 
 func (n *ngt) InsertVQueueBufferLen() uint64 {
-	if n != nil && n.kvs != nil && !n.IsFlushing() {
+	if n != nil && n.vq != nil && !n.IsFlushing() {
 		return uint64(n.vq.IVQLen())
 	}
 	return 0
 }
 
 func (n *ngt) DeleteVQueueBufferLen() uint64 {
-	if n != nil && n.kvs != nil && !n.IsFlushing() {
+	if n != nil && n.vq != nil && !n.IsFlushing() {
 		return uint64(n.vq.DVQLen())
 	}
 	return 0