From fd64c3bac6f2a611a154c86c93fd77404404aba5 Mon Sep 17 00:00:00 2001 From: immutableT Date: Fri, 5 Oct 2018 16:22:00 +0000 Subject: [PATCH] Increase time-out of kms-service concurrency tests. --- .../value/encrypt/envelope/grpc_service_unix_test.go | 8 ++------ 1 file changed, 2 insertions(+), 6 deletions(-) diff --git a/staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/envelope/grpc_service_unix_test.go b/staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/envelope/grpc_service_unix_test.go index bc40b220c27..ca124770183 100644 --- a/staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/envelope/grpc_service_unix_test.go +++ b/staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/envelope/grpc_service_unix_test.go @@ -160,10 +160,6 @@ func TestUnsupportedVersion(t *testing.T) { } } -func TestConcurrentAccess(t *testing.T) { - -} - // Normal encryption and decryption operation. func TestGRPCService(t *testing.T) { // Start a test gRPC server. @@ -208,14 +204,14 @@ func TestGRPCServiceConcurrentAccess(t *testing.T) { defer f.server.Stop() // Create the gRPC client service. - service, err := NewGRPCService(endpoint, 1*time.Second) + service, err := NewGRPCService(endpoint, 15*time.Second) if err != nil { t.Fatalf("failed to create envelope service, error: %v", err) } defer destroyService(service) var wg sync.WaitGroup - n := 1000 + n := 100 wg.Add(n) for i := 0; i < n; i++ { go func() {