projects
/
citadel.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Mostly we should happen to add one IO context, output its id.
[citadel.git]
/
citadel
/
modules
/
eventclient
/
serv_eventclient.c
diff --git
a/citadel/modules/eventclient/serv_eventclient.c
b/citadel/modules/eventclient/serv_eventclient.c
index 04e1938e9919881a578e9d8b8d46ddd564f80df8..4a27c2482effb42bd47f7cbb99054218d58e63c8 100644
(file)
--- a/
citadel/modules/eventclient/serv_eventclient.c
+++ b/
citadel/modules/eventclient/serv_eventclient.c
@@
-611,6
+611,8
@@
ev_async ExitEventLoop;
static void QueueEventAddCallback(EV_P_ ev_async *w, int revents)
{
CitContext *Ctx;
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;
ev_tstamp Now;
HashList *q;
void *v;
@@
-635,9
+637,11
@@
static void QueueEventAddCallback(EV_P_ ev_async *w, int revents)
while (GetNextHashPos(q, It, &len, &Key, &v))
{
IOAddHandler *h = v;
while (GetNextHashPos(q, It, &len, &Key, &v))
{
IOAddHandler *h = v;
+ count ++;
if (h->IO->ID == 0) {
h->IO->ID = EvIDSource++;
}
if (h->IO->ID == 0) {
h->IO->ID = EvIDSource++;
}
+ IOID = h->IO->ID;
if (h->IO->StartIO == 0.0)
h->IO->StartIO = Now;
if (h->IO->StartIO == 0.0)
h->IO->StartIO = Now;
@@
-669,7
+673,7
@@
static void QueueEventAddCallback(EV_P_ ev_async *w, int revents)
}
DeleteHashPos(&It);
DeleteHashContent(&q);
}
DeleteHashPos(&It);
DeleteHashContent(&q);
- EVQ
M_syslog(LOG_DEBUG, "EVENT Q Add done.\n"
);
+ EVQ
_syslog(LOG_DEBUG, "%s CC[%ld] EVENT Q Add %ld done.", IOSTR, IOID, count
);
}
}
@@
-762,6
+766,8
@@
extern void ShutDownDBCLient(AsyncIO *IO);
static void DBQueueEventAddCallback(EV_P_ ev_async *w, int revents)
{
CitContext *Ctx;
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;
ev_tstamp Now;
HashList *q;
void *v;
@@
-788,8
+794,10
@@
static void DBQueueEventAddCallback(EV_P_ ev_async *w, int revents)
{
IOAddHandler *h = v;
eNextState rc;
{
IOAddHandler *h = v;
eNextState rc;
+ count ++;
if (h->IO->ID == 0)
h->IO->ID = EvIDSource++;
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;
if (h->IO->StartDB == 0.0)
h->IO->StartDB = Now;
h->IO->Now = Now;
@@
-809,7
+817,7
@@
static void DBQueueEventAddCallback(EV_P_ ev_async *w, int revents)
}
DeleteHashPos(&It);
DeleteHashContent(&q);
}
DeleteHashPos(&It);
DeleteHashContent(&q);
- EVQ
M_syslog(LOG_DEBUG, "DBEVENT Q Add done.\n"
);
+ EVQ
_syslog(LOG_DEBUG, "%s CC[%ld] DBEVENT Q Add %ld done.", IOSTR, IOID, count
);
}
}