#include <sys_defs.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 stream_trigger {
int fd;
char *service;
};
static void stream_trigger_event(int event, char *context)
{
struct stream_trigger *sp = (struct stream_trigger *) context;
static const char *myname = "stream_trigger_event";
if (event == EVENT_TIME)
msg_warn("%s: read timeout for service %s", myname, sp->service);
event_disable_readwrite(sp->fd);
event_cancel_timer(stream_trigger_event, context);
if (close(sp->fd) < 0)
msg_warn("%s: close %s: %m", myname, sp->service);
myfree(sp->service);
myfree((char *) sp);
}
int stream_trigger(const char *service, const char *buf, ssize_t len, int timeout)
{
const char *myname = "stream_trigger";
struct stream_trigger *sp;
int fd;
if (msg_verbose > 1)
msg_info("%s: service %s", myname, service);
if ((fd = stream_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);
sp = (struct stream_trigger *) mymalloc(sizeof(*sp));
sp->fd = fd;
sp->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(stream_trigger_event, (char *) sp, timeout + 100);
event_enable_read(fd, stream_trigger_event, (char *) sp);
return (0);
}