diff options
Diffstat (limited to 'src/zmq_engine.hpp')
| -rw-r--r-- | src/zmq_engine.hpp | 9 |
1 files changed, 4 insertions, 5 deletions
diff --git a/src/zmq_engine.hpp b/src/zmq_engine.hpp index ba25ded..8299ebf 100644 --- a/src/zmq_engine.hpp +++ b/src/zmq_engine.hpp @@ -20,6 +20,7 @@ #ifndef __ZMQ_ZMQ_ENGINE_HPP_INCLUDED__ #define __ZMQ_ZMQ_ENGINE_HPP_INCLUDED__ +#include "i_engine.hpp" #include "io_object.hpp" #include "tcp_socket.hpp" #include "zmq_encoder.hpp" @@ -28,24 +29,22 @@ namespace zmq { - class zmq_engine_t : public io_object_t + class zmq_engine_t : public io_object_t, public i_engine { public: zmq_engine_t (class io_thread_t *parent_, fd_t fd_); ~zmq_engine_t (); + // i_engine interface implementation. void plug (struct i_inout *inout_); void unplug (); + void revive (); // i_poll_events interface implementation. void in_event (); void out_event (); - // This method is called by the session to signalise that there - // are messages to send available. - void revive (); - private: // Function to handle network disconnections. |