During a blocking read, we sleep for 1 ms after each iteration through
the connected writers. Currently we do this by calling Sleep (1).
Remove this call to Sleep and instead change the timeout in the
cygwait call from 0 to 1, so that raw_read can be interrupted while
sleeping.
}
else
{
- /* Allow interruption. */
- DWORD waitret = cygwait (NULL, cw_nowait, cw_cancel | cw_sig_eintr);
+ /* Allow interruption and don't hog the CPU. */
+ DWORD waitret = cygwait (NULL, 1, cw_cancel | cw_sig_eintr);
if (waitret == WAIT_CANCELED)
pthread::static_cancel_self ();
else if (waitret == WAIT_SIGNALED)
set_errno (EBADF);
goto errout;
}
- /* Don't hog the CPU. */
- Sleep (1);
}
errout:
len = (size_t) -1;