xuemingqiang/mongo
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

working towrads unifying network code

Browse Source
This commit is contained in:
Eliot Horowitz
2011-04-05 02:24:16 -04:00
parent ec093cc5ac
commit f9237e3cb6
14 changed files with 133 additions and 36 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
db/instance.cpp
View File

@@ -221,7 +221,7 @@ namespace mongo {
}
// Returns false when request includes 'end'
void assembleResponse( Message &m, DbResponse &dbresponse, const SockAddr &client ) {
void assembleResponse( Message &m, DbResponse &dbresponse, const HostAndPort& remote ) {
// before we lock...
int op = m.operation();
@@ -268,7 +268,7 @@ namespace mongo {
currentOpP = nestedOp.get();
}
CurOp& currentOp = *currentOpP;
currentOp.reset(client,op);
currentOp.reset(remote,op);
OpDebug& debug = currentOp.debug();
StringBuilder& ss = debug.str;
@@ -652,7 +652,7 @@ namespace mongo {
if ( lastError._get() )
lastError.startRequest( toSend, lastError._get() );
DbResponse dbResponse;
assembleResponse( toSend, dbResponse );
assembleResponse( toSend, dbResponse , HostAndPort( "localhost" , -1 ) );
assert( dbResponse.response );
dbResponse.response->concat(); // can get rid of this if we make response handling smarter
response = *dbResponse.response;
@@ -664,7 +664,7 @@ namespace mongo {
if ( lastError._get() )
lastError.startRequest( toSend, lastError._get() );
DbResponse dbResponse;
assembleResponse( toSend, dbResponse );
assembleResponse( toSend, dbResponse , HostAndPort( "localhost" , -1 ) );
getDur().commitIfNeeded();
}