< prev index next > src/java.base/windows/classes/sun/nio/ch/DefaultPollerProvider.java
Print this page
class DefaultPollerProvider extends PollerProvider {
DefaultPollerProvider() { }
@Override
int defaultReadPollers(Poller.Mode mode) {
! assert mode == Poller.Mode.SYSTEM_THREADS;
int ncpus = Runtime.getRuntime().availableProcessors();
return Math.max(Integer.highestOneBit(ncpus / 8), 1);
}
@Override
class DefaultPollerProvider extends PollerProvider {
DefaultPollerProvider() { }
@Override
int defaultReadPollers(Poller.Mode mode) {
! if (mode != Poller.Mode.SYSTEM_THREADS) {
+ throw new UnsupportedOperationException();
+ }
int ncpus = Runtime.getRuntime().availableProcessors();
return Math.max(Integer.highestOneBit(ncpus / 8), 1);
}
@Override
return (fdVal >> 2) & (toIndex - 1);
}
@Override
Poller readPoller(boolean subPoller) throws IOException {
! assert !subPoller;
return new WEPollPoller(true);
}
@Override
Poller writePoller(boolean subPoller) throws IOException {
! assert !subPoller;
return new WEPollPoller(false);
}
}
return (fdVal >> 2) & (toIndex - 1);
}
@Override
Poller readPoller(boolean subPoller) throws IOException {
! if (subPoller)
+ throw new UnsupportedOperationException();
return new WEPollPoller(true);
}
@Override
Poller writePoller(boolean subPoller) throws IOException {
! if (subPoller)
+ throw new UnsupportedOperationException();
return new WEPollPoller(false);
}
}
< prev index next >