diff options
| -rw-r--r-- | plugin_fifo.c | 39 |
1 files changed, 26 insertions, 13 deletions
diff --git a/plugin_fifo.c b/plugin_fifo.c index f8be4c8..3a41e04 100644 --- a/plugin_fifo.c +++ b/plugin_fifo.c @@ -149,11 +149,37 @@ static int openFifo() } +static void startFifo(void) +{ + static int started = 0; + + if (started) + return; + + started = 1; + + configure_fifo(); + fd.path = fifopath; + fd.input = -1; + fd.created = 0; + openFifo(); + + /* ignore broken pipe */ + signal(SIGPIPE, SIG_IGN); + + memset(msg, 0, FIFO_BUFFER_SIZE); + +} + + static void fiforead(RESULT * result) { char buf[FIFO_BUFFER_SIZE]; unsigned int i; int bytes = 1; + + startFifo(); + memset(buf, 0, FIFO_BUFFER_SIZE); strcat(buf, "ERROR"); @@ -184,18 +210,6 @@ static void fiforead(RESULT * result) /* plugin initialization */ int plugin_init_fifo(void) { - configure_fifo(); - fd.path = fifopath; - fd.input = -1; - fd.created = 0; - if (openFifo() < 0) { - return -1; - } - - /* ignore broken pipe */ - signal(SIGPIPE, SIG_IGN); - - memset(msg, 0, FIFO_BUFFER_SIZE); AddFunction("fifo::read", 0, fiforead); return 0; } @@ -203,7 +217,6 @@ int plugin_init_fifo(void) void plugin_exit_fifo(void) { - /* close filedescriptors */ closeFifo(); } |