/* source: xio-gopen.c */ /* Copyright Gerhard Rieger and contributors (see file CHANGES) */ /* Published under the GNU General Public License V.2, see file COPYING */ /* this file contains the source for opening addresses of generic open type */ #include "xiosysincludes.h" #include "xioopen.h" #include "xio-named.h" #include "xio-unix.h" #include "xio-gopen.h" #if WITH_GOPEN static int xioopen_gopen(int argc, const char *argv[], struct opt *opts, int xioflags, xiofile_t *fd, unsigned groups, int dummy1, int dummy2, int dummy3); const struct addrdesc addr_gopen = { "gopen", 3, xioopen_gopen, GROUP_FD|GROUP_FIFO|GROUP_CHR|GROUP_BLK|GROUP_REG|GROUP_NAMED|GROUP_OPEN|GROUP_FILE|GROUP_TERMIOS|GROUP_SOCKET|GROUP_SOCK_UNIX, 0, 0, 0 HELP(":") }; static int xioopen_gopen(int argc, const char *argv[], struct opt *opts, int xioflags, xiofile_t *fd, unsigned groups, int dummy1, int dummy2, int dummy3) { const char *filename = argv[1]; flags_t openflags = (xioflags & XIO_ACCMODE); mode_t st_mode; bool exists; bool opt_unlink_close = false; int result; if ((result = _xioopen_named_early(argc, argv, fd, GROUP_NAMED|groups, &exists, opts)) < 0) { return result; } st_mode = result; if (exists) { /* file (or at least named entry) exists */ if ((xioflags&XIO_ACCMODE) != XIO_RDONLY) { openflags |= O_APPEND; } } else { openflags |= O_CREAT; } /* note: when S_ISSOCK was undefined, it always gives 0 */ if (exists && S_ISSOCK(st_mode)) { #if WITH_UNIX union sockaddr_union us; socklen_t uslen = sizeof(us); char infobuff[256]; Info1("\"%s\" is a socket, connecting to it", filename); result = _xioopen_unix_client(&fd->stream, xioflags, groups, 0, opts, filename); if (result < 0) { return result; } applyopts_named(filename, opts, PH_PASTOPEN); /* unlink-late */ if (Getsockname(fd->stream.fd, (struct sockaddr *)&us, &uslen) < 0) { Warn4("getsockname(%d, %p, {%d}): %s", fd->stream.fd, &us, uslen, strerror(errno)); } else { Notice1("successfully connected via %s", sockaddr_unix_info(&us.un, uslen, infobuff, sizeof(infobuff))); } #else Error("\"%s\" is a socket, but UNIX socket support is not compiled in"); return -1; #endif /* WITH_UNIX */ } else { /* a file name */ Info1("\"%s\" is not a socket, open()'ing it", filename); retropt_bool(opts, OPT_UNLINK_CLOSE, &opt_unlink_close); if (opt_unlink_close) { if ((fd->stream.unlink_close = strdup(filename)) == NULL) { Error1("strdup(\"%s\"): out of memory", filename); } fd->stream.opt_unlink_close = true; } Notice3("opening %s \"%s\" for %s", filetypenames[(st_mode&S_IFMT)>>12], filename, ddirection[(xioflags&XIO_ACCMODE)]); if ((result = _xioopen_open(filename, openflags, opts)) < 0) return result; #ifdef I_PUSH if (S_ISCHR(st_mode)) { Ioctl(result, I_PUSH, "ptem"); Ioctl(result, I_PUSH, "ldterm"); Ioctl(result, I_PUSH, "ttcompat"); } #endif fd->stream.fd = result; #if WITH_TERMIOS if (Isatty(fd->stream.fd)) { if (Tcgetattr(fd->stream.fd, &fd->stream.savetty) < 0) { Warn2("cannot query current terminal settings on fd %d: %s", fd->stream.fd, strerror(errno)); } else { fd->stream.ttyvalid = true; } } #endif /* WITH_TERMIOS */ applyopts_named(filename, opts, PH_FD); applyopts(fd->stream.fd, opts, PH_FD); applyopts_cloexec(fd->stream.fd, opts); } if ((result = applyopts2(fd->stream.fd, opts, PH_PASTSOCKET, PH_CONNECTED)) < 0) return result; if ((result = _xio_openlate(&fd->stream, opts)) < 0) return result; return 0; } #endif /* WITH_GOPEN */