Skip to content

Commit

Permalink
Merge pull request #179 from bluca/backport
Browse files Browse the repository at this point in the history
Backport fixes from libzmq
  • Loading branch information
somdoron authored Aug 30, 2020
2 parents c9894a4 + 2fb9c40 commit 13d2709
Show file tree
Hide file tree
Showing 18 changed files with 487 additions and 310 deletions.
4 changes: 4 additions & 0 deletions src/i_engine.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -41,6 +41,10 @@ namespace zmq
{
virtual ~i_engine () {}

// Indicate if the engine has an handshake stage.
// If engine has handshake stage, engine must call session.engine_ready when the handshake is complete.
virtual bool has_handshake_stage () = 0;

// Plug the engine to the session.
virtual void plug (zmq::io_thread_t *io_thread_,
class session_base_t *session_) = 0;
Expand Down
2 changes: 1 addition & 1 deletion src/ipc_connecter.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -123,7 +123,7 @@ void zmq::ipc_connecter_t::out_event ()
}
// Create the engine object for this connection.
stream_engine_t *engine = new (std::nothrow)
stream_engine_t (fd, options, endpoint);
stream_engine_t (fd, options, endpoint, !options.raw_sock);
alloc_assert (engine);

// Attach the engine to the corresponding session object.
Expand Down
2 changes: 1 addition & 1 deletion src/ipc_listener.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -102,7 +102,7 @@ void zmq::ipc_listener_t::in_event ()

// Create the engine object for this connection.
stream_engine_t *engine = new (std::nothrow)
stream_engine_t (fd, options, endpoint);
stream_engine_t (fd, options, endpoint, !options.raw_sock);
alloc_assert (engine);

// Choose I/O thread to run connecter in. Given that we are already
Expand Down
Loading

0 comments on commit 13d2709

Please sign in to comment.