summaryrefslogtreecommitdiff
path: root/src/mongo/executor/network_interface_integration_test.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/executor/network_interface_integration_test.cpp')
-rw-r--r--src/mongo/executor/network_interface_integration_test.cpp35
1 files changed, 18 insertions, 17 deletions
diff --git a/src/mongo/executor/network_interface_integration_test.cpp b/src/mongo/executor/network_interface_integration_test.cpp
index 366b92ff22e..b84fcb844d8 100644
--- a/src/mongo/executor/network_interface_integration_test.cpp
+++ b/src/mongo/executor/network_interface_integration_test.cpp
@@ -343,7 +343,7 @@ TEST_F(NetworkInterfaceTest, CancelLocally) {
// Wait for op to complete, assert that it was canceled.
auto result = deferred.get();
ASSERT_EQ(ErrorCodes::CallbackCanceled, result.status);
- ASSERT(result.elapsedMillis);
+ ASSERT(result.elapsed);
assertNumOps(1u, 0u, 0u, 0u);
}
@@ -394,7 +394,7 @@ TEST_F(NetworkInterfaceTest, CancelRemotely) {
// Wait for the command to return, assert that it was canceled.
auto result = deferred.get();
ASSERT_EQ(ErrorCodes::CallbackCanceled, result.status);
- ASSERT(result.elapsedMillis);
+ ASSERT(result.elapsed);
// Wait for the operation to be killed on the remote host.
numCurrentOpRan += waitForCommandToStop("echo", kMaxWait);
@@ -460,7 +460,7 @@ TEST_F(NetworkInterfaceTest, CancelRemotelyTimedOut) {
// Wait for the command to return, assert that it was canceled.
auto result = deferred.get();
ASSERT_EQ(ErrorCodes::CallbackCanceled, result.status);
- ASSERT(result.elapsedMillis);
+ ASSERT(result.elapsed);
// We have one canceled operation (echo), one timedout operation (_killOperations),
// and one succeeded operation on top of the currentOp operations (configureFailPoint).
@@ -488,7 +488,7 @@ TEST_F(NetworkInterfaceTest, ImmediateCancel) {
// Wait for op to complete, assert that it was canceled.
auto result = deferred.get();
ASSERT_EQ(ErrorCodes::CallbackCanceled, result.status);
- ASSERT(result.elapsedMillis);
+ ASSERT(result.elapsed);
assertNumOps(1u, 0u, 0u, 0u);
}
@@ -502,7 +502,7 @@ TEST_F(NetworkInterfaceTest, LateCancel) {
net().cancelCommand(cbh);
ASSERT_OK(result.status);
- ASSERT(result.elapsedMillis);
+ ASSERT(result.elapsed);
assertNumOps(0u, 0u, 0u, 1u);
}
@@ -520,7 +520,7 @@ TEST_F(NetworkInterfaceTest, AsyncOpTimeout) {
// check that we've timed out.
if (!pingCommandMissing(result)) {
ASSERT_EQ(ErrorCodes::NetworkInterfaceExceededTimeLimit, result.status);
- ASSERT(result.elapsedMillis);
+ ASSERT(result.elapsed);
assertNumOps(0u, 1u, 0u, 0u);
}
}
@@ -552,11 +552,11 @@ TEST_F(NetworkInterfaceTest, AsyncOpTimeoutWithOpCtxDeadlineSooner) {
}
ASSERT_EQ(ErrorCodes::NetworkInterfaceExceededTimeLimit, result.status);
- ASSERT(result.elapsedMillis);
+ ASSERT(result.elapsed);
// check that the request timeout uses the smaller of the operation context deadline and
// the timeout specified in the request constructor.
- ASSERT_GTE(result.elapsedMillis.value(), opCtxDeadline);
- ASSERT_LT(result.elapsedMillis.value(), requestTimeout);
+ ASSERT_GTE(result.elapsed.value(), opCtxDeadline);
+ ASSERT_LT(result.elapsed.value(), requestTimeout);
assertNumOps(0u, 1u, 0u, 0u);
}
@@ -586,11 +586,12 @@ TEST_F(NetworkInterfaceTest, AsyncOpTimeoutWithOpCtxDeadlineLater) {
}
ASSERT_EQ(ErrorCodes::NetworkInterfaceExceededTimeLimit, result.status);
- ASSERT(result.elapsedMillis);
+ ASSERT(result.elapsed);
// check that the request timeout uses the smaller of the operation context deadline and
// the timeout specified in the request constructor.
- ASSERT_GTE(result.elapsedMillis.value(), requestTimeout);
- ASSERT_LT(result.elapsedMillis.value(), opCtxDeadline);
+ ASSERT_GTE(duration_cast<Milliseconds>(result.elapsed.value()), requestTimeout);
+ ASSERT_LT(duration_cast<Milliseconds>(result.elapsed.value()), opCtxDeadline);
+
assertNumOps(0u, 1u, 0u, 0u);
}
@@ -602,7 +603,7 @@ TEST_F(NetworkInterfaceTest, StartCommand) {
auto res = deferred.get();
- ASSERT(res.elapsedMillis);
+ ASSERT(res.elapsed);
uassertStatusOK(res.status);
// This opmsg request expect the following reply, which is generated below
@@ -650,7 +651,7 @@ TEST_F(NetworkInterfaceTest, FireAndForget) {
for (auto& future : futures) {
auto result = future.get();
- ASSERT(result.elapsedMillis);
+ ASSERT(result.elapsed);
uassertStatusOK(result.status);
ASSERT_EQ(1, result.data.getIntField("ok"));
}
@@ -658,7 +659,7 @@ TEST_F(NetworkInterfaceTest, FireAndForget) {
// Run a non-fireAndForget command and verify that we get a CommandFailed response.
auto nonFireAndForgetRequest = makeTestCommand(kNoTimeout, makeEchoCmdObj());
auto result = runCommandSync(nonFireAndForgetRequest);
- ASSERT(result.elapsedMillis);
+ ASSERT(result.elapsed);
uassertStatusOK(result.status);
ASSERT_EQ(0, result.data.getIntField("ok"));
ASSERT_EQ(ErrorCodes::CommandFailed, result.data.getIntField("code"));
@@ -750,7 +751,7 @@ TEST_F(NetworkInterfaceInternalClientTest,
// Verify that the ping op is counted as a success.
auto res = deferred.get();
- ASSERT(res.elapsedMillis);
+ ASSERT(res.elapsed);
assertNumOps(0u, 0u, 0u, 1u);
}
@@ -764,7 +765,7 @@ TEST_F(NetworkInterfaceTest, IsMasterRequestMissingInternalClientInfoWhenNotInte
ASSERT_FALSE(isMasterHandshake.request["internalClient"]);
// Verify that the ping op is counted as a success.
auto res = deferred.get();
- ASSERT(res.elapsedMillis);
+ ASSERT(res.elapsed);
assertNumOps(0u, 0u, 0u, 1u);
}