Commit 96e04423 authored by Martin Sustrik's avatar Martin Sustrik

Merge branch 'master' of git@github.com:sustrik/zeromq2

parents 36a57637 dc8f4b1b
...@@ -100,8 +100,10 @@ int zmq::socket_base_t::bind (const char *addr_) ...@@ -100,8 +100,10 @@ int zmq::socket_base_t::bind (const char *addr_)
choose_io_thread (options.affinity), this, options); choose_io_thread (options.affinity), this, options);
zmq_assert (listener); zmq_assert (listener);
int rc = listener->set_address (addr_type.c_str(), addr_args.c_str ()); int rc = listener->set_address (addr_type.c_str(), addr_args.c_str ());
if (rc != 0) if (rc != 0) {
delete listener;
return -1; return -1;
}
send_plug (listener); send_plug (listener);
send_own (this, listener); send_own (this, listener);
......
...@@ -35,14 +35,13 @@ namespace zmq ...@@ -35,14 +35,13 @@ namespace zmq
zmq_listener_t (class io_thread_t *parent_, socket_base_t *owner_, zmq_listener_t (class io_thread_t *parent_, socket_base_t *owner_,
const options_t &options_); const options_t &options_);
~zmq_listener_t ();
// Set address to listen on. // Set address to listen on.
int set_address (const char* protocol_, const char *addr_); int set_address (const char* protocol_, const char *addr_);
private: private:
~zmq_listener_t ();
// Handlers for incoming commands. // Handlers for incoming commands.
void process_plug (); void process_plug ();
void process_unplug (); void process_unplug ();
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment