From d6f72482b370deea8f9e68e50614a404834ccf74 Mon Sep 17 00:00:00 2001 From: Douglas Clowes Date: Thu, 6 Jun 2013 15:45:04 +1000 Subject: [PATCH] change state to connected before notify callback for connect --- asyncqueue.c | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/asyncqueue.c b/asyncqueue.c index e258feb2..fedc9c84 100644 --- a/asyncqueue.c +++ b/asyncqueue.c @@ -178,13 +178,13 @@ static int TimedReconnect(void *cntx, int mode) self->queue_name, __func__, state_name(self->state)); self->state = eAsyncConnecting; } else { - snprintf(line, 132, "Reconnect on AsyncQueue '%s'", self->queue_name); - SICSLogWrite(line, eStatus); - AQ_Notify(self, AQU_RECONNECT); NetWatchSetMode(self->nw_ctx, nwatch_read); SICSLogPrintf(eStatus, "In %s:%s: state %s => eAsyncConnected\n", self->queue_name, __func__, state_name(self->state)); self->state = eAsyncConnected; + snprintf(line, 132, "Reconnect on AsyncQueue '%s'", self->queue_name); + SICSLogWrite(line, eStatus); + AQ_Notify(self, AQU_RECONNECT); } return 1; }