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 11 java.base.jmod - Base Module
JDK 11 java.base.jmod is the JMOD file for JDK 11 Base module.
JDK 11 Base module compiled class files are stored in \fyicenter\jdk-11.0.1\jmods\java.base.jmod.
JDK 11 Base module compiled class files are also linked and stored in the \fyicenter\jdk-11.0.1\lib\modules JImage file.
JDK 11 Base module source code files are stored in \fyicenter\jdk-11.0.1\lib\src.zip\java.base.
You can click and view the content of each source code file in the list below.
✍: FYIcenter
⏎ sun/net/www/http/KeepAliveStreamCleaner.java
/* * Copyright (c) 2005, 2008, Oracle and/or its affiliates. All rights reserved. * ORACLE PROPRIETARY/CONFIDENTIAL. Use is subject to license terms. * * * * * * * * * * * * * * * * * * * * */ package sun.net.www.http; import java.io.IOException; import java.util.LinkedList; import sun.net.NetProperties; import java.security.AccessController; import java.security.PrivilegedAction; /** * This class is used to cleanup any remaining data that may be on a KeepAliveStream * so that the connection can be cached in the KeepAliveCache. * Instances of this class can be used as a FIFO queue for KeepAliveCleanerEntry objects. * Executing this Runnable removes each KeepAliveCleanerEntry from the Queue, reads * the reamining bytes on its KeepAliveStream, and if successful puts the connection in * the KeepAliveCache. * * @author Chris Hegarty */ @SuppressWarnings("serial") // never serialized class KeepAliveStreamCleaner extends LinkedList<KeepAliveCleanerEntry> implements Runnable { // maximum amount of remaining data that we will try to cleanup protected static int MAX_DATA_REMAINING = 512; // maximum amount of KeepAliveStreams to be queued protected static int MAX_CAPACITY = 10; // timeout for both socket and poll on the queue protected static final int TIMEOUT = 5000; // max retries for skipping data private static final int MAX_RETRIES = 5; static { final String maxDataKey = "http.KeepAlive.remainingData"; int maxData = AccessController.doPrivileged( new PrivilegedAction<Integer>() { public Integer run() { return NetProperties.getInteger(maxDataKey, MAX_DATA_REMAINING); }}).intValue() * 1024; MAX_DATA_REMAINING = maxData; final String maxCapacityKey = "http.KeepAlive.queuedConnections"; int maxCapacity = AccessController.doPrivileged( new PrivilegedAction<Integer>() { public Integer run() { return NetProperties.getInteger(maxCapacityKey, MAX_CAPACITY); }}).intValue(); MAX_CAPACITY = maxCapacity; } @Override public boolean offer(KeepAliveCleanerEntry e) { if (size() >= MAX_CAPACITY) return false; return super.offer(e); } @Override public void run() { KeepAliveCleanerEntry kace = null; do { try { synchronized(this) { long before = System.currentTimeMillis(); long timeout = TIMEOUT; while ((kace = poll()) == null) { this.wait(timeout); long after = System.currentTimeMillis(); long elapsed = after - before; if (elapsed > timeout) { /* one last try */ kace = poll(); break; } before = after; timeout -= elapsed; } } if(kace == null) break; KeepAliveStream kas = kace.getKeepAliveStream(); if (kas != null) { synchronized(kas) { HttpClient hc = kace.getHttpClient(); try { if (hc != null && !hc.isInKeepAliveCache()) { int oldTimeout = hc.getReadTimeout(); hc.setReadTimeout(TIMEOUT); long remainingToRead = kas.remainingToRead(); if (remainingToRead > 0) { long n = 0; int retries = 0; while (n < remainingToRead && retries < MAX_RETRIES) { remainingToRead = remainingToRead - n; n = kas.skip(remainingToRead); if (n == 0) retries++; } remainingToRead = remainingToRead - n; } if (remainingToRead == 0) { hc.setReadTimeout(oldTimeout); hc.finished(); } else hc.closeServer(); } } catch (IOException ioe) { hc.closeServer(); } finally { kas.setClosed(); } } } } catch (InterruptedException ie) { } } while (kace != null); } }
⏎ sun/net/www/http/KeepAliveStreamCleaner.java
Or download all of them as a single archive file:
File name: java.base-11.0.1-src.zip File size: 8740354 bytes Release date: 2018-11-04 Download
2020-05-29, 207484👍, 0💬
Popular Posts:
JDK 11 java.xml.jmod is the JMOD file for JDK 11 XML (eXtensible Markup Language) module. JDK 11 XML...
JasperReports, the world's most popular open source business intelligence and reporting engine and J...
How to run "javac" command from JDK tools.jar file? "javac" is the Java compiler command that allows...
What is the dom\GetElementsByTagName .javaprovided in the Apache Xerces package? I have Apache Xerce...
What Is activation.jar? I heard it's related to JAF (JavaBeans Activation Framework) 1.1? The if you...