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() {