test: change csi.sock to fix random e2e test failure

Author: andyzhangx

deploy/uninstall-driver.sh

@@ -0,0 +1,25 @@
+#!/bin/bash
+
+# Copyright 2019 The Kubernetes Authors.
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#     http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+set -uo pipefail
+
+echo 'Uninstalling Blobfuse CSI driver...'
+kubectl delete -f deploy/crd-csi-driver-registry.yaml
+kubectl delete -f deploy/crd-csi-node-info.yaml
+kubectl delete -f deploy/rbac-csi-blobfuse-controller.yaml
+kubectl delete -f deploy/csi-blobfuse-controller.yaml
+kubectl delete -f deploy/csi-blobfuse-node.yaml
+echo 'Blobfuse CSI driver uninstalled'

test/e2e/dynamic_provisioning.go

@@ -24,6 +24,8 @@ import (
 	"github.com/csi-driver/blobfuse-csi-driver/test/e2e/driver"
 	"github.com/csi-driver/blobfuse-csi-driver/test/e2e/testsuites"
 	. "github.com/onsi/ginkgo"
+	"github.com/pborman/uuid"
+
 	v1 "k8s.io/api/core/v1"
 	clientset "k8s.io/client-go/kubernetes"
 	"k8s.io/kubernetes/test/e2e/framework"
@@ -40,7 +42,7 @@ var _ = Describe("Dynamic Provisioning", func() {
 
 	nodeid := os.Getenv("nodeid")
 	blobfuseDriver := blobfuse.NewDriver(nodeid)
-	endpoint := "unix:///tmp/csi.sock"
+	endpoint := fmt.Sprintf("unix:///tmp/csi-%s.sock", uuid.NewUUID().String())
 
 	go func() {
 		blobfuseDriver.Run(endpoint)

test/e2e/pre_provisioning.go

@@ -26,6 +26,7 @@ import (
 	"github.com/csi-driver/blobfuse-csi-driver/test/e2e/driver"
 	"github.com/csi-driver/blobfuse-csi-driver/test/e2e/testsuites"
 	. "github.com/onsi/ginkgo"
+	"github.com/pborman/uuid"
 
 	v1 "k8s.io/api/core/v1"
 	clientset "k8s.io/client-go/kubernetes"
@@ -53,7 +54,7 @@ var _ = Describe("[blobfuse-csi-e2e] [single-az] Pre-Provisioned", func() {
 	)
 	nodeid := os.Getenv("nodeid")
 	blobfuseDriver := blobfuse.NewDriver(nodeid)
-	endpoint := "unix:///tmp/csi.sock"
+	endpoint := fmt.Sprintf("unix:///tmp/csi-%s.sock", uuid.NewUUID().String())
 
 	go func() {
 		blobfuseDriver.Run(endpoint)