#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 pass_trigger {
int connect_fd;
char *service;
int pass_fd[2];
};
static void pass_trigger_event(int event, void *context)
{
struct pass_trigger *pp = (struct pass_trigger *) context;
static const char *myname = "pass_trigger_event";
if (event == EVENT_TIME)
msg_warn("%s: read timeout for service %s", myname, pp->service);
event_disable_readwrite(pp->connect_fd);
event_cancel_timer(pass_trigger_event, context);
if (close(pp->connect_fd) < 0)
msg_warn("%s: close %s: %m", myname, pp->service);
if (close(pp->pass_fd[0]) < 0)
msg_warn("%s: close pipe: %m", myname);
if (close(pp->pass_fd[1]) < 0)
msg_warn("%s: close pipe: %m", myname);
myfree(pp->service);
myfree((void *) pp);
}
int pass_trigger(const char *service, const char *buf, ssize_t len, int timeout)
{
const char *myname = "pass_trigger";
int pass_fd[2];
struct pass_trigger *pp;
int connect_fd;
if (msg_verbose > 1)
msg_info("%s: service %s", myname, service);
if ((connect_fd = LOCAL_CONNECT(service, BLOCKING, timeout)) < 0) {
if (msg_verbose)
msg_warn("%s: connect to %s: %m", myname, service);
return (-1);
}
close_on_exec(connect_fd, CLOSE_ON_EXEC);
if (pipe(pass_fd) < 0)
msg_fatal("%s: pipe: %m", myname);
close_on_exec(pass_fd[0], CLOSE_ON_EXEC);
close_on_exec(pass_fd[1], CLOSE_ON_EXEC);
if (LOCAL_SEND_FD(connect_fd, pass_fd[0]) < 0)
msg_fatal("%s: send file descriptor: %m", myname);
pp = (struct pass_trigger *) mymalloc(sizeof(*pp));
pp->connect_fd = connect_fd;
pp->service = mystrdup(service);
pp->pass_fd[0] = pass_fd[0];
pp->pass_fd[1] = pass_fd[1];
if (write_buf(pass_fd[1], buf, len, timeout) < 0
|| write_buf(pass_fd[1], "", 1, timeout) < 0)
if (msg_verbose)
msg_warn("%s: write to %s: %m", myname, service);
if (timeout > 0)
event_request_timer(pass_trigger_event, (void *) pp, timeout + 100);
event_enable_read(connect_fd, pass_trigger_event, (void *) pp);
return (0);
}