summaryrefslogtreecommitdiff
path: root/src/mongo/db/dbdirectclient.cpp
diff options
context:
space:
mode:
authorJason Rassi <rassi@10gen.com>2015-03-09 13:24:07 -0400
committerJason Rassi <rassi@10gen.com>2015-03-09 17:21:23 -0400
commit0c388e562f6b1549b583486b151164df17b37d94 (patch)
treed4faf8b27722398c9885b8bade3c32efc94e43fe /src/mongo/db/dbdirectclient.cpp
parente6491d77039d58197aa3cf63323a0b6d47f6b859 (diff)
downloadmongo-0c388e562f6b1549b583486b151164df17b37d94.tar.gz
SERVER-17499 Unify GodScope and fromDBDirectClient bool
Diffstat (limited to 'src/mongo/db/dbdirectclient.cpp')
-rw-r--r--src/mongo/db/dbdirectclient.cpp26
1 files changed, 13 insertions, 13 deletions
diff --git a/src/mongo/db/dbdirectclient.cpp b/src/mongo/db/dbdirectclient.cpp
index 3d50bb98e4b..b20fdf07092 100644
--- a/src/mongo/db/dbdirectclient.cpp
+++ b/src/mongo/db/dbdirectclient.cpp
@@ -49,20 +49,21 @@ namespace mongo {
namespace {
- class GodScope {
- MONGO_DISALLOW_COPYING(GodScope);
+ class DirectClientScope {
+ MONGO_DISALLOW_COPYING(DirectClientScope);
public:
- GodScope(OperationContext* txn) : _txn(txn) {
- _prev = _txn->getClient()->setGod(true);
+ explicit DirectClientScope(OperationContext* txn)
+ : _txn(txn), _prev(_txn->getClient()->isInDirectClient()) {
+ _txn->getClient()->setInDirectClient(true);
}
- ~GodScope() {
- _txn->getClient()->setGod(_prev);
+ ~DirectClientScope() {
+ _txn->getClient()->setInDirectClient(_prev);
}
private:
- bool _prev;
- OperationContext* _txn;
+ OperationContext* const _txn;
+ const bool _prev;
};
} // namespace
@@ -120,14 +121,13 @@ namespace mongo {
Message& response,
bool assertOk,
string* actualServer) {
-
- GodScope gs(_txn);
+ DirectClientScope directClientScope(_txn);
if (lastError._get()) {
lastError.startRequest(toSend, lastError._get());
}
DbResponse dbResponse;
- assembleResponse(_txn, toSend, dbResponse, dummyHost, true);
+ assembleResponse(_txn, toSend, dbResponse, dummyHost);
verify(dbResponse.response);
// can get rid of this if we make response handling smarter
@@ -138,13 +138,13 @@ namespace mongo {
}
void DBDirectClient::say(Message& toSend, bool isRetry, string* actualServer) {
- GodScope gs(_txn);
+ DirectClientScope directClientScope(_txn);
if (lastError._get()) {
lastError.startRequest(toSend, lastError._get());
}
DbResponse dbResponse;
- assembleResponse(_txn, toSend, dbResponse, dummyHost, true);
+ assembleResponse(_txn, toSend, dbResponse, dummyHost);
}
auto_ptr<DBClientCursor> DBDirectClient::query(const string& ns,