summaryrefslogtreecommitdiff
path: root/util/message_server_port.cpp
diff options
context:
space:
mode:
authorEliot Horowitz <eliot@10gen.com>2011-03-30 17:03:52 -0400
committerEliot Horowitz <eliot@10gen.com>2011-03-31 03:12:43 -0400
commit134e8eb0e0913747ac648875514332fe9949d4cd (patch)
tree9d74bf3c35cf7920fd39fe18b890cc1d4774a63f /util/message_server_port.cpp
parent7c5b035e1bad0a4f1d84adde04df49b57dae7828 (diff)
downloadmongo-134e8eb0e0913747ac648875514332fe9949d4cd.tar.gz
remove all clientId related code and systems, and just use tls SERVER-2872
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 6d00628c8ad..76bd78d516c 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() );
}
}