return ret;
}
+void
+fhandler_fifo::release_select_sem (const char *from)
+{
+ LONG n_release;
+ if (reader) /* Number of select() call. */
+ n_release = get_obj_handle_count (select_sem)
+ - get_obj_handle_count (read_ready);
+ else /* Number of select() and reader */
+ n_release = get_obj_handle_count (select_sem)
+ - get_obj_handle_count (get_handle ());
+ debug_printf("%s(%s) release %d", from,
+ reader ? "reader" : "writer", n_release);
+ if (n_release)
+ ReleaseSemaphore (select_sem, n_release, NULL);
+}
+
void __reg3
fhandler_fifo::raw_read (void *in_ptr, size_t& len)
{
fifo_client_unlock ();
reading_unlock ();
if (select_sem)
- ReleaseSemaphore (select_sem, get_obj_handle_count (select_sem), NULL);
+ release_select_sem ("raw_read");
}
int __reg2
int
fhandler_fifo::close ()
{
+ if (select_sem)
+ {
+ release_select_sem ("close");
+ NtClose (select_sem);
+ }
if (writer)
{
nwriters_lock ();
NtClose (write_ready);
if (writer_opening)
NtClose (writer_opening);
- if (select_sem)
- {
- ReleaseSemaphore (select_sem, get_obj_handle_count (select_sem), NULL);
- NtClose (select_sem);
- }
if (nohandle ())
return 0;
else
return buf;
}
+void
+fhandler_pipe::release_select_sem (const char *from)
+{
+ LONG n_release;
+ if (get_dev () == FH_PIPER) /* Number of select() and writer */
+ n_release = get_obj_handle_count (select_sem)
+ - get_obj_handle_count (read_mtx);
+ else /* Number of select() call */
+ n_release = get_obj_handle_count (select_sem)
+ - get_obj_handle_count (query_hdl);
+ debug_printf("%s(%s) release %d", from,
+ get_dev () == FH_PIPER ? "PIPER" : "PIPEW", n_release);
+ if (n_release)
+ ReleaseSemaphore (select_sem, n_release, NULL);
+}
+
void __reg3
fhandler_pipe::raw_read (void *ptr, size_t& len)
{
ptr = ((char *) ptr) + nbytes_now;
nbytes += nbytes_now;
if (select_sem && nbytes_now > 0)
- ReleaseSemaphore (select_sem,
- get_obj_handle_count (select_sem), NULL);
+ release_select_sem ("raw_read");
}
else
{
ptr = ((char *) ptr) + nbytes_now;
nbytes += nbytes_now;
if (select_sem && nbytes_now > 0)
- ReleaseSemaphore (select_sem,
- get_obj_handle_count (select_sem), NULL);
+ release_select_sem ("raw_write");
/* 0 bytes returned? EAGAIN. See above. */
if (NT_SUCCESS (status) && nbytes == 0)
set_errno (EAGAIN);
int
fhandler_pipe::close ()
{
- if (read_mtx)
- CloseHandle (read_mtx);
if (select_sem)
{
- ReleaseSemaphore (select_sem, get_obj_handle_count (select_sem), NULL);
+ release_select_sem ("close");
CloseHandle (select_sem);
}
+ if (read_mtx)
+ CloseHandle (read_mtx);
if (query_hdl)
CloseHandle (query_hdl);
return fhandler_base::close ();