2009-03-02 19:35:34 +01:00
|
|
|
// message_server_port.cpp
|
|
|
|
|
|
|
|
#ifndef USE_ASIO
|
|
|
|
|
|
|
|
#include "message.h"
|
|
|
|
#include "message_server.h"
|
|
|
|
|
|
|
|
namespace mongo {
|
|
|
|
|
2009-03-02 22:27:35 +01:00
|
|
|
namespace pms {
|
2009-03-02 19:35:34 +01:00
|
|
|
|
2009-03-02 22:27:35 +01:00
|
|
|
MessagingPort * grab = 0;
|
|
|
|
MessageHandler * handler;
|
|
|
|
|
|
|
|
void threadRun(){
|
|
|
|
assert( grab );
|
|
|
|
MessagingPort * p = grab;
|
|
|
|
grab = 0;
|
|
|
|
|
2009-03-02 19:35:34 +01:00
|
|
|
Message m;
|
|
|
|
try {
|
|
|
|
while ( 1 ){
|
|
|
|
m.reset();
|
|
|
|
|
|
|
|
if ( ! p->recv(m) ) {
|
|
|
|
log() << "end connection " << p->farEnd.toString() << endl;
|
|
|
|
p->shutdown();
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
|
2009-03-02 22:27:35 +01:00
|
|
|
handler->process( m , p );
|
2009-03-02 19:35:34 +01:00
|
|
|
}
|
|
|
|
}
|
|
|
|
catch ( ... ){
|
|
|
|
problem() << "uncaught exception in PortMessageServer::threadRun, closing connection" << endl;
|
|
|
|
delete p;
|
2009-03-02 22:27:35 +01:00
|
|
|
}
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
class PortMessageServer : public MessageServer , public Listener {
|
|
|
|
public:
|
|
|
|
PortMessageServer( int port , MessageHandler * handler ) :
|
|
|
|
MessageServer( port , handler ) ,
|
|
|
|
Listener( port ){
|
|
|
|
|
|
|
|
uassert( "multiple PortMessageServer not supported" , ! pms::handler );
|
|
|
|
pms::handler = handler;
|
2009-03-02 19:35:34 +01:00
|
|
|
}
|
|
|
|
|
|
|
|
virtual void accepted(MessagingPort * p) {
|
2009-03-02 22:27:35 +01:00
|
|
|
assert( ! pms::grab );
|
|
|
|
pms::grab = p;
|
|
|
|
boost::thread thr( pms::threadRun );
|
|
|
|
while ( pms::grab )
|
|
|
|
sleepmillis(1);
|
2009-03-02 19:35:34 +01:00
|
|
|
}
|
|
|
|
|
|
|
|
void run(){
|
|
|
|
listen();
|
|
|
|
}
|
|
|
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
|
|
MessageServer * createServer( int port , MessageHandler * handler ){
|
|
|
|
return new PortMessageServer( port , handler );
|
|
|
|
}
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
#endif
|