mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-07-24 20:24:09 +00:00
Merge pull request #69470 from immutableT/envelope-flake-test-fix
Increase time-out of kms gRPC service concurrency tests.
This commit is contained in:
commit
844d686591
@ -160,10 +160,6 @@ func TestUnsupportedVersion(t *testing.T) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func TestConcurrentAccess(t *testing.T) {
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
// Normal encryption and decryption operation.
|
// Normal encryption and decryption operation.
|
||||||
func TestGRPCService(t *testing.T) {
|
func TestGRPCService(t *testing.T) {
|
||||||
// Start a test gRPC server.
|
// Start a test gRPC server.
|
||||||
@ -208,14 +204,14 @@ func TestGRPCServiceConcurrentAccess(t *testing.T) {
|
|||||||
defer f.server.Stop()
|
defer f.server.Stop()
|
||||||
|
|
||||||
// Create the gRPC client service.
|
// Create the gRPC client service.
|
||||||
service, err := NewGRPCService(endpoint, 1*time.Second)
|
service, err := NewGRPCService(endpoint, 15*time.Second)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
t.Fatalf("failed to create envelope service, error: %v", err)
|
t.Fatalf("failed to create envelope service, error: %v", err)
|
||||||
}
|
}
|
||||||
defer destroyService(service)
|
defer destroyService(service)
|
||||||
|
|
||||||
var wg sync.WaitGroup
|
var wg sync.WaitGroup
|
||||||
n := 1000
|
n := 100
|
||||||
wg.Add(n)
|
wg.Add(n)
|
||||||
for i := 0; i < n; i++ {
|
for i := 0; i < n; i++ {
|
||||||
go func() {
|
go func() {
|
||||||
|
Loading…
Reference in New Issue
Block a user