summaryrefslogtreecommitdiff
path: root/src/mongo/util/net/message_server.h
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/util/net/message_server.h')
-rw-r--r--src/mongo/util/net/message_server.h54
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);
}