X-Git-Url: https://code.citadel.org/?p=citadel.git;a=blobdiff_plain;f=citadel%2Fevent_client.c;fp=citadel%2Fevent_client.c;h=999c9e4546c1b989efc6fb93c6f6ab8df8394b8f;hp=3e2cbdccaadea3eeb711acf13b2e2ceee6551ef1;hb=8357d67fb22adec3b854d61bdbd898dcfcc91959;hpb=19576adee6e0a5fb959f8506eb68e31be590fe94 diff --git a/citadel/event_client.c b/citadel/event_client.c index 3e2cbdcca..999c9e454 100644 --- a/citadel/event_client.c +++ b/citadel/event_client.c @@ -26,6 +26,7 @@ #include "ctdl_module.h" #include "event_client.h" +#include "citserver.h" ConstStr IOStates[] = { {HKEY("DB Queue")}, @@ -562,6 +563,11 @@ IO_send_callback(struct ev_loop *loop, ev_io *watcher, int revents) 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); @@ -885,6 +891,11 @@ IO_recv_callback(struct ev_loop *loop, ev_io *watcher, int revents) 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);