#include "ctdl_module.h"
#include "event_client.h"
+#include "citserver.h"
+#include "config.h"
ConstStr IOStates[] = {
{HKEY("DB Queue")},
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
{
IO->SendBuf.fd);
fd = fopen(fn, "a+");
+ if (fd == NULL) {
+ syslog(LOG_EMERG, "failed to open file %s: %s", fn, strerror(errno));
+ cit_backtrace();
+ exit(1);
+ }
fprintf(fd, "Send: BufSize: %ld BufContent: [",
nbytes);
rv = fwrite(pchh, nbytes, 1, fd);
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);
IO->SendBuf.fd);
fd = fopen(fn, "a+");
+ if (fd == NULL) {
+ syslog(LOG_EMERG, "failed to open file %s: %s", fn, strerror(errno));
+ cit_backtrace();
+ exit(1);
+ }
fprintf(fd, "Read: BufSize: %ld BufContent: [",
nbytes);
rv = fwrite(pchh, nbytes, 1, fd);
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);
case eAbort:
//// StopClientWatchers(IO);
ShutDownCLient(IO);
+ break;
+ case eDBQuery:
+ StopClientWatchers(IO, 0);
+ QueueAnDBOperation(IO);
+ break;
default:
break;
}
+ case eDBQuery:
+ StopClientWatchers(IO, 0);
+ QueueAnDBOperation(IO);
+ break;
default:
break;
}
memset(&egress_sin, 0, sizeof(egress_sin));
egress_sin.sin_family = AF_INET;
- if (!IsEmptyStr(config.c_ip_addr)) {
- egress_sin.sin_addr.s_addr = inet_addr(config.c_ip_addr);
+ if (!IsEmptyStr(CtdlGetConfigStr("c_ip_addr"))) {
+ egress_sin.sin_addr.s_addr = inet_addr(CtdlGetConfigStr("c_ip_addr"));
if (egress_sin.sin_addr.s_addr == !INADDR_ANY) {
egress_sin.sin_addr.s_addr = INADDR_ANY;
}