fix(zfs): timer stop when checkVolCreation exit (#600)

Signed-off-by: rfyiamcool <rfyiamcool@163.com>
openebs · Nov 27, 2024 · 51972c4 · 51972c4
1 parent 98610ac
commit 51972c4
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/pkg/zfs/volume.go b/pkg/zfs/volume.go
@@ -116,12 +116,14 @@ func GetNodeID(nodename string) (string, error) {
 }
 
 func checkVolCreation(ctx context.Context, volname string) (bool, error) {
-	timeout := time.After(10 * time.Second)
+	timeout := time.NewTimer(10 * time.Second)
+	defer timeout.Stop()
+
 	for {
 		select {
 		case <-ctx.Done():
 			return true, fmt.Errorf("zfs: context deadline reached")
-		case <-timeout:
+		case <-timeout.C:
 			return true, fmt.Errorf("zfs: vol creation timeout reached")
 		default:
 			vol, err := GetZFSVolume(volname)