Implement Cloning for csi-hostpath driver

This PR adds support for cloning of hostpath volumes.

examples/csi-clone.yaml

@@ -0,0 +1,14 @@
+apiVersion: v1
+kind: PersistentVolumeClaim
+metadata:
+  name: hp-pvc-clone
+spec:
+  storageClassName: csi-hostpath-sc
+  dataSource:
+    name: src-hp-pvc
+    kind: PersistentVolumeClaim
+  accessModes:
+    - ReadWriteOnce
+  resources:
+    requests:
+      storage: 1Gi

pkg/hostpath/controllerserver.go

@@ -65,6 +65,7 @@ func NewControllerServer(ephemeral bool) *controllerServer {
 				csi.ControllerServiceCapability_RPC_CREATE_DELETE_VOLUME,
 				csi.ControllerServiceCapability_RPC_CREATE_DELETE_SNAPSHOT,
 				csi.ControllerServiceCapability_RPC_LIST_SNAPSHOTS,
+				csi.ControllerServiceCapability_RPC_CLONE_VOLUME,
 			}),
 	}
 }
@@ -178,19 +179,38 @@ func (cs *controllerServer) CreateVolume(ctx context.Context, req *csi.CreateVol
 			snapshotId := contentSource.GetSnapshot().GetSnapshotId()
 			snapshot, ok := hostPathVolumeSnapshots[snapshotId]
 			if !ok {
+				deleteHostpathVolume(volumeID)
 				return nil, status.Errorf(codes.NotFound, "cannot find snapshot %v", snapshotId)
 			}
 			if snapshot.ReadyToUse != true {
+				deleteHostpathVolume(volumeID)
 				return nil, status.Errorf(codes.Internal, "Snapshot %v is not yet ready to use.", snapshotId)
 			}
 			snapshotPath := snapshot.Path
 			args := []string{"zxvf", snapshotPath, "-C", path}
 			executor := utilexec.New()
 			out, err := executor.Command("tar", args...).CombinedOutput()
 			if err != nil {
+				deleteHostpathVolume(volumeID)
 				return nil, status.Error(codes.Internal, fmt.Sprintf("failed pre-populate data for volume: %v: %s", err, out))
 			}
 		}
+		if srcVolume := contentSource.GetVolume(); srcVolume != nil {
+			srcVolumeID := srcVolume.GetVolumeId()
+			hostPathVolume, ok := hostPathVolumes[srcVolumeID]
+			if !ok {
+				deleteHostpathVolume(volumeID)
+				return nil, status.Error(codes.Internal, "source volumeID does not exist, are source/destination in the same storage class?")
+			}
+			srcPath := hostPathVolume.VolPath
+			args := []string{"-a", srcPath + "/*", path + "/"}
+			executor := utilexec.New()
+			out, err := executor.Command("cp", args...).CombinedOutput()
+			if err != nil {
+				deleteHostpathVolume(volumeID)
+				return nil, status.Error(codes.Internal, fmt.Sprintf("failed pre-populate data (clone) for volume: %v: %s", err, out))
+			}
+		}
 	}
 
 	createVolumeResponse := &csi.CreateVolumeResponse{}

pkg/hostpath/hostpath.go

@@ -169,6 +169,7 @@ func createHostpathVolume(volID, name string, cap int64, volAccessType accessTyp
 
 // deleteVolume deletes the directory for the hostpath volume.
 func deleteHostpathVolume(volID string) error {
+	glog.V(4).Infof("deleting hostpath volume: %s", volID)
 	path := getVolumePath(volID)
 	if err := os.RemoveAll(path); err != nil {
 		return err