feat(shutdown): add cur loop break

2020-12-09 19:10:51 +08:00
parent daaf0e420e
commit 2b1aeaaa77
1 changed files with 1 additions and 1 deletions
--- a/collect.go
+++ b/collect.go
@@ -43,7 +43,7 @@ func collectCopyCountLiveAnchors(cxt *WorkerContext) {
 				continue
 			}

-			for cur.Next(context.TODO()) {
+			for cur.Next(context.TODO()) && !ps.IsClose() {
 				// la := &database.LiveAnchorsCountPoint{}
 				la := &database.LiveAnchorsCountPointObjectID{}
 				err = cur.Decode(la)