fix: nil check for flushing

Signed-off-by: hlts2 <[email protected]>
vdaas · Sep 9, 2024 · 833ccf7 · 833ccf7
1 parent 4a90356
commit 833ccf7
Showing 1 changed file with 12 additions and 3 deletions.
diff --git a/pkg/agent/core/ngt/service/ngt.go b/pkg/agent/core/ngt/service/ngt.go
@@ -1941,15 +1941,24 @@ func (n *ngt) gc() {
 }
 
 func (n *ngt) Len() uint64 {
-	return n.kvs.Len()
+	if n != nil && n.kvs != nil {
+		return n.kvs.Len()
+	}
+	return 0
 }
 
 func (n *ngt) InsertVQueueBufferLen() uint64 {
-	return uint64(n.vq.IVQLen())
+	if n != nil && n.vq != nil {
+		return uint64(n.vq.IVQLen())
+	}
+	return 0
 }
 
 func (n *ngt) DeleteVQueueBufferLen() uint64 {
-	return uint64(n.vq.DVQLen())
+	if n != nil && n.vq != nil {
+		return uint64(n.vq.DVQLen())
+	}
+	return 0
 }
 
 func (n *ngt) GetDimensionSize() int {