diff options
Diffstat (limited to 'winsup/cygwin/fhandler_fifo.cc')
| -rw-r--r-- | winsup/cygwin/fhandler_fifo.cc | 243 |
1 files changed, 0 insertions, 243 deletions
diff --git a/winsup/cygwin/fhandler_fifo.cc b/winsup/cygwin/fhandler_fifo.cc deleted file mode 100644 index aa631528a..000000000 --- a/winsup/cygwin/fhandler_fifo.cc +++ /dev/null @@ -1,243 +0,0 @@ -/* fhandler_fifo.cc - See fhandler.h for a description of the fhandler classes. - - Copyright 2002, 2003, 2004, 2005, 2006 Red Hat, Inc. - - This file is part of Cygwin. - - This software is a copyrighted work licensed under the terms of the - Cygwin license. Please consult the file "CYGWIN_LICENSE" for - details. */ - -#include "winsup.h" -#include <errno.h> -#include <unistd.h> -#include <stdlib.h> - -#include "cygerrno.h" -#include "perprocess.h" -#include "security.h" -#include "path.h" -#include "fhandler.h" -#include "dtable.h" -#include "cygheap.h" -#include "pinfo.h" - -fhandler_fifo::fhandler_fifo () - : fhandler_pipe (), output_handle (NULL), - read_use (0), write_use (0) -{ -} - -void -fhandler_fifo::set_use (int incr) -{ - long oread_use = read_use; - - if (get_flags () & (O_WRONLY | O_APPEND)) - write_use += incr; - else if (get_flags () & O_RDWR) - { - write_use += incr; - read_use += incr; - } - else - read_use += incr; - - if (incr >= 0) - return; - if (read_use <= 0 && oread_use != read_use) - { - HANDLE h = get_handle (); - if (h) - { - set_io_handle (NULL); - CloseHandle (h); - } - } -} - -int -fhandler_fifo::close () -{ - fhandler_pipe::close (); - if (get_output_handle ()) - CloseHandle (get_output_handle ()); - if (!hExeced) - set_use (-1); - return 0; -} - -#define DUMMY_O_RDONLY 4 - -void -fhandler_fifo::close_one_end () -{ - int testflags = (get_flags () & (O_RDWR | O_WRONLY | O_APPEND)) ?: DUMMY_O_RDONLY; - static int flagtypes[] = {DUMMY_O_RDONLY | O_RDWR, O_WRONLY | O_APPEND | O_RDWR}; - HANDLE *handles[2] = {&(get_handle ()), &(get_output_handle ())}; - for (int i = 0; i < 2; i++) - if (!(testflags & flagtypes[i])) - { - CloseHandle (*handles[i]); - *handles[i] = NULL; - } - else if (i == 0 && !read_state) - { - create_read_state (2); - need_fork_fixup (true); - } -} -int -fhandler_fifo::open_not_mine (int flags) -{ - winpids pids ((DWORD) 0); - int res = 0; - - for (unsigned i = 0; i < pids.npids; i++) - { - _pinfo *p = pids[i]; - commune_result r; - if (p->pid != myself->pid) - { - r = p->commune_request (PICOM_FIFO, get_win32_name ()); - if (r.handles[0] == NULL) - continue; // process doesn't own fifo - debug_printf ("pid %d, handles[0] %p, handles[1] %p", p->pid, - r.handles[0], r.handles[1]); - } - else - { - /* FIXME: racy? */ - fhandler_fifo *fh = cygheap->fdtab.find_fifo (get_win32_name ()); - if (!fh) - continue; - if (!DuplicateHandle (hMainProc, fh->get_handle (), hMainProc, - &r.handles[0], 0, false, DUPLICATE_SAME_ACCESS)) - { - __seterrno (); - goto out; - } - if (!DuplicateHandle (hMainProc, fh->get_output_handle (), hMainProc, - &r.handles[1], 0, false, DUPLICATE_SAME_ACCESS)) - { - CloseHandle (r.handles[0]); - __seterrno (); - goto out; - } - } - - set_io_handle (r.handles[0]); - set_output_handle (r.handles[1]); - set_flags (flags); - close_one_end (); - res = 1; - goto out; - } - - set_errno (EAGAIN); - -out: - debug_printf ("res %d", res); - return res; -} - -#define FIFO_PREFIX "_cygfifo_" - -int -fhandler_fifo::open (int flags, mode_t) -{ - int res = 1; - char mutex[CYG_MAX_PATH]; - char *emutex = mutex + CYG_MAX_PATH; - char *p, *p1; - DWORD resw; - - /* Generate a semi-unique name to associate with this fifo but try to ensure - that it is no larger than CYG_MAX_PATH */ - for (p = mutex, p1 = strchr (get_name (), '\0'); - --p1 >= get_name () && p < emutex ; p++) - *p = (*p1 == '/') ? '_' : *p1; - strncpy (p, FIFO_PREFIX, emutex - p); - mutex[CYG_MAX_PATH - 1] = '\0'; - - /* Create a mutex lock access to this fifo to prevent a race by two processes - trying to figure out if they own the fifo or if they should create it. */ - HANDLE h = CreateMutex (&sec_none_nih, false, mutex); - if (!h) - { - __seterrno (); - system_printf ("couldn't open fifo mutex '%s', %E", mutex); - res = 0; - goto out; - } - - lock_process::locker.release (); /* Since we may be a while, release the - process lock that is held when we - open an fd. */ - /* FIXME? Need to wait for signal here? - This shouldn't block for long, but... */ - resw = WaitForSingleObject (h, INFINITE); - lock_process::locker.acquire (); /* Restore the lock */ - if (resw != WAIT_OBJECT_0 && resw != WAIT_ABANDONED_0) - { - __seterrno (); - system_printf ("Wait for fifo mutex '%s' failed, %E", mutex); - goto out; - } - - set_io_handle (NULL); - set_output_handle (NULL); - if (open_not_mine (flags)) - goto out; - - fhandler_pipe *fhs[2]; - if (create (fhs, 1, flags, true)) - { - __seterrno (); - res = 0; - } - else - { - set_flags (flags); - set_io_handle (fhs[0]->get_handle ()); - set_output_handle (fhs[1]->get_handle ()); - guard = fhs[0]->guard; - read_state = fhs[0]->read_state; - writepipe_exists = fhs[1]->writepipe_exists; - orig_pid = fhs[0]->orig_pid; - id = fhs[0]->id; - delete (fhs[0]); - delete (fhs[1]); - set_use (1); - need_fork_fixup (true); - } - -out: - if (h) - { - ReleaseMutex (h); - CloseHandle (h); - } - debug_printf ("returning %d, errno %d", res, get_errno ()); - return res; -} - -int -fhandler_fifo::dup (fhandler_base *child) -{ - int res = fhandler_pipe::dup (child); - if (!res) - { - fhandler_fifo *ff = (fhandler_fifo *) child; - if (get_output_handle () - && !DuplicateHandle (hMainProc, get_output_handle (), hMainProc, - &ff->get_output_handle (), false, true, - DUPLICATE_SAME_ACCESS)) - { - __seterrno (); - child->close (); - res = -1; - } - } - return res; -} |