summaryrefslogtreecommitdiff
path: root/util/message_server_port.cpp
diff options
context:
space:
mode:
authorAntonin Kral <a.kral@bobek.cz>2011-04-07 07:35:46 +0200
committerAntonin Kral <a.kral@bobek.cz>2011-04-07 07:35:46 +0200
commit8d913e98e8058c6322975a858f884a769735bb43 (patch)
tree52da0129272024f7132594b8227d81ec72f83af1 /util/message_server_port.cpp
parent582fc32574a3b158c81e49cb00e6ae59205e66ba (diff)
downloadmongodb-8d913e98e8058c6322975a858f884a769735bb43.tar.gz
Imported Upstream version 1.8.1
Diffstat (limited to 'util/message_server_port.cpp')
-rw-r--r--util/message_server_port.cpp10
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() );
}
}