diff options
author | Christopher Faylor <me@cgf.cx> | 2008-08-20 06:25:06 +0400 |
---|---|---|
committer | Christopher Faylor <me@cgf.cx> | 2008-08-20 06:25:06 +0400 |
commit | fbf39a58cbbd92f3f185bad685c67099cc1ec805 (patch) | |
tree | 52d78923e8a61c058d6ecfba274985cd8ff549e8 /winsup/cygwin/fhandler.cc | |
parent | ec8a7e416f570407fe5360959272418a2b4c79f8 (diff) |
* fhandler.cc (fhandler_base::wait_overlapped): Always assume that bytes will
be non-NULL. Distinguish input result from result derived from WFMO and
GetOverlappedResult or res can never be -1. Only raise SIGPIPE when writing.
* fhandler.h (fhandler_base::wait_overlapped): Pass first argument by value.
* fhandler_fifo.cc (fhandler_fifo::wait): Pass in dummy byte count to
wait_overlapped.
* pipe.cc (DEFAULT_PIPEBUFSIZE): Define to 65536 explicitly.
Diffstat (limited to 'winsup/cygwin/fhandler.cc')
-rw-r--r-- | winsup/cygwin/fhandler.cc | 23 |
1 files changed, 11 insertions, 12 deletions
diff --git a/winsup/cygwin/fhandler.cc b/winsup/cygwin/fhandler.cc index 3fdddd549..1db40ac76 100644 --- a/winsup/cygwin/fhandler.cc +++ b/winsup/cygwin/fhandler.cc @@ -1680,18 +1680,17 @@ fhandler_base::destroy_overlapped () } int -fhandler_base::wait_overlapped (bool& res, bool writing, DWORD *bytes) +fhandler_base::wait_overlapped (bool inres, bool writing, DWORD *bytes) { - if (bytes) - *bytes = (DWORD) -1; + int res; + *bytes = (DWORD) -1; DWORD err = GetLastError (); - if (!res && err != ERROR_IO_PENDING) + if (!inres && err != ERROR_IO_PENDING) { - if (err != ERROR_HANDLE_EOF) + if (err != ERROR_HANDLE_EOF && err != ERROR_BROKEN_PIPE) goto err; res = 1; - if (*bytes) - *bytes = 0; + *bytes = 0; } else { @@ -1707,12 +1706,13 @@ fhandler_base::wait_overlapped (bool& res, bool writing, DWORD *bytes) if (&_my_tls == _main_tls) w4[n++] = signal_arrived; HANDLE h = writing ? get_output_handle () : get_handle (); - switch (WaitForMultipleObjects (n, w4, false, INFINITE)) + DWORD res = WaitForMultipleObjects (n, w4, false, INFINITE); + ResetEvent (get_overlapped ()->hEvent); + switch (res) { case WAIT_OBJECT_0: debug_printf ("normal read"); - if (!bytes || - GetOverlappedResult (h, get_overlapped (), bytes, false)) + if (GetOverlappedResult (h, get_overlapped (), bytes, false)) res = 1; else { @@ -1738,10 +1738,9 @@ fhandler_base::wait_overlapped (bool& res, bool writing, DWORD *bytes) err: __seterrno_from_win_error (err); res = -1; - if (err == ERROR_NO_DATA || err == ERROR_BROKEN_PIPE) + if (writing && (err == ERROR_NO_DATA || err == ERROR_BROKEN_PIPE)) raise (SIGPIPE); out: - ResetEvent (get_overlapped ()->hEvent); return res; } |