minor fix

qingyang-hu · qingyang-hu · commit 12fb07c3c2d3 · 2024-08-12T16:57:17.000-04:00
diff --git a/mongo/integration/mtest/mongotest.go b/mongo/integration/mtest/mongotest.go
@@ -616,9 +616,11 @@ func (t *T) ClearFailPoints() {
 		if err != nil {
 			t.Fatalf("error clearing fail point %s: %v", fp.name, err)
 		}
-		if fp.client != t.Client {
-			_ = fp.client.Disconnect(context.Background())
-			t.fpClients[fp.client] = false
+		t.fpClients[fp.client] = false
+	}
+	for client, active := range t.fpClients {
+		if !active && client != t.Client {
+			_ = client.Disconnect(context.Background())
 		}
 	}
 	t.failPoints = t.failPoints[:0]

Original file line number	Diff line number	Diff line change
`@@ -616,9 +616,11 @@ func (t *T) ClearFailPoints() {`
`616`	`616`	`if err != nil {`
`617`	`617`	`t.Fatalf("error clearing fail point %s: %v", fp.name, err)`
`618`	`618`	`}`
`619`		`- if fp.client != t.Client {`
`620`		`- _ = fp.client.Disconnect(context.Background())`
`621`		`- t.fpClients[fp.client] = false`
	`619`	`+ t.fpClients[fp.client] = false`
	`620`	`+ }`
	`621`	`+ for client, active := range t.fpClients {`
	`622`	`+ if !active && client != t.Client {`
	`623`	`+ _ = client.Disconnect(context.Background())`
`622`	`624`	`}`
`623`	`625`	`}`
`624`	`626`	`t.failPoints = t.failPoints[:0]`