summaryrefslogtreecommitdiff
path: root/src/zmq_connecter_init.cpp
diff options
context:
space:
mode:
authormalosek <malosek@fastmq.com>2009-09-16 14:26:04 +0200
committermalosek <malosek@fastmq.com>2009-09-16 14:26:04 +0200
commit3534732c0614a764731fbea2431247068fa63330 (patch)
tree411b0a7b0fea4f9da2bb4318b42ab60f50715474 /src/zmq_connecter_init.cpp
parent17800ac85e667d18124d0e90f9387d6c90887570 (diff)
parenta71d00288008b7ed1dc91b6ad3d5fdf25a5e683e (diff)
Merge branch 'master' of git@github.com:sustrik/zeromq2
Diffstat (limited to 'src/zmq_connecter_init.cpp')
-rw-r--r--src/zmq_connecter_init.cpp6
1 files changed, 5 insertions, 1 deletions
diff --git a/src/zmq_connecter_init.cpp b/src/zmq_connecter_init.cpp
index ffd4a64..f0cbf90 100644
--- a/src/zmq_connecter_init.cpp
+++ b/src/zmq_connecter_init.cpp
@@ -60,9 +60,13 @@ bool zmq::zmq_connecter_init_t::read (::zmq_msg_t *msg_)
if (!session_name.empty ())
session = owner->find_session (session_name.c_str ());
if (!session) {
- // TODO
+
+ // TODO:
+ // The socket is already closing. The session is already shut down,
+ // so no point in continuing with connecting. Shut the connection down.
zmq_assert (false);
}
+
send_attach (session, engine);
engine = NULL;