set timeout in timeout

Signed-off-by: zwwhdls <[email protected]>
juicedata · Sep 24, 2024 · 23f1662 · 23f1662
1 parent 4808231
commit 23f1662
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/pkg/controller/pod_driver.go b/pkg/controller/pod_driver.go
@@ -687,7 +687,10 @@ func (p *PodDriver) recoverTarget(ctx context.Context, podName, sourcePath strin
 		}
 		log.Info("recover volPath", "target", ti.target, "mountPath", sourcePath)
 		mountOption := []string{"bind"}
-		if err := p.Mount(sourcePath, ti.target, "none", mountOption); err != nil {
+		err = util.DoWithTimeout(ctx, defaultCheckoutTimeout, func() error {
+			return p.Mount(sourcePath, ti.target, "none", mountOption)
+		})
+		if err != nil {
 			ms := fmt.Sprintf("exec cmd: mount -o bind %s %s err:%v", sourcePath, ti.target, err)
 			log.Error(err, "bind mount error")
 			return fmt.Errorf(ms)