X-Git-Url: https://code.citadel.org/?p=citadel.git;a=blobdiff_plain;f=citadel%2Fevent_client.c;h=57a6440102f12ca86d58b83aba96c0f1d1ad76f7;hp=2fc22de8c600eecf3bafbe315c8f40b5a549e6e8;hb=192056a6112602350c1f8a73eae2e134a31c7ba2;hpb=e83d78b9d9bd2d5ad7b440fd6bc01efae2ad8cf6

diff --git a/citadel/event_client.c b/citadel/event_client.c
index 2fc22de8c..57a644010 100644
--- a/citadel/event_client.c
+++ b/citadel/event_client.c
@@ -203,6 +203,28 @@ eNextState QueueEventContext(AsyncIO *IO, IO_CallBack CB)
 	return eSendReply;
 }
 
+extern eNextState evcurl_handle_start(AsyncIO *IO);
+
+eNextState QueueCurlContext(AsyncIO *IO)
+{
+	IOAddHandler *h;
+	int i;
+
+	h = (IOAddHandler*)malloc(sizeof(IOAddHandler));
+	h->IO = IO;
+	h->EvAttch = evcurl_handle_start;
+
+	pthread_mutex_lock(&EventQueueMutex);
+	syslog(LOG_DEBUG, "EVENT Q\n");
+	i = ++evbase_count;
+	Put(InboundEventQueue, IKEY(i), h, NULL);
+	pthread_mutex_unlock(&EventQueueMutex);
+
+	ev_async_send (event_base, &AddJob);
+	syslog(LOG_DEBUG, "EVENT Q Done.\n");
+	return eSendReply;
+}
+
 int ShutDownEventQueue(void)
 {
 	pthread_mutex_lock(&DBEventQueueMutex);