projects
/
citadel.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Assert that we don't always have a valid session.
[citadel.git]
/
citadel
/
event_client.c
diff --git
a/citadel/event_client.c
b/citadel/event_client.c
index fad9eefeccaa5dea30651ba65cc482a1baa19d65..4ab63a4a292bbd1edb08e490b195698d75decddf 100644
(file)
--- a/
citadel/event_client.c
+++ b/
citadel/event_client.c
@@
-157,7
+157,7
@@
DB_PerformNext(struct ev_loop *loop, ev_idle *watcher, int revents)
AsyncIO *IO = watcher->data;
SetEVState(IO, eDBNext);
AsyncIO *IO = watcher->data;
SetEVState(IO, eDBNext);
-
IO->CitContext->lastcmd = IO->Now = ev_now(
event_db);
+
SET_EV_TIME(IO,
event_db);
EV_syslog(LOG_DEBUG, "%s()", __FUNCTION__);
become_session(IO->CitContext);
EV_syslog(LOG_DEBUG, "%s()", __FUNCTION__);
become_session(IO->CitContext);
@@
-221,7
+221,7
@@
static void IO_abort_shutdown_callback(struct ev_loop *loop,
SetEVState(IO, eIOAbort);
EV_syslog(LOG_DEBUG, "EVENT Q: %s\n", __FUNCTION__);
SetEVState(IO, eIOAbort);
EV_syslog(LOG_DEBUG, "EVENT Q: %s\n", __FUNCTION__);
-
IO->CitContext->lastcmd = IO->Now = ev_now(
event_base);
+
SET_EV_TIME(IO,
event_base);
assert(IO->ShutdownAbort);
IO->ShutdownAbort(IO);
}
assert(IO->ShutdownAbort);
IO->ShutdownAbort(IO);
}
@@
-544,7
+544,7
@@
IO_send_callback(struct ev_loop *loop, ev_io *watcher, int revents)
AsyncIO *IO = watcher->data;
const char *errmsg = NULL;
AsyncIO *IO = watcher->data;
const char *errmsg = NULL;
-
IO->CitContext->lastcmd = IO->Now = ev_now(
event_base);
+
SET_EV_TIME(IO,
event_base);
become_session(IO->CitContext);
#ifdef BIGBAD_IODBG
{
become_session(IO->CitContext);
#ifdef BIGBAD_IODBG
{
@@
-721,7
+721,7
@@
IO_Timeout_callback(struct ev_loop *loop, ev_timer *watcher, int revents)
AsyncIO *IO = watcher->data;
SetEVState(IO, eIOTimeout);
AsyncIO *IO = watcher->data;
SetEVState(IO, eIOTimeout);
-
IO->CitContext->lastcmd = IO->Now = ev_now(
event_base);
+
SET_EV_TIME(IO,
event_base);
ev_timer_stop (event_base, &IO->rw_timeout);
become_session(IO->CitContext);
ev_timer_stop (event_base, &IO->rw_timeout);
become_session(IO->CitContext);
@@
-750,7
+750,7
@@
IO_connfail_callback(struct ev_loop *loop, ev_timer *watcher, int revents)
AsyncIO *IO = watcher->data;
SetEVState(IO, eIOConnfail);
AsyncIO *IO = watcher->data;
SetEVState(IO, eIOConnfail);
-
IO->CitContext->lastcmd = IO->Now = ev_now(
event_base);
+
SET_EV_TIME(IO,
event_base);
ev_timer_stop (event_base, &IO->conn_fail);
if (IO->SendBuf.fd != 0)
ev_timer_stop (event_base, &IO->conn_fail);
if (IO->SendBuf.fd != 0)
@@
-783,7
+783,7
@@
IO_connfailimmediate_callback(struct ev_loop *loop,
AsyncIO *IO = watcher->data;
SetEVState(IO, eIOConnfailNow);
AsyncIO *IO = watcher->data;
SetEVState(IO, eIOConnfailNow);
-
IO->CitContext->lastcmd = IO->Now = ev_now(
event_base);
+
SET_EV_TIME(IO,
event_base);
ev_idle_stop (event_base, &IO->conn_fail_immediate);
if (IO->SendBuf.fd != 0)
ev_idle_stop (event_base, &IO->conn_fail_immediate);
if (IO->SendBuf.fd != 0)
@@
-813,7
+813,7
@@
IO_connestd_callback(struct ev_loop *loop, ev_io *watcher, int revents)
int err;
SetEVState(IO, eIOConnNow);
int err;
SetEVState(IO, eIOConnNow);
-
IO->CitContext->lastcmd = IO->Now = ev_now(
event_base);
+
SET_EV_TIME(IO,
event_base);
EVM_syslog(LOG_DEBUG, "connect() succeeded.\n");
ev_io_stop(loop, &IO->conn_event);
EVM_syslog(LOG_DEBUG, "connect() succeeded.\n");
ev_io_stop(loop, &IO->conn_event);
@@
-847,7
+847,7
@@
IO_recv_callback(struct ev_loop *loop, ev_io *watcher, int revents)
ssize_t nbytes;
AsyncIO *IO = watcher->data;
ssize_t nbytes;
AsyncIO *IO = watcher->data;
-
IO->CitContext->lastcmd = IO->Now = ev_now(
event_base);
+
SET_EV_TIME(IO,
event_base);
switch (IO->NextState) {
case eReadFile:
nbytes = FileRecvChunked(&IO->IOB, &errmsg);
switch (IO->NextState) {
case eReadFile:
nbytes = FileRecvChunked(&IO->IOB, &errmsg);
@@
-933,7
+933,7
@@
IO_postdns_callback(struct ev_loop *loop, ev_idle *watcher, int revents)
AsyncIO *IO = watcher->data;
SetEVState(IO, eCaresFinished);
AsyncIO *IO = watcher->data;
SetEVState(IO, eCaresFinished);
-
IO->CitContext->lastcmd = IO->Now = ev_now(
event_base);
+
SET_EV_TIME(IO,
event_base);
EV_syslog(LOG_DEBUG, "event: %s\n", __FUNCTION__);
become_session(IO->CitContext);
assert(IO->DNS.Query->PostDNS);
EV_syslog(LOG_DEBUG, "event: %s\n", __FUNCTION__);
become_session(IO->CitContext);
assert(IO->DNS.Query->PostDNS);