Commit ce4d3216 authored by Lourens Naudé's avatar Lourens Naudé

Revert "Merge pull request #473 from methodmissing/fix-engine-endpoint"

This reverts commit 1a18c7b0, reversing
changes made to bef9a41b.
parent 1a18c7b0
...@@ -63,6 +63,7 @@ zmq::stream_engine_t::stream_engine_t (fd_t fd_, const options_t &options_, cons ...@@ -63,6 +63,7 @@ zmq::stream_engine_t::stream_engine_t (fd_t fd_, const options_t &options_, cons
greeting_bytes_read (0), greeting_bytes_read (0),
session (NULL), session (NULL),
options (options_), options (options_),
endpoint (endpoint_),
plugged (false), plugged (false),
socket (NULL) socket (NULL)
{ {
...@@ -95,8 +96,6 @@ zmq::stream_engine_t::stream_engine_t (fd_t fd_, const options_t &options_, cons ...@@ -95,8 +96,6 @@ zmq::stream_engine_t::stream_engine_t (fd_t fd_, const options_t &options_, cons
int rc = setsockopt (s, SOL_SOCKET, SO_NOSIGPIPE, &set, sizeof (int)); int rc = setsockopt (s, SOL_SOCKET, SO_NOSIGPIPE, &set, sizeof (int));
errno_assert (rc == 0); errno_assert (rc == 0);
#endif #endif
endpoint = new char[endpoint_.length() + 1];
strcpy (endpoint, endpoint_.c_str());
} }
zmq::stream_engine_t::~stream_engine_t () zmq::stream_engine_t::~stream_engine_t ()
...@@ -118,7 +117,6 @@ zmq::stream_engine_t::~stream_engine_t () ...@@ -118,7 +117,6 @@ zmq::stream_engine_t::~stream_engine_t ()
delete encoder; delete encoder;
if (decoder != NULL) if (decoder != NULL)
delete decoder; delete decoder;
delete [] endpoint;
} }
void zmq::stream_engine_t::plug (io_thread_t *io_thread_, void zmq::stream_engine_t::plug (io_thread_t *io_thread_,
...@@ -486,7 +484,7 @@ int zmq::stream_engine_t::push_msg (msg_t *msg_) ...@@ -486,7 +484,7 @@ int zmq::stream_engine_t::push_msg (msg_t *msg_)
void zmq::stream_engine_t::error () void zmq::stream_engine_t::error ()
{ {
zmq_assert (session); zmq_assert (session);
socket->event_disconnected (endpoint, s); socket->event_disconnected (endpoint.c_str(), s);
session->detach (); session->detach ();
unplug (); unplug ();
delete this; delete this;
......
...@@ -132,7 +132,7 @@ namespace zmq ...@@ -132,7 +132,7 @@ namespace zmq
options_t options; options_t options;
// String representation of endpoint // String representation of endpoint
char *endpoint; std::string endpoint;
bool plugged; bool plugged;
......
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