diff options
Diffstat (limited to 'src/mongo/executor/network_interface_integration_test.cpp')
-rw-r--r-- | src/mongo/executor/network_interface_integration_test.cpp | 35 |
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); } |