CURL *chnd;
struct curl_slist *headers;
char errdesc[CURL_ERROR_SIZE];
+ const char *CurlError;
int attached;
/* Saving / loading a message async from / to disk */
ReadAsyncMsg *ReadMsg;
struct CtdlMessage *AsyncMsg;
- struct recptypes *AsyncRcp;
+ recptypes *AsyncRcp;
/* Context specific data; Hint: put AsyncIO in there */
void *Data; /* application specific data */
#define EDBGLOG(LEVEL) if ((LEVEL != LOG_DEBUG) || (DebugEventLoop != 0))
-#define CCID ((CitContext*)IO->CitContext)->cs_pid
+#define CCID ((CitContext*)IO->CitContext)?((CitContext*)IO->CitContext)->cs_pid:-1
#define EVQ_syslog(LEVEL, FORMAT, ...) \
EDBGLOG (LEVEL) syslog(LEVEL, "IOQ " FORMAT, __VA_ARGS__)
eNextState NextDBOperation(AsyncIO *IO, IO_CallBack CB);
eNextState QueueDBOperation(AsyncIO *IO, IO_CallBack CB);
+eNextState EventQueueDBOperation(AsyncIO *IO, IO_CallBack CB);
void StopDBWatchers(AsyncIO *IO);
eNextState QueueEventContext(AsyncIO *IO, IO_CallBack CB);
eNextState QueueCurlContext(AsyncIO *IO);
+eNextState DBQueueEventContext(AsyncIO *IO, IO_CallBack CB);
eNextState EvConnectSock(AsyncIO *IO,
double conn_timeout,
void KillAsyncIOContext(AsyncIO *IO);
void StopCurlWatchers(AsyncIO *IO);
+eNextState CurlQueueDBOperation(AsyncIO *IO, IO_CallBack CB);
eNextState ReAttachIO(AsyncIO *IO,
void *pData,