diff options
author | Antonin Kral <a.kral@bobek.cz> | 2011-04-07 07:35:46 +0200 |
---|---|---|
committer | Antonin Kral <a.kral@bobek.cz> | 2011-04-07 07:35:46 +0200 |
commit | 8d913e98e8058c6322975a858f884a769735bb43 (patch) | |
tree | 52da0129272024f7132594b8227d81ec72f83af1 /util/message_server_port.cpp | |
parent | 582fc32574a3b158c81e49cb00e6ae59205e66ba (diff) | |
download | mongodb-8d913e98e8058c6322975a858f884a769735bb43.tar.gz |
Imported Upstream version 1.8.1
Diffstat (limited to 'util/message_server_port.cpp')
-rw-r--r-- | util/message_server_port.cpp | 10 |
1 files changed, 8 insertions, 2 deletions
diff --git a/util/message_server_port.cpp b/util/message_server_port.cpp index 6d00628..76bd78d 100644 --- a/util/message_server_port.cpp +++ b/util/message_server_port.cpp @@ -23,6 +23,7 @@ #include "message_server.h" #include "../db/cmdline.h" +#include "../db/lasterror.h" #include "../db/stats/counters.h" namespace mongo { @@ -38,14 +39,19 @@ namespace mongo { setThreadName( "conn" ); - auto_ptr<MessagingPort> p( inPort ); + scoped_ptr<MessagingPort> p( inPort ); string otherSide; Message m; try { + LastError * le = new LastError(); + lastError.reset( le ); // lastError now has ownership + otherSide = p->farEnd.toString(); + handler->connected( p.get() ); + while ( 1 ) { m.reset(); p->clearCounters(); @@ -57,7 +63,7 @@ namespace mongo { break; } - handler->process( m , p.get() ); + handler->process( m , p.get() , le ); networkCounter.hit( p->getBytesIn() , p->getBytesOut() ); } } |