Commit ca87aaed authored by Simon Giesecke's avatar Simon Giesecke

Problem: ipc_connector_t::_timer_started is unspecifically named

Solution: rename to _reconnect_timer_started
parent c94ad648
...@@ -62,7 +62,7 @@ zmq::ipc_connecter_t::ipc_connecter_t (class io_thread_t *io_thread_, ...@@ -62,7 +62,7 @@ zmq::ipc_connecter_t::ipc_connecter_t (class io_thread_t *io_thread_,
_s (retired_fd), _s (retired_fd),
_handle_valid (false), _handle_valid (false),
_delayed_start (delayed_start_), _delayed_start (delayed_start_),
_timer_started (false), _reconnect_timer_started (false),
_session (session_), _session (session_),
_current_reconnect_ivl (options.reconnect_ivl) _current_reconnect_ivl (options.reconnect_ivl)
{ {
...@@ -74,7 +74,7 @@ zmq::ipc_connecter_t::ipc_connecter_t (class io_thread_t *io_thread_, ...@@ -74,7 +74,7 @@ zmq::ipc_connecter_t::ipc_connecter_t (class io_thread_t *io_thread_,
zmq::ipc_connecter_t::~ipc_connecter_t () zmq::ipc_connecter_t::~ipc_connecter_t ()
{ {
zmq_assert (!_timer_started); zmq_assert (!_reconnect_timer_started);
zmq_assert (!_handle_valid); zmq_assert (!_handle_valid);
zmq_assert (_s == retired_fd); zmq_assert (_s == retired_fd);
} }
...@@ -89,9 +89,9 @@ void zmq::ipc_connecter_t::process_plug () ...@@ -89,9 +89,9 @@ void zmq::ipc_connecter_t::process_plug ()
void zmq::ipc_connecter_t::process_term (int linger_) void zmq::ipc_connecter_t::process_term (int linger_)
{ {
if (_timer_started) { if (_reconnect_timer_started) {
cancel_timer (reconnect_timer_id); cancel_timer (reconnect_timer_id);
_timer_started = false; _reconnect_timer_started = false;
} }
if (_handle_valid) { if (_handle_valid) {
...@@ -142,7 +142,7 @@ void zmq::ipc_connecter_t::out_event () ...@@ -142,7 +142,7 @@ void zmq::ipc_connecter_t::out_event ()
void zmq::ipc_connecter_t::timer_event (int id_) void zmq::ipc_connecter_t::timer_event (int id_)
{ {
zmq_assert (id_ == reconnect_timer_id); zmq_assert (id_ == reconnect_timer_id);
_timer_started = false; _reconnect_timer_started = false;
start_connecting (); start_connecting ();
} }
...@@ -180,7 +180,7 @@ void zmq::ipc_connecter_t::add_reconnect_timer () ...@@ -180,7 +180,7 @@ void zmq::ipc_connecter_t::add_reconnect_timer ()
int rc_ivl = get_new_reconnect_ivl (); int rc_ivl = get_new_reconnect_ivl ();
add_timer (rc_ivl, reconnect_timer_id); add_timer (rc_ivl, reconnect_timer_id);
_socket->event_connect_retried (_endpoint, rc_ivl); _socket->event_connect_retried (_endpoint, rc_ivl);
_timer_started = true; _reconnect_timer_started = true;
} }
} }
......
...@@ -112,7 +112,7 @@ class ipc_connecter_t : public own_t, public io_object_t ...@@ -112,7 +112,7 @@ class ipc_connecter_t : public own_t, public io_object_t
const bool _delayed_start; const bool _delayed_start;
// True iff a timer has been started. // True iff a timer has been started.
bool _timer_started; bool _reconnect_timer_started;
// Reference to the session we belong to. // Reference to the session we belong to.
zmq::session_base_t *_session; zmq::session_base_t *_session;
......
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