Welcome to mirror list, hosted at ThFree Co, Russian Federation.

cygwin.com/git/newlib-cygwin.git - Unnamed repository; edit this file 'description' to name the repository.
summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
Diffstat (limited to 'winsup/cygwin/fhandler_fifo.cc')
-rw-r--r--winsup/cygwin/fhandler_fifo.cc178
1 files changed, 0 insertions, 178 deletions
diff --git a/winsup/cygwin/fhandler_fifo.cc b/winsup/cygwin/fhandler_fifo.cc
deleted file mode 100644
index d38d58670..000000000
--- a/winsup/cygwin/fhandler_fifo.cc
+++ /dev/null
@@ -1,178 +0,0 @@
-/* fhandler_fifo.cc. See fhandler.h for a description of the fhandler classes.
-
- Copyright 2002, 2003, 2004 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), owner (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 ();
- CloseHandle (get_output_handle ());
- set_use (-1);
- return 0;
-}
-
-#define DUMMY_O_RDONLY 4
-int
-fhandler_fifo::open_not_mine (int flags)
-{
- winpids pids;
- static int flagtypes[] = {DUMMY_O_RDONLY | O_RDWR, O_WRONLY | O_APPEND | O_RDWR};
- HANDLE *usehandles[2] = {&(get_handle ()), &(get_output_handle ())};
- int res;
-
- for (unsigned i = 0; i < pids.npids; i++)
- {
- _pinfo *p = pids[i];
- HANDLE hp = OpenProcess (PROCESS_DUP_HANDLE, false, p->dwProcessId);
- if (!hp)
- {
- __seterrno ();
- goto err;
- }
-
- HANDLE handles[2];
- commune_result r;
- r = p->commune_send (PICOM_FIFO, get_win32_name ());
- if (r.handles[0] == NULL)
- continue; // process doesn't own fifo
-
- flags = (flags & (O_RDWR | O_WRONLY | O_APPEND)) ?: DUMMY_O_RDONLY;
- for (int i = 0; i < 2; i++)
- {
- if (!(flags & flagtypes[i]))
- continue;
- if (!DuplicateHandle (hp, r.handles[i], hMainProc, usehandles[i], 0,
- false, DUPLICATE_SAME_ACCESS))
- {
- debug_printf ("couldn't duplicate handle %d/%p, %E", i, handles[i]);
- __seterrno ();
- goto err;
- }
-
- if (i == 0)
- {
- read_state = CreateEvent (&sec_none_nih, FALSE, FALSE, NULL);
- set_need_fork_fixup ();
- }
- }
- CloseHandle (hp);
-
- res = 1;
- set_flags (flags);
- goto out;
- }
-
- set_errno (EAGAIN);
-
-err:
- res = 0;
- debug_printf ("failed");
-
-out:
- debug_printf ("res %d", res);
- return res;
-}
-
-int
-fhandler_fifo::open (int flags, mode_t)
-{
- int res = 1;
-
- fhandler_pipe *fhs[2];
- if (create (fhs, 0, flags, true))
- goto errnout;
-
- set_flags (fhs[0]->get_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);
- goto out;
-
-errnout:
- __seterrno ();
- res = 0;
-
-out:
- 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 (!DuplicateHandle (hMainProc, get_output_handle (), hMainProc,
- &ff->get_output_handle (), false, true,
- DUPLICATE_SAME_ACCESS))
- {
- child->close ();
- res = -1;
- }
- }
- return 0;
-}