diff options
| author | Matthew Russotto <matthew.russotto@mongodb.com> | 2019-11-26 21:24:44 +0000 |
|---|---|---|
| committer | evergreen <evergreen@mongodb.com> | 2019-11-26 21:24:44 +0000 |
| commit | 3c77881955004780a8dd424434575f9dc0a5632d (patch) | |
| tree | d38ba3cc3c5c913bd091e9e2e2da51040f770179 /src/mongo/rpc | |
| parent | ec9a2f13d82f141d8aca9e3df9e9112b722f2563 (diff) | |
| download | mongo-3c77881955004780a8dd424434575f9dc0a5632d.tar.gz | |
SERVER-44631 DBClient_Connection should retain error code information
Diffstat (limited to 'src/mongo/rpc')
| -rw-r--r-- | src/mongo/rpc/op_msg_integration_test.cpp | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/mongo/rpc/op_msg_integration_test.cpp b/src/mongo/rpc/op_msg_integration_test.cpp index 8cfbf1fa6bf..8659b7014d9 100644 --- a/src/mongo/rpc/op_msg_integration_test.cpp +++ b/src/mongo/rpc/op_msg_integration_test.cpp @@ -350,7 +350,7 @@ void exhaustTest(bool enableChecksum) { ASSERT_BSONOBJ_EQ(nextBatch[1].embeddedObject(), BSON("_id" << 1)); // Receive next exhaust batch. - conn->recv(reply, lastRequestId); + ASSERT_OK(conn->recv(reply, lastRequestId)); lastRequestId = reply.header().getId(); ASSERT(OpMsg::isFlagSet(reply, OpMsg::kMoreToCome)); ASSERT_EQ(OpMsg::isFlagSet(reply, OpMsg::kChecksumPresent), enableChecksum); @@ -363,7 +363,7 @@ void exhaustTest(bool enableChecksum) { ASSERT_BSONOBJ_EQ(nextBatch[1].embeddedObject(), BSON("_id" << 3)); // Receive terminal batch. - ASSERT(conn->recv(reply, lastRequestId)); + ASSERT_OK(conn->recv(reply, lastRequestId)); ASSERT(!OpMsg::isFlagSet(reply, OpMsg::kMoreToCome)); ASSERT_EQ(OpMsg::isFlagSet(reply, OpMsg::kChecksumPresent), enableChecksum); res = OpMsg::parse(reply).body; |