|
|
@ -21,6 +21,9 @@ disconnectCallback(const redisAsyncContext *c, int status) {
|
|
|
|
printf("disconnected, schedule reconnect.\n");
|
|
|
|
printf("disconnected, schedule reconnect.\n");
|
|
|
|
s->ac = NULL;
|
|
|
|
s->ac = NULL;
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/* wait 10 msec and reconnect */
|
|
|
|
|
|
|
|
s->tv_reconnect.tv_sec = 0;
|
|
|
|
|
|
|
|
s->tv_reconnect.tv_usec = 100000;
|
|
|
|
dishy_connect(s);
|
|
|
|
dishy_connect(s);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
@ -64,8 +67,6 @@ dishy_connect(struct server *s) {
|
|
|
|
/* schedule reconnect */
|
|
|
|
/* schedule reconnect */
|
|
|
|
evtimer_set(&s->ev_reconnect, on_timer_reconnect, s);
|
|
|
|
evtimer_set(&s->ev_reconnect, on_timer_reconnect, s);
|
|
|
|
event_base_set(s->base, &s->ev_reconnect);
|
|
|
|
event_base_set(s->base, &s->ev_reconnect);
|
|
|
|
s->tv_reconnect.tv_sec = 1;
|
|
|
|
|
|
|
|
s->tv_reconnect.tv_usec = 0;
|
|
|
|
|
|
|
|
evtimer_add(&s->ev_reconnect, &s->tv_reconnect);
|
|
|
|
evtimer_add(&s->ev_reconnect, &s->tv_reconnect);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|