typedef enum _eNextState {
eSendDNSQuery,
eReadDNSReply,
+
eDBQuery,
+
eConnect,
eSendReply,
eSendMore,
+ eSendFile,
+
eReadMessage,
eReadMore,
eReadPayload,
+ eReadFile,
+
eTerminateConnection,
eAbort
}eNextState;
IOBuffer SendBuf,
RecvBuf;
+ FDIOBuffer IOB; /* when sending from / reading into files, this is used. */
+
/* our events... */
ev_cleanup abort_by_shutdown, /* server wants to go down... */
db_abort_by_shutdown; /* server wants to go down... */
eNextState NextDBOperation(AsyncIO *IO, IO_CallBack CB);
eNextState QueueDBOperation(AsyncIO *IO, IO_CallBack CB);
eNextState QueueEventContext(AsyncIO *IO, IO_CallBack CB);
+eNextState QueueCurlContext(AsyncIO *IO);
int ShutDownEventQueue(void);
eNextState InitEventIO(AsyncIO *IO,
void *pData,
int ReadFirst);
-void evcurl_handle_start(AsyncIO *IO);
-
#endif /* __EVENT_CLIENT_H__ */