mirrors/mongodb
mirrors/mongodb
0
0
Fork 0
mirror of https://github.com/mongodb/mongo.git synced 2024-12-01 09:32:32 +01:00
Code Issues Releases Activity

mongos async: cache remote port

Browse Source
This commit is contained in:
Mathias Stearn 2010-01-25 15:35:54 -05:00
parent 45886bc725
commit ab09697687
1 changed files with 11 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
util/message_server_asio.cpp
View File

@ -32,7 +32,6 @@
using namespace boost;
using namespace boost::asio;
using namespace boost::asio::ip;
//using namespace std;
namespace mongo {
namespace {
@ -41,9 +40,12 @@ namespace mongo {
class MessageServerSession : public boost::enable_shared_from_this<MessageServerSession> , public AbstractMessagingPort {
public:
MessageServerSession( MessageHandler * handler , io_service& ioservice ) : _handler( handler ) , _socket( ioservice ){
}
MessageServerSession( MessageHandler * handler , io_service& ioservice )
: _handler( handler )
, _socket( ioservice )
, _portCache(0)
{ }
~MessageServerSession(){
cout << "disconnect from: " << _socket.remote_endpoint() << endl;
}
@ -117,7 +119,9 @@ namespace mongo {
virtual unsigned remotePort(){
return _socket.remote_endpoint().port();
if (!_portCache)
_portCache = _socket.remote_endpoint().port(); //this is expensive
return _portCache;
}
private:
@ -134,6 +138,8 @@ namespace mongo {
MsgData _inHeader;
Message _cur;
Message _reply;
unsigned _portCache;
};