finalize allocation & freeing of rss stuff

[citadel.git] / citadel / event_client.h

diff --git a/citadel/event_client.h b/citadel/event_client.h
index 8647fdde43720722de033bd6356932eaac566dc8..5939ad914ce96db005e862437ab3f83220d02ec7 100644 (file)
--- a/citadel/event_client.h
+++ b/citadel/event_client.h
@@ -1,3 +1,4 @@
+#define EV_COMPAT3 0
 #include <ev.h>
 #include <sys/types.h>
 #include <sys/socket.h>
@@ -36,15 +37,18 @@ typedef struct _DNSQueryParts {
 
 typedef struct _evcurl_request_data 
 {
-       CURL *chnd;
-       char errdesc[CURL_ERROR_SIZE];
-       int attached;
-       char* PlainPostData;
-       long PlainPostDataLen;
-       StrBuf *PostData;
-       StrBuf *ReplyData;
-///    ParsedURL *URL; /// take from AsyncIO->ConnectMe
-       struct curl_slist * headers;
+       CURL              *chnd;
+       struct curl_slist *headers;
+       char               errdesc[CURL_ERROR_SIZE];
+
+       int                attached;
+
+       char              *PlainPostData;
+       long               PlainPostDataLen;
+       StrBuf            *PostData;
+
+       StrBuf            *ReplyData;
+       long               httpcode;
 } evcurl_request_data;
 
 struct AsyncIO {
@@ -62,7 +66,8 @@ struct AsyncIO {
        ev_cleanup abort_by_shutdown; /* server wants to go down... */
        ev_timer conn_fail,           /* connection establishing timed out */
                rw_timeout;           /* timeout while sending data */
-       ev_idle unwind_stack;         /* get c-ares out of the stack */
+       ev_idle unwind_stack,         /* get c-ares out of the stack */
+               conn_fail_immediate;  /* unwind stack, but fail immediately. */
        ev_io recv_event,             /* receive data from the client */
                send_event,           /* send more data to the client */
                conn_event;           /* Connection successfully established */
@@ -88,6 +93,10 @@ struct AsyncIO {
        
        evcurl_request_data HttpReq;
 
+       /* Saving / loading a message async from / to disk */
+
+       struct CtdlMessage *AsyncMsg;
+       struct recptypes *AsyncRcp;
        /* Custom data; its expected to contain  AsyncIO so we can save malloc()s... */
        void *Data;        /* application specific data */
        void *CitContext;  /* Citadel Session context... */
@@ -100,6 +109,8 @@ typedef struct _IOAddHandler {
 
 void FreeAsyncIOContents(AsyncIO *IO);
 
+void NextDBOperation(AsyncIO *IO, IO_CallBack CB);
+int QueueDBOperation(AsyncIO *IO, IO_CallBack CB);
 int QueueEventContext(AsyncIO *IO, IO_CallBack CB);
 int ShutDownEventQueue(void);
 
@@ -136,6 +147,7 @@ void InitC_ares_dns(AsyncIO *IO);
 int evcurl_init(AsyncIO *IO, 
                void *CustomData, 
                const char* Desc,
-               int CallBack);
+               IO_CallBack CallBack, 
+               IO_CallBack Terminate);
 
 void evcurl_handle_start(AsyncIO *IO);