diff options
author | Martin Sustrik <sustrik@fastmq.commkdir> | 2009-08-09 11:21:47 +0200 |
---|---|---|
committer | Martin Sustrik <sustrik@fastmq.commkdir> | 2009-08-09 11:21:47 +0200 |
commit | bde396f1561fb5e57e6e413a40d904586e186d42 (patch) | |
tree | cbd7537c95bbc8ab8a09a17cec6533a268500264 /src/zmq_listener.hpp | |
parent | 5b5b513330e96e3e08d0c2c60d03044091976420 (diff) |
fix to 3-thread synchronisation algorithm
Diffstat (limited to 'src/zmq_listener.hpp')
-rw-r--r-- | src/zmq_listener.hpp | 15 |
1 files changed, 15 insertions, 0 deletions
diff --git a/src/zmq_listener.hpp b/src/zmq_listener.hpp index ea7cb92..74d42e1 100644 --- a/src/zmq_listener.hpp +++ b/src/zmq_listener.hpp @@ -20,7 +20,10 @@ #ifndef __ZMQ_ZMQ_LISTENER_HPP_INCLUDED__ #define __ZMQ_ZMQ_LISTENER_HPP_INCLUDED__ +#include <string> + #include "io_object.hpp" +#include "tcp_listener.hpp" namespace zmq { @@ -31,6 +34,9 @@ namespace zmq zmq_listener_t (class io_thread_t *parent_, object_t *owner_); + // Set IP address to listen on. + int set_address (const char *addr_); + private: ~zmq_listener_t (); @@ -38,6 +44,15 @@ namespace zmq // Handlers for incoming commands. void process_plug (); + // Handle I/O events. + void in_event (); + + // Actual listening socket. + tcp_listener_t tcp_listener; + + // Handle corresponding to the listening socket. + handle_t handle; + zmq_listener_t (const zmq_listener_t&); void operator = (const zmq_listener_t&); }; |