improve error handling

Signed-off-by: Xuhui zhang <[email protected]>

pkg/controller/pod_driver.go

@@ -986,6 +986,9 @@ func (p *PodDriver) doAbortFuse(mountpod *corev1.Pod, devMinor uint32) error {
 	if err == nil {
 		log.Info("mount point is normal, don't need to abort fuse connection")
 		return nil
+	} else if err.Error() != "function timeout" {
+		log.Error(err, "stat mount point error")
+		return err
 	}
 	job := builder.NewFuseAbortJob(mountpod, devMinor, mntPath)
 	if _, err := p.Client.CreateJob(context.Background(), job); err != nil {

pkg/juicefs/mount/builder/job.go

@@ -194,22 +194,21 @@ func NewFuseAbortJob(mountpod *corev1.Pod, devMinor uint32, mntPath string) *bat
 								"sh",
 								"-c",
 								fmt.Sprintf(`
-                                    attempt=1
-									while [ $attempt -le 5 ]; do
-										if timeout 1 stat "%s"; then
-											echo "fuse mount success, exit 0"
-											exit 0
-										fi
-											sleep 1
-											attempt=$((attempt+1))
-									done
+attempt=1
+while [ $attempt -le 5 ]; do
+    if timeout 1 stat "%s"; then
+        echo "fuse mount success, exit 0"
+        exit 0
+    fi
+    sleep 1
+    attempt=$((attempt+1))
+done
 
-									echo "fuse mount failed, aborting..."
+echo "fuse mount failed, aborting..."
 
-									if [ $(cat /sys/fs/fuse/connections/%d/waiting) -gt 0 ]; then 
-										echo 1 > /sys/fs/fuse/connections/%d/abort 	
-									fi
-                                `, mntPath, devMinor, devMinor),
+if [ $(cat /sys/fs/fuse/connections/%d/waiting) -gt 0 ]; then
+    echo 1 > /sys/fs/fuse/connections/%d/abort
+fi`, mntPath, devMinor, devMinor),
 							},
 							SecurityContext: &corev1.SecurityContext{
 								Privileged: &privileged,