From 6be4b0143793ab5ceebc5d9d6bbe5c2f1333a0d2 Mon Sep 17 00:00:00 2001 From: Martin Sustrik Date: Fri, 21 Aug 2009 14:29:22 +0200 Subject: session management implemented --- src/session.hpp | 15 +++++++++++---- 1 file changed, 11 insertions(+), 4 deletions(-) (limited to 'src/session.hpp') diff --git a/src/session.hpp b/src/session.hpp index 2cb8e18..6d6bcf7 100644 --- a/src/session.hpp +++ b/src/session.hpp @@ -20,8 +20,11 @@ #ifndef __ZMQ_SESSION_HPP_INCLUDED__ #define __ZMQ_SESSION_HPP_INCLUDED__ +#include + #include "i_inout.hpp" #include "owned.hpp" +#include "options.hpp" namespace zmq { @@ -30,24 +33,28 @@ namespace zmq { public: - session_t (object_t *parent_, socket_base_t *owner_, - class zmq_engine_t *engine_); + session_t (object_t *parent_, socket_base_t *owner_, const char *name_); private: ~session_t (); // i_inout interface implementation. - bool read (::zmq_msg *msg_); - bool write (::zmq_msg *msg_); + bool read (::zmq_msg_t *msg_); + bool write (::zmq_msg_t *msg_); void flush (); // Handlers for incoming commands. void process_plug (); void process_unplug (); + void process_attach (class zmq_engine_t *engine_); class zmq_engine_t *engine; + // The name of the session. One that is used to register it with + // socket-level repository of sessions. + std::string name; + session_t (const session_t&); void operator = (const session_t&); }; -- cgit v1.2.3