case eSendMore:
assert(IO->SendDone);
IO->NextState = IO->SendDone(IO);
- ev_io_start(event_base, &IO->send_event);
+ switch (IO->NextState)
+ {
+ case eSendFile:
+ case eSendReply:
+ case eSendMore:
+ case eReadMessage:
+ case eReadPayload:
+ case eReadMore:
+ case eReadFile:
+ ev_io_start(event_base, &IO->send_event);
+ break;
+ case eDBQuery:
+ StopClientWatchers(IO, 0);
+ default:
+ break;
+ }
break;
case eReadPayload:
case eReadMore:
IO->Data = Data;
IO->CitContext = CloneContext(CC);
- IO->CitContext->session_specific_data = (char*) Data;
+ IO->CitContext->session_specific_data = Data;
IO->CitContext->IO = IO;
IO->NextState = NextState;
IO->Data = Data;
IO->CitContext = CloneContext(CC);
- IO->CitContext->session_specific_data = (char*) Data;
+ IO->CitContext->session_specific_data = Data;
IO->CitContext->IO = IO;
IO->SendDone = SendDone;
eNextState KillTerminate(AsyncIO *IO)
{
+ long id;
KillOtherSessionContext *Ctx = (KillOtherSessionContext*)IO->Data;
EV_syslog(LOG_DEBUG, "%s Exit\n", __FUNCTION__);
+ id = IO->ID;
FreeAsyncIOContents(IO);
memset(Ctx, 0, sizeof(KillOtherSessionContext));
+ IO->ID = id; /* just for the case we want to analyze it in a coredump */
free(Ctx);
return eAbort;