diff options
Diffstat (limited to 'src/mongo/db/dbdirectclient.cpp')
| -rw-r--r-- | src/mongo/db/dbdirectclient.cpp | 9 |
1 files changed, 4 insertions, 5 deletions
diff --git a/src/mongo/db/dbdirectclient.cpp b/src/mongo/db/dbdirectclient.cpp index 5b1499da351..60a001f534e 100644 --- a/src/mongo/db/dbdirectclient.cpp +++ b/src/mongo/db/dbdirectclient.cpp @@ -123,10 +123,9 @@ bool DBDirectClient::call(Message& toSend, Message& response, bool assertOk, str DirectClientScope directClientScope(_opCtx); LastError::get(_opCtx->getClient()).startRequest(); - DbResponse dbResponse; CurOp curOp(_opCtx); - assembleResponse(_opCtx, toSend, dbResponse, kHostAndPortForDirectClient); - verify(!dbResponse.response.empty()); + auto dbResponse = assembleResponse(_opCtx, toSend, kHostAndPortForDirectClient); + invariant(!dbResponse.response.empty()); response = std::move(dbResponse.response); return true; @@ -136,9 +135,9 @@ void DBDirectClient::say(Message& toSend, bool isRetry, string* actualServer) { DirectClientScope directClientScope(_opCtx); LastError::get(_opCtx->getClient()).startRequest(); - DbResponse dbResponse; CurOp curOp(_opCtx); - assembleResponse(_opCtx, toSend, dbResponse, kHostAndPortForDirectClient); + auto dbResponse = assembleResponse(_opCtx, toSend, kHostAndPortForDirectClient); + invariant(dbResponse.response.empty()); } unique_ptr<DBClientCursor> DBDirectClient::query(const string& ns, |