14 * version 2 for more details (a copy is included in the LICENSE file that
15 * accompanied this code).
16 *
17 * You should have received a copy of the GNU General Public License version
18 * 2 along with this work; if not, write to the Free Software Foundation,
19 * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
20 *
21 * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
22 * or visit www.oracle.com if you need additional information or have any
23 * questions.
24 */
25 package sun.nio.ch;
26
27 import java.io.IOException;
28 import jdk.internal.vm.ContinuationSupport;
29
30 /**
31 * Default PollerProvider for Linux.
32 */
33 class DefaultPollerProvider extends PollerProvider {
34 DefaultPollerProvider() { }
35
36 @Override
37 Poller.Mode defaultPollerMode() {
38 if (ContinuationSupport.isSupported()) {
39 return Poller.Mode.VTHREAD_POLLERS;
40 } else {
41 return Poller.Mode.SYSTEM_THREADS;
42 }
43 }
44
45 @Override
46 int defaultReadPollers(Poller.Mode mode) {
47 int ncpus = Runtime.getRuntime().availableProcessors();
48 if (mode == Poller.Mode.VTHREAD_POLLERS) {
49 return Math.min(Integer.highestOneBit(ncpus), 32);
50 } else {
51 return Math.max(Integer.highestOneBit(ncpus / 4), 1);
52 }
53 }
54
55 @Override
56 Poller readPoller(boolean subPoller) throws IOException {
57 return new EPollPoller(subPoller, true);
58 }
59
60 @Override
61 Poller writePoller(boolean subPoller) throws IOException {
62 return new EPollPoller(subPoller, false);
63 }
64 }
|
14 * version 2 for more details (a copy is included in the LICENSE file that
15 * accompanied this code).
16 *
17 * You should have received a copy of the GNU General Public License version
18 * 2 along with this work; if not, write to the Free Software Foundation,
19 * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
20 *
21 * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
22 * or visit www.oracle.com if you need additional information or have any
23 * questions.
24 */
25 package sun.nio.ch;
26
27 import java.io.IOException;
28 import jdk.internal.vm.ContinuationSupport;
29
30 /**
31 * Default PollerProvider for Linux.
32 */
33 class DefaultPollerProvider extends PollerProvider {
34 private static final boolean USE_IOURING;
35 static {
36 String s = System.getProperty("jdk.io_uring");
37 USE_IOURING = "".equals(s) || Boolean.parseBoolean(s);
38 }
39
40 DefaultPollerProvider(Poller.Mode mode) {
41 super(mode);
42 }
43
44 DefaultPollerProvider() {
45 this(ContinuationSupport.isSupported()
46 ? Poller.Mode.VTHREAD_POLLERS
47 : Poller.Mode.SYSTEM_THREADS);
48 }
49
50 @Override
51 int defaultReadPollers() {
52 int ncpus = Runtime.getRuntime().availableProcessors();
53 return switch (pollerMode()) {
54 case SYSTEM_THREADS -> Math.max(Integer.highestOneBit(ncpus / 4), 1);
55 case VTHREAD_POLLERS -> Math.min(Integer.highestOneBit(ncpus), 32);
56 default -> super.defaultReadPollers();
57 };
58 }
59
60 @Override
61 Poller readPoller(boolean subPoller) throws IOException {
62 Poller.Mode mode = pollerMode();
63 if (USE_IOURING) {
64 return new IoUringPoller(mode, subPoller, true);
65 } else {
66 return new EPollPoller(mode, subPoller, true);
67 }
68 }
69
70 @Override
71 Poller writePoller(boolean subPoller) throws IOException {
72 Poller.Mode mode = pollerMode();
73 if (USE_IOURING) {
74 return new IoUringPoller(mode, subPoller, false);
75 } else {
76 return new EPollPoller(mode, subPoller, false);
77 }
78 }
79 }
|