< prev index next >

src/java.base/windows/classes/sun/nio/ch/WEPollSelectorImpl.java

Print this page
@@ -106,18 +106,23 @@
          int numEntries;
          processUpdateQueue();
          processDeregisterQueue();
          try {
              begin(blocking);
-             numEntries = WEPoll.wait(eph, pollArrayAddress, NUM_EPOLLEVENTS, to);
+             numEntries = poll(to);
          } finally {
              end(blocking);
          }
          processDeregisterQueue();
          return processEvents(numEntries, action);
      }
  
+     @Override
+     protected int implPoll(long timeout) throws IOException {
+         return WEPoll.wait(eph, pollArrayAddress, NUM_EPOLLEVENTS, (int) timeout);
+     }
+ 
      /**
       * Process changes to the interest ops.
       */
      private void processUpdateQueue() {
          assert Thread.holdsLock(this);
< prev index next >