ev_async WakeupCurl;
evcurl_global_data global;
+eNextState QueueAnDBOperation(AsyncIO *IO);
+
static void
gotstatus(int nnrun)
{
if (CURLMSG_DONE == msg->msg) {
CURL *chnd;
- char *chandle = NULL;
+ void *chandle = NULL;
CURLcode sta;
CURLMcode msta;
AsyncIO*IO;
switch(IO->SendDone(IO))
{
case eDBQuery:
+ FreeURL(&IO->ConnectMe);
+ QueueAnDBOperation(IO);
+ break;
case eSendDNSQuery:
case eReadDNSReply:
case eConnect:
{
evcurl_global_data *global = cglobal;
CURLM *mhnd = global->mhnd;
- char *f;
+ void *f;
AsyncIO *IO = (AsyncIO*) vIO;
CURLcode sta;
const char *Action;
static void QueueEventAddCallback(EV_P_ ev_async *w, int revents)
{
CitContext *Ctx;
+ long IOID = -1;
+ long count = 0;
ev_tstamp Now;
HashList *q;
void *v;
while (GetNextHashPos(q, It, &len, &Key, &v))
{
IOAddHandler *h = v;
+ count ++;
if (h->IO->ID == 0) {
h->IO->ID = EvIDSource++;
}
+ IOID = h->IO->ID;
if (h->IO->StartIO == 0.0)
h->IO->StartIO = Now;
}
DeleteHashPos(&It);
DeleteHashContent(&q);
- EVQM_syslog(LOG_DEBUG, "EVENT Q Add done.\n");
+ EVQ_syslog(LOG_DEBUG, "%s CC[%ld] EVENT Q Add %ld done.", IOSTR, IOID, count);
}
static void DBQueueEventAddCallback(EV_P_ ev_async *w, int revents)
{
CitContext *Ctx;
+ long IOID = -1;
+ long count = 0;;
ev_tstamp Now;
HashList *q;
void *v;
{
IOAddHandler *h = v;
eNextState rc;
+ count ++;
if (h->IO->ID == 0)
h->IO->ID = EvIDSource++;
+ IOID = h->IO->ID;
if (h->IO->StartDB == 0.0)
h->IO->StartDB = Now;
h->IO->Now = Now;
}
DeleteHashPos(&It);
DeleteHashContent(&q);
- EVQM_syslog(LOG_DEBUG, "DBEVENT Q Add done.\n");
+ EVQ_syslog(LOG_DEBUG, "%s CC[%ld] DBEVENT Q Add %ld done.", IOSTR, IOID, count);
}