From d47e58544f8f6b2fdfbb53077e6cc68b44624127 Mon Sep 17 00:00:00 2001 From: Craig Tiller Date: Fri, 9 Sep 2022 10:53:58 -0700 Subject: [PATCH] [flaky] Increase timeout (#30909) --- .../alts/handshaker/alts_concurrent_connectivity_test.cc | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/test/core/tsi/alts/handshaker/alts_concurrent_connectivity_test.cc b/test/core/tsi/alts/handshaker/alts_concurrent_connectivity_test.cc index 9e263a0d85d..ce352c9ae6b 100644 --- a/test/core/tsi/alts/handshaker/alts_concurrent_connectivity_test.cc +++ b/test/core/tsi/alts/handshaker/alts_concurrent_connectivity_test.cc @@ -225,8 +225,6 @@ class ConnectLoopRunner { self->server_address_.get(), self->fake_handshake_server_addr_.get(), self->reconnect_backoff_ms_); // Connect, forcing an ALTS handshake - gpr_timespec connect_deadline = - grpc_timeout_seconds_to_deadline(self->per_connect_deadline_seconds_); grpc_connectivity_state state = grpc_channel_check_connectivity_state(channel, 1); ASSERT_EQ(state, GRPC_CHANNEL_IDLE); @@ -240,7 +238,10 @@ class ConnectLoopRunner { grpc_channel_watch_connectivity_state( channel, state, gpr_inf_future(GPR_CLOCK_REALTIME), cq, nullptr); grpc_event ev = - grpc_completion_queue_next(cq, connect_deadline, nullptr); + grpc_completion_queue_next(cq, + grpc_timeout_seconds_to_deadline( + self->per_connect_deadline_seconds_), + nullptr); ASSERT_EQ(ev.type, GRPC_OP_COMPLETE) << "connect_loop runner:" << std::hex << self << " got ev.type:" << ev.type << " i:" << i; @@ -289,7 +290,7 @@ TEST(AltsConcurrentConnectivityTest, TestBasicClientServerHandshakes) { { ConnectLoopRunner runner( test_server.address(), fake_handshake_server.address(), - 5 /* per connect deadline seconds */, 10 /* loops */, + 10 /* per connect deadline seconds */, 10 /* loops */, GRPC_CHANNEL_READY /* expected connectivity states */, 0 /* reconnect_backoff_ms unset */); }