diff options
author | Eliot Horowitz <eliot@10gen.com> | 2011-03-30 17:03:52 -0400 |
---|---|---|
committer | Eliot Horowitz <eliot@10gen.com> | 2011-03-31 03:12:43 -0400 |
commit | 134e8eb0e0913747ac648875514332fe9949d4cd (patch) | |
tree | 9d74bf3c35cf7920fd39fe18b890cc1d4774a63f /util/message_server_port.cpp | |
parent | 7c5b035e1bad0a4f1d84adde04df49b57dae7828 (diff) | |
download | mongo-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.cpp | 10 |
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() ); } } |