diff options
Diffstat (limited to 'src/mongo/util/net/message_server.h')
-rw-r--r-- | src/mongo/util/net/message_server.h | 54 |
1 files changed, 27 insertions, 27 deletions
diff --git a/src/mongo/util/net/message_server.h b/src/mongo/util/net/message_server.h index 7bb9759eeff..8807b6c0cb7 100644 --- a/src/mongo/util/net/message_server.h +++ b/src/mongo/util/net/message_server.h @@ -38,37 +38,37 @@ namespace mongo { - class MessageHandler { - public: - virtual ~MessageHandler() {} - - /** - * called once when a socket is connected - */ - virtual void connected( AbstractMessagingPort* p ) = 0; +class MessageHandler { +public: + virtual ~MessageHandler() {} - /** - * called every time a message comes in - * handler is responsible for responding to client - */ - virtual void process(Message& m, AbstractMessagingPort* p) = 0; - }; + /** + * called once when a socket is connected + */ + virtual void connected(AbstractMessagingPort* p) = 0; - class MessageServer { - public: - struct Options { - int port; // port to bind to - std::string ipList; // addresses to bind to + /** + * called every time a message comes in + * handler is responsible for responding to client + */ + virtual void process(Message& m, AbstractMessagingPort* p) = 0; +}; - Options() : port(0), ipList("") {} - }; +class MessageServer { +public: + struct Options { + int port; // port to bind to + std::string ipList; // addresses to bind to - virtual ~MessageServer() {} - virtual void run() = 0; - virtual void setAsTimeTracker() = 0; - virtual void setupSockets() = 0; + Options() : port(0), ipList("") {} }; - // TODO use a factory here to decide between port and asio variations - MessageServer * createServer( const MessageServer::Options& opts , MessageHandler * handler ); + virtual ~MessageServer() {} + virtual void run() = 0; + virtual void setAsTimeTracker() = 0; + virtual void setupSockets() = 0; +}; + +// TODO use a factory here to decide between port and asio variations +MessageServer* createServer(const MessageServer::Options& opts, MessageHandler* handler); } |