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

Avoid encoding from competing goroutines

Browse Source
This commit is contained in:
Jordan Liggitt 2019-09-09 12:03:38 -04:00
parent 38752f7f99
commit 510140ee27
1 changed files with 15 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
test/integration/apiserver/admissionwebhook/load_balance_test.go
View File

@ -154,17 +154,19 @@ func TestWebhookLoadBalance(t *testing.T) {
t.Fatal(err) t.Fatal(err)
} }
pod := &corev1.Pod{ pod := func() *corev1.Pod {
ObjectMeta: metav1.ObjectMeta{ return &corev1.Pod{
Namespace: ns, ObjectMeta: metav1.ObjectMeta{
GenerateName: "loadbalance-", Namespace: ns,
}, GenerateName: "loadbalance-",
Spec: corev1.PodSpec{ },
Containers: []v1.Container{{ Spec: corev1.PodSpec{
Name: "fake-name", Containers: []v1.Container{{
Image: "fakeimage", Name: "fake-name",
}}, Image: "fakeimage",
}, }},
},
}
} }
// Submit 10 parallel requests // Submit 10 parallel requests
@ -173,7 +175,7 @@ func TestWebhookLoadBalance(t *testing.T) {
wg.Add(1) wg.Add(1)
go func() { go func() {
defer wg.Done() defer wg.Done()
_, err := client.CoreV1().Pods(ns).Create(pod) _, err := client.CoreV1().Pods(ns).Create(pod())
if err != nil { if err != nil {
t.Error(err) t.Error(err)
} }
@ -192,7 +194,7 @@ func TestWebhookLoadBalance(t *testing.T) {
wg.Add(1) wg.Add(1)
go func() { go func() {
defer wg.Done() defer wg.Done()
_, err := client.CoreV1().Pods(ns).Create(pod) _, err := client.CoreV1().Pods(ns).Create(pod())
if err != nil { if err != nil {
t.Error(err) t.Error(err)
} }