diff options
author | Kaloian Manassiev <kaloian.manassiev@mongodb.com> | 2015-03-05 14:16:21 -0500 |
---|---|---|
committer | Kaloian Manassiev <kaloian.manassiev@mongodb.com> | 2015-03-09 11:46:33 -0400 |
commit | 5c2ec43c0a8d20283968165d2e004644b0f23390 (patch) | |
tree | 398ff0a944dfa011e9a7d21c32c90bdb42e8d440 /src/mongo/s/request.cpp | |
parent | c5b0ff8c1d063ced62da89446f675a05d1181816 (diff) | |
download | mongo-5c2ec43c0a8d20283968165d2e004644b0f23390.tar.gz |
SERVER-17496 Move ShardConnection to separate file
Diffstat (limited to 'src/mongo/s/request.cpp')
-rw-r--r-- | src/mongo/s/request.cpp | 28 |
1 files changed, 12 insertions, 16 deletions
diff --git a/src/mongo/s/request.cpp b/src/mongo/s/request.cpp index ac2a6781eae..e1f6b322f40 100644 --- a/src/mongo/s/request.cpp +++ b/src/mongo/s/request.cpp @@ -34,35 +34,31 @@ #include "mongo/s/request.h" -#include "mongo/client/connpool.h" #include "mongo/db/auth/authorization_session.h" #include "mongo/db/commands.h" -#include "mongo/db/dbmessage.h" -#include "mongo/db/operation_context_noop.h" #include "mongo/db/stats/counters.h" -#include "mongo/s/chunk.h" #include "mongo/s/client_info.h" -#include "mongo/s/config.h" #include "mongo/s/cursors.h" #include "mongo/s/grid.h" -#include "mongo/s/server.h" +#include "mongo/s/strategy.h" #include "mongo/util/log.h" +#include "mongo/util/timer.h" namespace mongo { using std::endl; using std::string; - Request::Request( Message& m, AbstractMessagingPort* p ) : - _m(m) , _d( m ) , _p(p) , _didInit(false) { + Request::Request(Message& m, AbstractMessagingPort* p) + : _clientInfo(ClientInfo::get()), + _m(m), + _d(m), + _p(p), + _id(_m.header().getId()), + _didInit(false) { - _id = _m.header().getId(); - - _txn.reset(new OperationContextNoop()); - - _clientInfo = ClientInfo::get(); - if ( p ) { - _clientInfo->newPeerRequest( p->remote() ); + if (p) { + _clientInfo->newPeerRequest(p->remote()); } else { _clientInfo->newRequest(); @@ -74,7 +70,7 @@ namespace mongo { return; _didInit = true; reset(); - _clientInfo->getAuthorizationSession()->startRequest(_txn.get()); + _clientInfo->getAuthorizationSession()->startRequest(NULL); } // Deprecated, will move to the strategy itself |