version 1.365, 2006/09/07 16:36:50
|
version 1.366, 2006/09/08 09:50:51
|
Line 2728 static int LoopForStop (AHTReqContext *m
|
Line 2728 static int LoopForStop (AHTReqContext *m
|
TtaHandleOneEvent (&msg); |
TtaHandleOneEvent (&msg); |
else |
else |
break; |
break; |
|
#ifdef IV |
if (count < 300) |
if (count < 300) |
count ++; // no more than 300 retries |
count ++; // no more than 300 retries |
else |
else |
me->reqStatus = HT_ABORT; |
me->reqStatus = HT_ABORT; |
|
#endif |
} |
} |
if (!AmayaIsAlive ()) |
if (!AmayaIsAlive ()) |
/* Amaya was killed by one of the callback handlers */ |
/* Amaya was killed by one of the callback handlers */ |
Line 2754 static int LoopForStop (AHTReqContext *m
|
Line 2756 static int LoopForStop (AHTReqContext *m
|
exit (0); |
exit (0); |
if (TtaFetchOneAvailableEvent (&ev)) |
if (TtaFetchOneAvailableEvent (&ev)) |
TtaHandleOneEvent (&ev); |
TtaHandleOneEvent (&ev); |
|
#ifdef IV |
if (count < 300) |
if (count < 300) |
count ++; // no more than 300 retries |
count ++; // no more than 300 retries |
else |
else |
me->reqStatus = HT_ABORT; |
me->reqStatus = HT_ABORT; |
|
#endif |
#ifdef _WX |
#ifdef _WX |
/* this is necessary for synchronous request*/ |
/* this is necessary for synchronous request*/ |
/* check the socket stats */ |
/* check the socket stats */ |