diff --git a/grpc/tests/timeout_test.cpp b/grpc/tests/timeout_test.cpp index e14fd1dc8b6b..df3a41a09cc8 100644 --- a/grpc/tests/timeout_test.cpp +++ b/grpc/tests/timeout_test.cpp @@ -6,6 +6,7 @@ #include +#include #include #include #include @@ -28,7 +29,7 @@ class UnitTestService final : public sample::ugrpc::UnitTestServiceBase { LOG_DEBUG() << request_counter_ << " request attempt: now=" << std::chrono::system_clock::now() << ", deadline=" << context.GetServerContext().deadline(); if (++request_counter_ % 4) { - engine::InterruptibleSleepFor(std::chrono::milliseconds{200}); + engine::InterruptibleSleepFor(tests::kShortTimeout + tests::kAddSleep); EXPECT_TRUE(context.GetServerContext().IsCancelled()); // this status should not reach client because of 'perAttemptRecvTimeout' LOG_DEBUG() << request_counter_ << ": return ABORTED"; @@ -51,7 +52,7 @@ using TimeoutTest = ugrpc::tests::ServiceFixture; UTEST_F(TimeoutTest, DISABLED_IN_OLD_GRPC_TEST_NAME(PerAttemptTimeout)) { ugrpc::client::Qos qos; qos.attempts = 4; - qos.timeout = std::chrono::milliseconds{100}; + qos.timeout = tests::kShortTimeout; ugrpc::client::ClientQos client_qos; client_qos.SetDefault(qos); const auto config = std::vector{{tests::kUnitTestClientQos, client_qos}};