From f2bcdf3bbcb4ff5fe59d9fdd806808a17bfe5ae4 Mon Sep 17 00:00:00 2001 From: Yijie Ma Date: Wed, 18 Jan 2023 11:09:17 -0800 Subject: [PATCH] Add a test case for infinite past or unix epoch expiry in alarm_test.cc (#32101) * initial commit * review --- test/cpp/common/alarm_test.cc | 24 ++++++++++++++++++++++++ 1 file changed, 24 insertions(+) diff --git a/test/cpp/common/alarm_test.cc b/test/cpp/common/alarm_test.cc index 4b571e021da..192e30705bd 100644 --- a/test/cpp/common/alarm_test.cc +++ b/test/cpp/common/alarm_test.cc @@ -266,6 +266,30 @@ TEST(AlarmTest, NegativeExpiry) { EXPECT_EQ(junk, output_tag); } +// Infinite past or unix epoch should fire immediately. +TEST(AlarmTest, InfPastExpiry) { + CompletionQueue cq; + void* junk = reinterpret_cast(1618033); + Alarm alarm; + alarm.Set(&cq, gpr_inf_past(GPR_CLOCK_REALTIME), junk); + + void* output_tag; + bool ok; + CompletionQueue::NextStatus status = + cq.AsyncNext(&output_tag, &ok, grpc_timeout_seconds_to_deadline(10)); + + EXPECT_EQ(status, CompletionQueue::GOT_EVENT); + EXPECT_TRUE(ok); + EXPECT_EQ(junk, output_tag); + + alarm.Set(&cq, std::chrono::system_clock::time_point(), junk); + status = cq.AsyncNext(&output_tag, &ok, grpc_timeout_seconds_to_deadline(10)); + + EXPECT_EQ(status, CompletionQueue::GOT_EVENT); + EXPECT_TRUE(ok); + EXPECT_EQ(junk, output_tag); +} + TEST(AlarmTest, Cancellation) { CompletionQueue cq; void* junk = reinterpret_cast(1618033);