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

Merge pull request #94539 from liggitt/deflake-cmdevice

Browse Source 
Use unique socket name per cm test
This commit is contained in:
Kubernetes Prow Robot 2020-09-04 15:41:41 -07:00 committed by GitHub
commit c4cf7d331f
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
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
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) {