github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-23 19:56:01 +00:00
Code Issues Projects Releases Wiki Activity

Use unique socket name per cm test

Browse Source
This commit is contained in:
Jordan Liggitt 2020-09-04 14:55:23 -04:00
parent a23cf7077e
commit 803da10d8b
1 changed files with 8 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
pkg/kubelet/cm/devicemanager/endpoint_test.go
View File

@ -17,6 +17,7 @@ limitations under the License.
package devicemanager package devicemanager
import ( import (
"fmt"
"path" "path"
"testing" "testing"
"time" "time"
@ -26,12 +27,12 @@ import (
pluginapi "k8s.io/kubelet/pkg/apis/deviceplugin/v1beta1" pluginapi "k8s.io/kubelet/pkg/apis/deviceplugin/v1beta1"
) )
var ( func esocketName() string {
esocketName = "mock.sock" return fmt.Sprintf("mock%d.sock", time.Now().UnixNano())
) }
func TestNewEndpoint(t *testing.T) { func TestNewEndpoint(t *testing.T) {
socket := path.Join("/tmp", esocketName) socket := path.Join("/tmp", esocketName())
devs := []*pluginapi.Device{ devs := []*pluginapi.Device{
{ID: "ADeviceId", Health: pluginapi.Healthy}, {ID: "ADeviceId", Health: pluginapi.Healthy},
@ -42,7 +43,7 @@ func TestNewEndpoint(t *testing.T) {
} }
func TestRun(t *testing.T) { func TestRun(t *testing.T) {
socket := path.Join("/tmp", esocketName) socket := path.Join("/tmp", esocketName())
devs := []*pluginapi.Device{ devs := []*pluginapi.Device{
{ID: "ADeviceId", Health: pluginapi.Healthy}, {ID: "ADeviceId", Health: pluginapi.Healthy},
@ -107,7 +108,7 @@ func TestRun(t *testing.T) {
} }
func TestAllocate(t *testing.T) { func TestAllocate(t *testing.T) {
socket := path.Join("/tmp", esocketName) socket := path.Join("/tmp", esocketName())
devs := []*pluginapi.Device{ devs := []*pluginapi.Device{
{ID: "ADeviceId", Health: pluginapi.Healthy}, {ID: "ADeviceId", Health: pluginapi.Healthy},
} }
@ -160,7 +161,7 @@ func TestAllocate(t *testing.T) {
} }
func TestGetPreferredAllocation(t *testing.T) { func TestGetPreferredAllocation(t *testing.T) {
socket := path.Join("/tmp", esocketName) socket := path.Join("/tmp", esocketName())
callbackCount := 0 callbackCount := 0
callbackChan := make(chan int) callbackChan := make(chan int)
p, e := esetup(t, []*pluginapi.Device{}, socket, "mock", func(n string, d []pluginapi.Device) { p, e := esetup(t, []*pluginapi.Device{}, socket, "mock", func(n string, d []pluginapi.Device) {