< prev index next >

src/java.base/linux/classes/sun/nio/ch/DefaultPollerProvider.java

Print this page

 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     private static final boolean USE_IORING_OP_READ;
 36     private static final boolean USE_IORING_OP_WRITE;
 37     static {
 38         String s = System.getProperty("jdk.io_uring");
 39         if ("".equals(s) || Boolean.parseBoolean(s)) {
 40             USE_IOURING = true;
 41             s = System.getProperty("jdk.io_uring.read");
 42             USE_IORING_OP_READ = "".equals(s) || Boolean.parseBoolean(s);
 43             s = System.getProperty("jdk.io_uring.write");
 44             USE_IORING_OP_WRITE = "".equals(s) || Boolean.parseBoolean(s);
 45         } else {
 46             USE_IOURING = false;
 47             USE_IORING_OP_READ = false;
 48             USE_IORING_OP_WRITE = false;
 49         }
 50     }
 51 
 52     DefaultPollerProvider(Poller.Mode mode) {
 53         super(mode);
 54     }
 55 
 56     DefaultPollerProvider() {
 57         this(ContinuationSupport.isSupported()
 58                 ? Poller.Mode.VTHREAD_POLLERS
 59                 : Poller.Mode.SYSTEM_THREADS);
 60     }
 61 
 62     @Override
 63     int defaultReadPollers() {
 64         int ncpus = Runtime.getRuntime().availableProcessors();
 65         return switch (pollerMode()) {
 66             case SYSTEM_THREADS  -> Math.max(Integer.highestOneBit(ncpus / 4), 1);
 67             case VTHREAD_POLLERS -> Math.min(Integer.highestOneBit(ncpus), 32);
 68             default              -> super.defaultReadPollers();
 69         };
 70     }
 71 
 72     @Override
 73     Poller readPoller(boolean subPoller) throws IOException {
 74         Poller.Mode mode = pollerMode();
 75         if (USE_IOURING) {
 76             // read poller is system thread in SYSTEM_THREADS mode
 77             boolean supportReadOps = USE_IORING_OP_READ
 78                     && ((mode == Poller.Mode.SYSTEM_THREADS) || subPoller);
 79             return new IoUringPoller(mode, subPoller, true, supportReadOps);
 80         } else {
 81             return new EPollPoller(mode, subPoller, true);
 82         }
 83     }
 84 
 85     @Override
 86     Poller writePoller(boolean subPoller) throws IOException {
 87         Poller.Mode mode = pollerMode();
 88         if (USE_IOURING) {
 89             // write poller is system thread in SYSTEM_THREADS and POLLER_PER_CARRIER modes
 90             boolean supportWriteOps = USE_IORING_OP_WRITE
 91                     && ((mode != Poller.Mode.VTHREAD_POLLERS) || subPoller);
 92             return new IoUringPoller(mode, subPoller, false, supportWriteOps);
 93         } else {
 94             return new EPollPoller(mode, subPoller, false);
 95         }
 96     }
 97 
 98     @Override
 99     boolean supportReadOps() {
100         return USE_IORING_OP_READ;
101     }
102 
103     @Override
104     boolean supportWriteOps() {
105         return USE_IORING_OP_WRITE;
106     }
107 }
< prev index next >