Bugfix NGT flush logic

pkg/agent/core/ngt/service/ngt.go

@@ -908,7 +908,7 @@
 				}
 				return ctx.Err()
 			case <-tick.C:
-				if n.vq.IVQLen() >= n.alen {
+				if n.vq != nil && !n.IsFlushing() && n.vq.IVQLen() >= n.alen {
 					err = n.CreateIndex(ctx, n.poolSize)
 				}
 			case <-limit.C:
@@ -1249,7 +1249,7 @@
 	runtime.GC()
 	atomic.AddUint64(&n.nogce, 1)
 
-	if n.inMem {
+	if !n.inMem {
 		// delete file
 		err = file.DeleteDir(ctx, n.path)
 		if err != nil {
@@ -1941,15 +1941,24 @@
 }
 
 func (n *ngt) Len() uint64 {
-	return n.kvs.Len()
+	if n != nil && n.kvs != nil && !n.IsFlushing() {
+		return n.kvs.Len()
+	}
+	return 0
 }
 
 func (n *ngt) InsertVQueueBufferLen() uint64 {
-	return uint64(n.vq.IVQLen())
+	if n != nil && n.vq != nil && !n.IsFlushing() {
+		return uint64(n.vq.IVQLen())
+	}
+	return 0
 }
 
 func (n *ngt) DeleteVQueueBufferLen() uint64 {
-	return uint64(n.vq.DVQLen())
+	if n != nil && n.vq != nil && !n.IsFlushing() {
+		return uint64(n.vq.DVQLen())
+	}
+	return 0
 }
 
 func (n *ngt) GetDimensionSize() int {