#include <sys_defs.h>
#include <sys/socket.h>
#include <unistd.h>
#include <string.h>
#include <msg.h>
#include <connect.h>
#include <iostuff.h>
#include <mymalloc.h>
#include <events.h>
#include <trigger.h>
struct unix_trigger {
int fd;
char *service;
};
static void unix_trigger_event(int event, char *context)
{
struct unix_trigger *up = (struct unix_trigger *) context;
static const char *myname = "unix_trigger_event";
if (event == EVENT_TIME)
msg_warn("%s: read timeout for service %s", myname, up->service);
event_disable_readwrite(up->fd);
event_cancel_timer(unix_trigger_event, context);
if (close(up->fd) < 0)
msg_warn("%s: close %s: %m", myname, up->service);
myfree(up->service);
myfree((char *) up);
}
int unix_trigger(const char *service, const char *buf, ssize_t len, int timeout)
{
const char *myname = "unix_trigger";
struct unix_trigger *up;
int fd;
if (msg_verbose > 1)
msg_info("%s: service %s", myname, service);
if ((fd = unix_connect(service, BLOCKING, timeout)) < 0) {
if (msg_verbose)
msg_warn("%s: connect to %s: %m", myname, service);
return (-1);
}
close_on_exec(fd, CLOSE_ON_EXEC);
up = (struct unix_trigger *) mymalloc(sizeof(*up));
up->fd = fd;
up->service = mystrdup(service);
if (write_buf(fd, buf, len, timeout) < 0
|| write_buf(fd, "", 1, timeout) < 0)
if (msg_verbose)
msg_warn("%s: write to %s: %m", myname, service);
if (timeout > 0)
event_request_timer(unix_trigger_event, (char *) up, timeout + 100);
event_enable_read(fd, unix_trigger_event, (char *) up);
return (0);
}