fix tests

pkg/rclone/controllerserver.go

@@ -25,10 +25,10 @@ type controllerServer struct {
 func (cs *controllerServer) ValidateVolumeCapabilities(ctx context.Context, req *csi.ValidateVolumeCapabilitiesRequest) (*csi.ValidateVolumeCapabilitiesResponse, error) {
 	volId := req.GetVolumeId()
 	if len(volId) == 0 {
-		return nil, status.Error(codes.InvalidArgument, "DeteleVolume must be provided volume id")
+		return nil, status.Error(codes.InvalidArgument, "ValidateVolumeCapabilities must be provided volume id")
 	}
 	if len(req.GetVolumeCapabilities()) == 0 {
-		return nil, status.Error(codes.InvalidArgument, "CreateVolume without capabilities")
+		return nil, status.Error(codes.InvalidArgument, "ValidateVolumeCapabilities without capabilities")
 	}
 
 	cs.mutex.Lock()

pkg/rclone/rclone.go

@@ -1,6 +1,7 @@
 package rclone
 
 import (
+	"bufio"
 	"bytes"
 	"encoding/json"
 	"errors"
@@ -383,16 +384,24 @@ func (r *Rclone) run_daemon() error {
 
 	env := os.Environ()
 	cmd := os_exec.Command(rclone_cmd, rclone_args...)
+	stderr, err := cmd.StderrPipe()
+	if err != nil {
+		panic("couldn't get stderr of rclone process")
+	}
+	scanner := bufio.NewScanner(stderr)
 	cmd.Env = env
 	if err := cmd.Start(); err != nil {
 		return err
 	}
 	r.process = cmd.Process.Pid
 	go func() {
+		output := ""
+		for scanner.Scan() {
+			output = scanner.Text()
+		}
 		err := cmd.Wait()
 		if err != nil {
-			klog.Errorf("background process failed with: %s", err)
-			panic(fmt.Sprintf("background exited"))
+			klog.Errorf("background process failed with: %s,%s", output, err)
 		}
 	}()
 	return nil

test/sanity_test.go

@@ -80,5 +80,8 @@ provider=AWS`},
 	}
 	sanity.Test(t, cfg)
 
+	// sanity just completely kills the driver, leaking the rclone daemon, so we cleanup manually
+	driver.RcloneOps.Cleanup()
+
 	kubeClient.CoreV1().Secrets("csi-rclone").Delete(context.Background(), "test-pvc", metav1.DeleteOptions{})
 }