AsyncIO *IO = watcher->data;
SetEVState(IO, eDBNext);
- IO->Now = ev_now(event_db);
+ SET_EV_TIME(IO, event_db);
EV_syslog(LOG_DEBUG, "%s()", __FUNCTION__);
become_session(IO->CitContext);
SetEVState(IO, eIOAbort);
EV_syslog(LOG_DEBUG, "EVENT Q: %s\n", __FUNCTION__);
- IO->Now = ev_now(event_base);
+ SET_EV_TIME(IO, event_base);
assert(IO->ShutdownAbort);
IO->ShutdownAbort(IO);
}
AsyncIO *IO = watcher->data;
const char *errmsg = NULL;
- IO->Now = ev_now(event_base);
+ SET_EV_TIME(IO, event_base);
become_session(IO->CitContext);
#ifdef BIGBAD_IODBG
{
AsyncIO *IO = watcher->data;
SetEVState(IO, eIOTimeout);
- IO->Now = ev_now(event_base);
+ SET_EV_TIME(IO, event_base);
ev_timer_stop (event_base, &IO->rw_timeout);
become_session(IO->CitContext);
AsyncIO *IO = watcher->data;
SetEVState(IO, eIOConnfail);
- 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)
AsyncIO *IO = watcher->data;
SetEVState(IO, eIOConnfailNow);
- 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)
int err;
SetEVState(IO, eIOConnNow);
- 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);
ssize_t nbytes;
AsyncIO *IO = watcher->data;
- IO->Now = ev_now(event_base);
+ SET_EV_TIME(IO, event_base);
switch (IO->NextState) {
case eReadFile:
nbytes = FileRecvChunked(&IO->IOB, &errmsg);
AsyncIO *IO = watcher->data;
SetEVState(IO, eCaresFinished);
- 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);