From 803da10d8b73ec078821445f709e6e96802c17fd Mon Sep 17 00:00:00 2001 From: Jordan Liggitt Date: Fri, 4 Sep 2020 14:55:23 -0400 Subject: [PATCH] Use unique socket name per cm test --- pkg/kubelet/cm/devicemanager/endpoint_test.go | 15 ++++++++------- 1 file changed, 8 insertions(+), 7 deletions(-) diff --git a/pkg/kubelet/cm/devicemanager/endpoint_test.go b/pkg/kubelet/cm/devicemanager/endpoint_test.go index 6496bbb13f0..f20550985a1 100644 --- a/pkg/kubelet/cm/devicemanager/endpoint_test.go +++ b/pkg/kubelet/cm/devicemanager/endpoint_test.go @@ -17,6 +17,7 @@ limitations under the License. package devicemanager import ( + "fmt" "path" "testing" "time" @@ -26,12 +27,12 @@ import ( pluginapi "k8s.io/kubelet/pkg/apis/deviceplugin/v1beta1" ) -var ( - esocketName = "mock.sock" -) +func esocketName() string { + return fmt.Sprintf("mock%d.sock", time.Now().UnixNano()) +} func TestNewEndpoint(t *testing.T) { - socket := path.Join("/tmp", esocketName) + socket := path.Join("/tmp", esocketName()) devs := []*pluginapi.Device{ {ID: "ADeviceId", Health: pluginapi.Healthy}, @@ -42,7 +43,7 @@ func TestNewEndpoint(t *testing.T) { } func TestRun(t *testing.T) { - socket := path.Join("/tmp", esocketName) + socket := path.Join("/tmp", esocketName()) devs := []*pluginapi.Device{ {ID: "ADeviceId", Health: pluginapi.Healthy}, @@ -107,7 +108,7 @@ func TestRun(t *testing.T) { } func TestAllocate(t *testing.T) { - socket := path.Join("/tmp", esocketName) + socket := path.Join("/tmp", esocketName()) devs := []*pluginapi.Device{ {ID: "ADeviceId", Health: pluginapi.Healthy}, } @@ -160,7 +161,7 @@ func TestAllocate(t *testing.T) { } func TestGetPreferredAllocation(t *testing.T) { - socket := path.Join("/tmp", esocketName) + socket := path.Join("/tmp", esocketName()) callbackCount := 0 callbackChan := make(chan int) p, e := esetup(t, []*pluginapi.Device{}, socket, "mock", func(n string, d []pluginapi.Device) {