mirrors/mongodb
mirrors/mongodb
0
0
Fork 0
mirror of https://github.com/mongodb/mongo.git synced 2024-12-01 09:32:32 +01:00
Code Issues Releases Activity

SERVER-50227 Convert OpMsg integration test to use ClockSource instead of TickSource

Browse Source
This commit is contained in:
Ben Caimano 2020-08-27 15:55:18 +00:00 committed by Evergreen Agent
parent 4406491b2b
commit 291f925b64
1 changed files with 12 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
src/mongo/rpc/op_msg_integration_test.cpp
View File

@ -568,7 +568,7 @@ TEST(OpMsg, ServerHandlesExhaustIsMasterCorrectly) {
ASSERT(conn);
}
auto tickSource = getGlobalServiceContext()->getTickSource();
auto clockSource = getGlobalServiceContext()->getPreciseClockSource();
// Issue an isMaster command without a topology version.
auto isMasterCmd = BSON("isMaster" << 1);
@ -590,11 +590,11 @@ TEST(OpMsg, ServerHandlesExhaustIsMasterCorrectly) {
OpMsg::setFlag(&request, OpMsg::kExhaustSupported);
// Run isMaster command to initiate the exhaust stream.
auto beforeExhaustCommand = tickSource->getTicks();
auto beforeExhaustCommand = clockSource->now();
ASSERT(conn->call(request, reply));
auto afterFirstResponse = tickSource->getTicks();
auto afterFirstResponse = clockSource->now();
// Allow for clock skew when testing the response time.
ASSERT_GT(tickSource->ticksTo<Milliseconds>(afterFirstResponse - beforeExhaustCommand),
ASSERT_GT(duration_cast<Milliseconds>(afterFirstResponse - beforeExhaustCommand),
Milliseconds(50));
ASSERT(OpMsg::isFlagSet(reply, OpMsg::kMoreToCome));
res = OpMsg::parse(reply).body;
@ -605,9 +605,9 @@ TEST(OpMsg, ServerHandlesExhaustIsMasterCorrectly) {
// Receive next exhaust message.
auto lastRequestId = reply.header().getId();
ASSERT_OK(conn->recv(reply, lastRequestId));
auto afterSecondResponse = tickSource->getTicks();
auto afterSecondResponse = clockSource->now();
// Allow for clock skew when testing the response time.
ASSERT_GT(tickSource->ticksTo<Milliseconds>(afterSecondResponse - afterFirstResponse),
ASSERT_GT(duration_cast<Milliseconds>(afterSecondResponse - afterFirstResponse),
Milliseconds(50));
ASSERT(OpMsg::isFlagSet(reply, OpMsg::kMoreToCome));
res = OpMsg::parse(reply).body;
@ -631,7 +631,7 @@ TEST(OpMsg, ServerHandlesExhaustIsMasterWithTopologyChange) {
ASSERT(conn);
}
auto tickSource = getGlobalServiceContext()->getTickSource();
auto clockSource = getGlobalServiceContext()->getPreciseClockSource();
// Issue an isMaster command without a topology version.
auto isMasterCmd = BSON("isMaster" << 1);
@ -656,11 +656,11 @@ TEST(OpMsg, ServerHandlesExhaustIsMasterWithTopologyChange) {
// Run isMaster command to initiate the exhaust stream. The first response should be received
// immediately.
auto beforeExhaustCommand = tickSource->getTicks();
auto beforeExhaustCommand = clockSource->now();
ASSERT(conn->call(request, reply));
auto afterFirstResponse = tickSource->getTicks();
auto afterFirstResponse = clockSource->now();
// Allow for clock skew when testing the response time.
ASSERT_LT(tickSource->ticksTo<Milliseconds>(afterFirstResponse - beforeExhaustCommand),
ASSERT_LT(duration_cast<Milliseconds>(afterFirstResponse - beforeExhaustCommand),
Milliseconds(50));
ASSERT(OpMsg::isFlagSet(reply, OpMsg::kMoreToCome));
res = OpMsg::parse(reply).body;
@ -671,9 +671,9 @@ TEST(OpMsg, ServerHandlesExhaustIsMasterWithTopologyChange) {
// Receive next exhaust message. The second response waits for 'maxAwaitTimeMS'.
auto lastRequestId = reply.header().getId();
ASSERT_OK(conn->recv(reply, lastRequestId));
auto afterSecondResponse = tickSource->getTicks();
auto afterSecondResponse = clockSource->now();
// Allow for clock skew when testing the response time.
ASSERT_GT(tickSource->ticksTo<Milliseconds>(afterSecondResponse - afterFirstResponse),
ASSERT_GT(duration_cast<Milliseconds>(afterSecondResponse - afterFirstResponse),
Milliseconds(50));
ASSERT(OpMsg::isFlagSet(reply, OpMsg::kMoreToCome));
res = OpMsg::parse(reply).body;