fix(zfs): timer stop when checkVolCreation exit

Signed-off-by: rfyiamcool <[email protected]>
openebs · Nov 7, 2024 · 75bce7e · 75bce7e
1 parent b2f57b9
commit 75bce7e
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)