linse/sics
0
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Move "Timeout trace" in asyncqueue trace logging

Browse Source
This commit is contained in:
Douglas Clowes
2014-08-06 10:32:27 +10:00
parent bf355fb9ed
commit 08f29ef255
1 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
asyncqueue.c
View File

@ -465,11 +465,6 @@ static int CommandTimeout(void *cntx, int mode)
pAsyncQueue self = (pAsyncQueue) cntx; pAsyncQueue self = (pAsyncQueue) cntx;
pAQ_Cmd myCmd = self->command_head; pAQ_Cmd myCmd = self->command_head;
self->nw_tmr = 0; self->nw_tmr = 0;
if (myCmd->retries > 0) {
--myCmd->retries;
StartCommand(self);
} else {
int iRet;
if (self->trace) { if (self->trace) {
struct timeval tv; struct timeval tv;
gettimeofday(&tv, NULL); gettimeofday(&tv, NULL);
@ -477,6 +472,11 @@ static int CommandTimeout(void *cntx, int mode)
"Timeout Trace on AsyncQueue %s", self->queue_name); "Timeout Trace on AsyncQueue %s", self->queue_name);
SICSLogWriteHexTime(myCmd->tran->inp_buf, myCmd->tran->inp_idx, eLog, &tv); SICSLogWriteHexTime(myCmd->tran->inp_buf, myCmd->tran->inp_idx, eLog, &tv);
} }
if (myCmd->retries > 0) {
--myCmd->retries;
StartCommand(self);
} else {
int iRet;
iRet = iRet =
self->protocol->handleEvent(self->protocol, myCmd->tran, self->protocol->handleEvent(self->protocol, myCmd->tran,
AQU_TIMEOUT); AQU_TIMEOUT);