< prev index next > src/java.base/unix/classes/sun/nio/ch/UnixDispatcher.java
Print this page
@Override
void close(FileDescriptor fd) throws IOException {
close0(fd);
}
! private void signalThreads(long reader, long writer) {
if (NativeThread.isNativeThread(reader))
! NativeThread.signal(reader);
if (NativeThread.isNativeThread(writer))
! NativeThread.signal(writer);
}
@Override
! void implPreClose(FileDescriptor fd, long reader, long writer) throws IOException {
if (SUPPORTS_PENDING_SIGNALS) {
signalThreads(reader, writer);
}
preClose0(fd);
if (!SUPPORTS_PENDING_SIGNALS) {
@Override
void close(FileDescriptor fd) throws IOException {
close0(fd);
}
! private void signalThreads(NativeThread reader, NativeThread writer) {
if (NativeThread.isNativeThread(reader))
! reader.signal();
if (NativeThread.isNativeThread(writer))
! writer.signal();
}
@Override
! void implPreClose(FileDescriptor fd, NativeThread reader, NativeThread writer) throws IOException {
if (SUPPORTS_PENDING_SIGNALS) {
signalThreads(reader, writer);
}
preClose0(fd);
if (!SUPPORTS_PENDING_SIGNALS) {
< prev index next >