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

Merge pull request #94544 from liggitt/deflake-serving-options

Browse Source 
Deflake serving options, avoid hard-coding ports
This commit is contained in:
Kubernetes Prow Robot 2020-09-04 14:11:41 -07:00 committed by GitHub
commit 1a04aac31d
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 13 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
staging/src/k8s.io/apiserver/pkg/server/options/serving_unix_test.go
View File

@ -19,31 +19,37 @@ limitations under the License.
package options package options
import ( import (
"fmt"
"net" "net"
"testing" "testing"
) )
func TestCreateListenerSharePort(t *testing.T) { func TestCreateListenerSharePort(t *testing.T) {
addr := "127.0.0.1:12345"
c := net.ListenConfig{Control: permitPortReuse} c := net.ListenConfig{Control: permitPortReuse}
if _, _, err := CreateListener("tcp", addr, c); err != nil { l, port, err := CreateListener("tcp", "127.0.0.1:0", c)
if err != nil {
t.Fatalf("failed to create listener: %v", err) t.Fatalf("failed to create listener: %v", err)
} }
defer l.Close()
if _, _, err := CreateListener("tcp", addr, c); err != nil { l2, _, err := CreateListener("tcp", fmt.Sprintf("127.0.0.1:%d", port), c)
if err != nil {
t.Fatalf("failed to create 2nd listener: %v", err) t.Fatalf("failed to create 2nd listener: %v", err)
} }
defer l2.Close()
} }
func TestCreateListenerPreventUpgrades(t *testing.T) { func TestCreateListenerPreventUpgrades(t *testing.T) {
addr := "127.0.0.1:12346" l, port, err := CreateListener("tcp", "127.0.0.1:0", net.ListenConfig{})
if err != nil {
if _, _, err := CreateListener("tcp", addr, net.ListenConfig{}); err != nil {
t.Fatalf("failed to create listener: %v", err) t.Fatalf("failed to create listener: %v", err)
} }
defer l.Close()
if _, _, err := CreateListener("tcp", addr, net.ListenConfig{Control: permitPortReuse}); err == nil { l2, _, err := CreateListener("tcp", fmt.Sprintf("127.0.0.1:%d", port), net.ListenConfig{Control: permitPortReuse})
if err == nil {
l2.Close()
t.Fatalf("creating second listener without port sharing should fail") t.Fatalf("creating second listener without port sharing should fail")
} }
} }