extern ev_async DBAddJob;
extern ev_async DBExitEventLoop;
-int QueueDBOperation(AsyncIO *IO, IO_CallBack CB)
+eNextState QueueDBOperation(AsyncIO *IO, IO_CallBack CB)
{
IOAddHandler *h;
int i;
ev_async_send (event_db, &DBAddJob);
CtdlLogPrintf(CTDL_DEBUG, "DBEVENT Q Done.\n");
- return 0;
+ return eDBQuery;
}
void ShutDownDBCLient(AsyncIO *IO)
extern ev_async ExitEventLoop;
-int QueueEventContext(AsyncIO *IO, IO_CallBack CB)
+eNextState QueueEventContext(AsyncIO *IO, IO_CallBack CB)
{
IOAddHandler *h;
int i;
ev_async_send (event_base, &AddJob);
CtdlLogPrintf(CTDL_DEBUG, "EVENT Q Done.\n");
- return 0;
+ return eSendReply;
}
int ShutDownEventQueue(void)
void FreeAsyncIOContents(AsyncIO *IO);
eNextState NextDBOperation(AsyncIO *IO, IO_CallBack CB);
-int QueueDBOperation(AsyncIO *IO, IO_CallBack CB);
-int QueueEventContext(AsyncIO *IO, IO_CallBack CB);
+eNextState QueueDBOperation(AsyncIO *IO, IO_CallBack CB);
+eNextState QueueEventContext(AsyncIO *IO, IO_CallBack CB);
int ShutDownEventQueue(void);
eNextState InitEventIO(AsyncIO *IO,