summaryrefslogtreecommitdiff
path: root/src/zmq_connecter.cpp
diff options
context:
space:
mode:
authorMartin Sustrik <sustrik@250bpm.com>2010-09-26 18:30:03 +0200
committerMartin Sustrik <sustrik@250bpm.com>2010-09-26 18:30:03 +0200
commitcf815e8c785254d97190f223765fbbd19a1e6d52 (patch)
tree5b76f6ad2d5e71eab8491957321834b7b5183e7b /src/zmq_connecter.cpp
parentbe79a9fbc26a55c90b693485f69dfd17f710cb13 (diff)
new interfaces for timers; the implementation is not changed yet
Diffstat (limited to 'src/zmq_connecter.cpp')
-rw-r--r--src/zmq_connecter.cpp8
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);
}