1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180
|
/* $Id: xio-pipe.c,v 1.19 2005/09/03 16:51:36 gerhard Exp $ */
/* Copyright Gerhard Rieger 2001-2005 */
/* Published under the GNU General Public License V.2, see file COPYING */
/* this file contains the source for opening addresses of pipe type */
#include "xiosysincludes.h"
#include "xioopen.h"
#include "xio-named.h"
#if WITH_PIPE
static int xioopen_fifo(char *a1, int rw, xiofile_t *fd, unsigned groups, int dummy1, int dummy2, void *dummyp1);
const struct addrdesc addr_pipe = { "pipe", 3, xioopen_fifo, GROUP_FD|GROUP_NAMED|GROUP_OPEN|GROUP_FIFO, 0, 0, NULL HELP(":<filename>") };
/* process an unnamed bidirectional "pipe" or "fifo" or "echo" argument with
options */
int xioopen_fifo_unnamed(char *arg, xiofile_t *sock) {
struct opt *opts = NULL, *opts2;
int filedes[2];
char *b;
int numleft;
int result;
/* keep groups consistent with help! */
if (parseopts(arg, GROUP_FD|GROUP_FIFO, &opts) < 0)
return STAT_NORETRY;
applyopts(-1, opts, PH_INIT);
if (applyopts_single(&sock->stream, opts, PH_INIT) < 0) return -1;
if (Pipe(filedes) != 0) {
Error2("pipe(%p): %s", filedes, strerror(errno));
return -1;
}
/*0 Info2("pipe({%d,%d})", filedes[0], filedes[1]);*/
sock->common.tag = XIO_TAG_RDWR;
sock->stream.dtype = DATA_PIPE;
sock->stream.fd = filedes[0];
sock->stream.para.bipipe.fdout = filedes[1];
if ((b = strdup(arg)) == NULL) {
Error1("strdup("F_Zu"): out of memory", strlen(arg)+1);
return -1;
}
applyopts_cloexec(sock->stream.fd, opts);
applyopts_cloexec(sock->stream.para.bipipe.fdout, opts);
/* one-time and input-direction options, no second application */
retropt_bool(opts, OPT_IGNOREEOF, &sock->stream.ignoreeof);
/* here we copy opts! */
if ((opts2 = copyopts(opts, GROUP_FIFO)) == NULL) {
return STAT_NORETRY;
}
/* apply options to first FD */
if ((result = applyopts(sock->stream.fd, opts, PH_ALL)) < 0) {
return result;
}
if ((result = applyopts_single(&sock->stream, opts, PH_ALL)) < 0) {
return result;
}
/* apply options to second FD */
if ((result = applyopts(sock->stream.para.bipipe.fdout, opts2, PH_ALL)) < 0)
{
return result;
}
if ((numleft = leftopts(opts)) > 0) {
Error1("%d option(s) could not be used", numleft);
showleft(opts);
}
Notice("writing to and reading from unnamed pipe");
return 0;
}
/* open a named pipe/fifo */
static int xioopen_fifo(char *a1, int xioflags, xiofile_t *fd, unsigned groups, int dummy1, int dummy2, void *dummyp1) {
int rw = (xioflags & XIO_ACCMODE);
struct opt *opts = NULL;
#if HAVE_STAT64
struct stat64 pipstat;
#else
struct stat pipstat;
#endif /* !HAVE_STAT64 */
bool opt_unlink_early = false;
bool opt_unlink_close = true;
mode_t mode = 0666;
int result;
char *a2;
a2 = strchr(a1, ',');
if (a2) *a2++ = '\0';
if ((result = parseopts(a2, groups, &opts)) < 0)
return result;
applyopts(-1, opts, PH_INIT);
if (applyopts_single(&fd->stream, opts, PH_INIT) < 0) return -1;
retropt_bool(opts, OPT_UNLINK_EARLY, &opt_unlink_early);
if (opt_unlink_early) {
if (Unlink(a1) < 0) {
if (errno == ENOENT) {
Warn2("unlink(%s): %s", a1, strerror(errno));
} else {
Error2("unlink(%s): %s", a1, strerror(errno));
return STAT_RETRYLATER;
}
}
}
retropt_bool(opts, OPT_UNLINK_CLOSE, &opt_unlink_close);
retropt_modet(opts, OPT_PERM, &mode);
if (applyopts_named(a1, opts, PH_EARLY) < 0) {
return STAT_RETRYLATER;
}
if (applyopts_named(a1, opts, PH_PREOPEN) < 0) {
return STAT_RETRYLATER;
}
if (
#if HAVE_STAT64
Stat64(a1, &pipstat) < 0
#else
Stat(a1, &pipstat) < 0
#endif /* !HAVE_STAT64 */
) {
if (errno != ENOENT) {
Error3("stat(\"%s\", %p): %s", a1, &pipstat, strerror(errno));
} else {
Debug1("xioopen_fifo(\"%s\"): does not exist, creating fifo", a1);
#if 0
result = Mknod(a1, S_IFIFO|mode, 0);
if (result < 0) {
Error3("mknod(%s, %d, 0): %s", a1, mode, strerror(errno));
return STAT_RETRYLATER;
}
#else
result = Mkfifo(a1, mode);
if (result < 0) {
Error3("mkfifo(%s, %d): %s", a1, mode, strerror(errno));
return STAT_RETRYLATER;
}
#endif
Notice2("created named pipe \"%s\" for %s", a1, ddirection[rw]);
}
if (opt_unlink_close) {
if ((fd->stream.unlink_close = strdup(a1)) == NULL) {
Error1("strdup(\"%s\"): out of memory", a1);
}
fd->stream.opt_unlink_close = true;
}
} else {
/* exists */
Debug1("xioopen_fifo(\"%s\"): already exist, opening it", a1);
Notice3("opening %s \"%s\" for %s",
filetypenames[(pipstat.st_mode&S_IFMT)>>12],
a1, ddirection[rw]);
/*applyopts_early(a1, opts);*/
applyopts_named(a1, opts, PH_EARLY);
}
if ((result = _xioopen_open(a1, rw, opts)) < 0) {
return result;
}
fd->stream.fd = result;
applyopts_named(a1, opts, PH_FD);
applyopts(fd->stream.fd, opts, PH_FD);
applyopts_cloexec(fd->stream.fd, opts);
return _xio_openlate(&fd->stream, opts);
}
#endif /* WITH_PIPE */
|