summaryrefslogtreecommitdiff
path: root/src/session.hpp
diff options
context:
space:
mode:
authorMartin Sustrik <sustrik@fastmq.commkdir>2009-08-21 14:29:22 +0200
committerMartin Sustrik <sustrik@fastmq.commkdir>2009-08-21 14:29:22 +0200
commit6be4b0143793ab5ceebc5d9d6bbe5c2f1333a0d2 (patch)
treea785065e54317d1d360e2e4b3a4acf1d6e5669f1 /src/session.hpp
parenta801b6d8b37557ccfb53030dca22f89a3f99b59c (diff)
session management implemented
Diffstat (limited to 'src/session.hpp')
-rw-r--r--src/session.hpp15
1 files changed, 11 insertions, 4 deletions
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 <string>
+
#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&);
};