diff options
author | Martin Sustrik <sustrik@250bpm.com> | 2010-09-26 18:30:03 +0200 |
---|---|---|
committer | Martin Sustrik <sustrik@250bpm.com> | 2010-09-26 18:30:03 +0200 |
commit | cf815e8c785254d97190f223765fbbd19a1e6d52 (patch) | |
tree | 5b76f6ad2d5e71eab8491957321834b7b5183e7b /src/zmq_connecter.cpp | |
parent | be79a9fbc26a55c90b693485f69dfd17f710cb13 (diff) |
new interfaces for timers; the implementation is not changed yet
Diffstat (limited to 'src/zmq_connecter.cpp')
-rw-r--r-- | src/zmq_connecter.cpp | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/src/zmq_connecter.cpp b/src/zmq_connecter.cpp index cfca875..7cb58d3 100644 --- a/src/zmq_connecter.cpp +++ b/src/zmq_connecter.cpp @@ -42,7 +42,7 @@ zmq::zmq_connecter_t::zmq_connecter_t (class io_thread_t *io_thread_, zmq::zmq_connecter_t::~zmq_connecter_t () { if (wait) - cancel_timer (); + cancel_timer (reconnect_timer_id); if (handle_valid) rm_fd (handle); } @@ -50,7 +50,7 @@ zmq::zmq_connecter_t::~zmq_connecter_t () void zmq::zmq_connecter_t::process_plug () { if (wait) - add_timer (); + add_timer (reconnect_period, reconnect_timer_id); else start_connecting (); } @@ -73,7 +73,7 @@ void zmq::zmq_connecter_t::out_event () if (fd == retired_fd) { tcp_connecter.close (); wait = true; - add_timer (); + add_timer (reconnect_period, reconnect_timer_id); return; } @@ -121,5 +121,5 @@ void zmq::zmq_connecter_t::start_connecting () // Handle any other error condition by eventual reconnect. wait = true; - add_timer (); + add_timer (reconnect_period, reconnect_timer_id); } |