diff --git a/src/php/tests/interop/xds_client.php b/src/php/tests/interop/xds_client.php index a44287e4c92..6e967d2a1f6 100644 --- a/src/php/tests/interop/xds_client.php +++ b/src/php/tests/interop/xds_client.php @@ -98,6 +98,7 @@ class ClientThread extends Thread { // Autoloaded classes do not get inherited in threads. // Hence we need to do this. require_once($this->autoload_path_); + $TIMEOUT_US = 30 * 1e6; // 30 seconds $stub = new Grpc\Testing\TestServiceClient($this->server_address_, [ 'credentials' => Grpc\ChannelCredentials::createInsecure() @@ -121,7 +122,8 @@ class ClientThread extends Thread { usleep($sleep_us); } list($response, $status) - = $stub->UnaryCall($request)->wait(); + = $stub->UnaryCall($request, [], + ['timeout' => $TIMEOUT_US])->wait(); if ($status->code == Grpc\STATUS_OK) { $this->results[] = $response->getHostname(); } else { diff --git a/src/ruby/pb/test/xds_client.rb b/src/ruby/pb/test/xds_client.rb index 4310a87f2ed..a70095ccd1f 100755 --- a/src/ruby/pb/test/xds_client.rb +++ b/src/ruby/pb/test/xds_client.rb @@ -122,7 +122,8 @@ def run_test_loop(stub, target_seconds_between_rpcs, fail_on_failed_rpcs) sleep(sleep_seconds) end begin - resp = stub.unary_call(req) + deadline = GRPC::Core::TimeConsts::from_relative_time(30) # 30 seconds + resp = stub.unary_call(req, deadline: deadline) remote_peer = resp.hostname rescue GRPC::BadStatus => e remote_peer = ""