summaryrefslogtreecommitdiff
path: root/src/session.cpp
diff options
context:
space:
mode:
authorMartin Sustrik <sustrik@fastmq.commkdir>2009-09-16 11:02:18 +0200
committerMartin Sustrik <sustrik@fastmq.commkdir>2009-09-16 11:02:18 +0200
commit9c522dccaf0b2c8074bd96fbfb4c968f45748ba4 (patch)
treedc57d84016ab8b0d1abbd5291bde434d985ab48a /src/session.cpp
parent6e03cb2f3eb083e1de8e7161d3ab21b52c87eece (diff)
reconnect added to zmq_connecter
Diffstat (limited to 'src/session.cpp')
-rw-r--r--src/session.cpp9
1 files changed, 6 insertions, 3 deletions
diff --git a/src/session.cpp b/src/session.cpp
index 31c6354..9593827 100644
--- a/src/session.cpp
+++ b/src/session.cpp
@@ -23,14 +23,15 @@
#include "pipe.hpp"
zmq::session_t::session_t (object_t *parent_, socket_base_t *owner_,
- const char *name_, const options_t &options_) :
+ const char *name_, const options_t &options_, bool reconnect_) :
owned_t (parent_, owner_),
in_pipe (NULL),
active (true),
out_pipe (NULL),
engine (NULL),
name (name_),
- options (options_)
+ options (options_),
+ reconnect (reconnect_)
{
}
@@ -69,7 +70,9 @@ void zmq::session_t::flush ()
void zmq::session_t::detach ()
{
- // Engine is terminating itself.
+ // TODO: Start reconnection process here.
+
+ // Engine is terminating itself. No need to deallocate it from here.
engine = NULL;
// In the case od anonymous connection, terminate the session.