< prev index next >

src/java.base/unix/classes/sun/nio/ch/UnixDispatcher.java

Print this page
*** 34,19 ***
      @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) {
--- 34,19 ---
      @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 >