Categories:
Audio (13)
Biotech (29)
Bytecode (36)
Database (77)
Framework (7)
Game (7)
General (507)
Graphics (53)
I/O (35)
IDE (2)
JAR Tools (101)
JavaBeans (21)
JDBC (121)
JDK (426)
JSP (20)
Logging (108)
Mail (58)
Messaging (8)
Network (84)
PDF (97)
Report (7)
Scripting (84)
Security (32)
Server (121)
Servlet (26)
SOAP (24)
Testing (54)
Web (15)
XML (309)
Collections:
Other Resources:
JDK 17 jdk.internal.le.jmod - Internal Line Editing Module
JDK 17 jdk.internal.le.jmod is the JMOD file for JDK 17 Internal Line Editing module.
JDK 17 Internal Line Editing module compiled class files are stored in \fyicenter\jdk-17.0.5\jmods\jdk.internal.le.jmod.
JDK 17 Internal Line Editing module compiled class files are also linked and stored in the \fyicenter\jdk-17.0.5\lib\modules JImage file.
JDK 17 Internal Line Editing module source code files are stored in \fyicenter\jdk-17.0.5\lib\src.zip\jdk.internal.le.
You can click and view the content of each source code file in the list below.
✍: FYIcenter
⏎ jdk/internal/org/jline/utils/NonBlocking.java
/* * Copyright (c) 2002-2018, the original author or authors. * * This software is distributable under the BSD license. See the terms of the * BSD license in the documentation provided with this software. * * https://opensource.org/licenses/BSD-3-Clause */ package jdk.internal.org.jline.utils; import java.io.IOException; import java.io.InputStream; import java.io.Reader; import java.nio.ByteBuffer; import java.nio.CharBuffer; import java.nio.charset.Charset; import java.nio.charset.CharsetDecoder; import java.nio.charset.CharsetEncoder; import java.nio.charset.CodingErrorAction; public class NonBlocking { public static NonBlockingPumpReader nonBlockingPumpReader() { return new NonBlockingPumpReader(); } public static NonBlockingPumpReader nonBlockingPumpReader(int size) { return new NonBlockingPumpReader(size); } public static NonBlockingPumpInputStream nonBlockingPumpInputStream() { return new NonBlockingPumpInputStream(); } public static NonBlockingPumpInputStream nonBlockingPumpInputStream(int size) { return new NonBlockingPumpInputStream(size); } public static NonBlockingInputStream nonBlockingStream(NonBlockingReader reader, Charset encoding) { return new NonBlockingReaderInputStream(reader, encoding); } public static NonBlockingInputStream nonBlocking(String name, InputStream inputStream) { if (inputStream instanceof NonBlockingInputStream) { return (NonBlockingInputStream) inputStream; } return new NonBlockingInputStreamImpl(name, inputStream); } public static NonBlockingReader nonBlocking(String name, Reader reader) { if (reader instanceof NonBlockingReader) { return (NonBlockingReader) reader; } return new NonBlockingReaderImpl(name, reader); } public static NonBlockingReader nonBlocking(String name, InputStream inputStream, Charset encoding) { return new NonBlockingInputStreamReader(nonBlocking(name, inputStream), encoding); } private static class NonBlockingReaderInputStream extends NonBlockingInputStream { private final NonBlockingReader reader; private final CharsetEncoder encoder; // To encode a character with multiple bytes (e.g. certain Unicode characters) // we need enough space to encode them. Reading would fail if the read() method // is used to read a single byte in these cases. // Use this buffer to ensure we always have enough space to encode a character. private final ByteBuffer bytes; private final CharBuffer chars; private NonBlockingReaderInputStream(NonBlockingReader reader, Charset charset) { this.reader = reader; this.encoder = charset.newEncoder() .onUnmappableCharacter(CodingErrorAction.REPLACE) .onMalformedInput(CodingErrorAction.REPLACE); this.bytes = ByteBuffer.allocate(4); this.chars = CharBuffer.allocate(2); // No input available after initialization this.bytes.limit(0); this.chars.limit(0); } @Override public int available() { return (int) (reader.available() * this.encoder.averageBytesPerChar()) + bytes.remaining(); } @Override public void close() throws IOException { reader.close(); } @Override public int read(long timeout, boolean isPeek) throws IOException { boolean isInfinite = (timeout <= 0L); while (!bytes.hasRemaining() && (isInfinite || timeout > 0L)) { long start = 0; if (!isInfinite) { start = System.currentTimeMillis(); } int c = reader.read(timeout); if (c == EOF) { return EOF; } if (c >= 0) { if (!chars.hasRemaining()) { chars.position(0); chars.limit(0); } int l = chars.limit(); chars.array()[chars.arrayOffset() + l] = (char) c; chars.limit(l + 1); bytes.clear(); encoder.encode(chars, bytes, false); bytes.flip(); } if (!isInfinite) { timeout -= System.currentTimeMillis() - start; } } if (bytes.hasRemaining()) { if (isPeek) { return Byte.toUnsignedInt(bytes.get(bytes.position())); } else { return Byte.toUnsignedInt(bytes.get()); } } else { return READ_EXPIRED; } } } private static class NonBlockingInputStreamReader extends NonBlockingReader { private final NonBlockingInputStream input; private final CharsetDecoder decoder; private final ByteBuffer bytes; private final CharBuffer chars; public NonBlockingInputStreamReader(NonBlockingInputStream inputStream, Charset encoding) { this(inputStream, (encoding != null ? encoding : Charset.defaultCharset()).newDecoder() .onMalformedInput(CodingErrorAction.REPLACE) .onUnmappableCharacter(CodingErrorAction.REPLACE)); } public NonBlockingInputStreamReader(NonBlockingInputStream input, CharsetDecoder decoder) { this.input = input; this.decoder = decoder; this.bytes = ByteBuffer.allocate(4); this.chars = CharBuffer.allocate(2); this.bytes.limit(0); this.chars.limit(0); } @Override protected int read(long timeout, boolean isPeek) throws IOException { boolean isInfinite = (timeout <= 0L); while (!chars.hasRemaining() && (isInfinite || timeout > 0L)) { long start = 0; if (!isInfinite) { start = System.currentTimeMillis(); } int b = input.read(timeout); if (b == EOF) { return EOF; } if (b >= 0) { if (!bytes.hasRemaining()) { bytes.position(0); bytes.limit(0); } int l = bytes.limit(); bytes.array()[bytes.arrayOffset() + l] = (byte) b; bytes.limit(l + 1); chars.clear(); decoder.decode(bytes, chars, false); chars.flip(); } if (!isInfinite) { timeout -= System.currentTimeMillis() - start; } } if (chars.hasRemaining()) { if (isPeek) { return chars.get(chars.position()); } else { return chars.get(); } } else { return READ_EXPIRED; } } @Override public int readBuffered(char[] b) throws IOException { if (b == null) { throw new NullPointerException(); } else if (b.length == 0) { return 0; } else { if (chars.hasRemaining()) { int r = Math.min(b.length, chars.remaining()); chars.get(b); return r; } else { byte[] buf = new byte[b.length]; int l = input.readBuffered(buf); if (l < 0) { return l; } else { ByteBuffer currentBytes; if (bytes.hasRemaining()) { int transfer = bytes.remaining(); byte[] newBuf = new byte[l + transfer]; bytes.get(newBuf, 0, transfer); System.arraycopy(buf, 0, newBuf, transfer, l); currentBytes = ByteBuffer.wrap(newBuf); bytes.position(0); bytes.limit(0); } else { currentBytes = ByteBuffer.wrap(buf, 0, l); } CharBuffer chars = CharBuffer.wrap(b); decoder.decode(currentBytes, chars, false); chars.flip(); if (currentBytes.hasRemaining()) { int pos = bytes.position(); bytes.limit(bytes.limit() + currentBytes.remaining()); bytes.put(currentBytes); bytes.position(pos); } return chars.remaining(); } } } } @Override public void shutdown() { input.shutdown(); } @Override public void close() throws IOException { input.close(); } } }
⏎ jdk/internal/org/jline/utils/NonBlocking.java
Or download all of them as a single archive file:
File name: jdk.internal.le-17.0.5-src.zip File size: 231458 bytes Release date: 2022-09-13 Download
⇒ JDK 17 jdk.internal.opt.jmod - Internal Opt Module
⇐ JDK 17 jdk.internal.jvmstat.jmod - Internal JVM Stat Module
2023-08-25, 3980👍, 0💬
Popular Posts:
ASM is an all purpose Java bytecode manipulation and analysis framework. It can be used to modify ex...
What JAR files are required to run sax\Writer.java provided in the Apache Xerces package? 1 JAR file...
JDK 11 java.xml.jmod is the JMOD file for JDK 11 XML (eXtensible Markup Language) module. JDK 11 XML...
What Is commons-fileupload-1.3.3 .jar?commons-fileupload-1.3.3 .jaris the JAR file for Apache Common...
iText is an ideal library for developers looking to enhance web- and other applications with dynamic...