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.management.jmod - Management Module
JDK 11 java.management.jmod is the JMOD file for JDK 11 Management module.
JDK 11 Management module compiled class files are stored in \fyicenter\jdk-11.0.1\jmods\java.management.jmod.
JDK 11 Management module compiled class files are also linked and stored in the \fyicenter\jdk-11.0.1\lib\modules JImage file.
JDK 11 Management module source code files are stored in \fyicenter\jdk-11.0.1\lib\src.zip\java.management.
You can click and view the content of each source code file in the list below.
✍: FYIcenter
⏎ com/sun/jmx/remote/internal/ServerCommunicatorAdmin.java
/* * Copyright (c) 2003, 2004, Oracle and/or its affiliates. All rights reserved. * ORACLE PROPRIETARY/CONFIDENTIAL. Use is subject to license terms. * * * * * * * * * * * * * * * * * * * * */ package com.sun.jmx.remote.internal; import com.sun.jmx.remote.util.ClassLogger; public abstract class ServerCommunicatorAdmin { public ServerCommunicatorAdmin(long timeout) { if (logger.traceOn()) { logger.trace("Constructor", "Creates a new ServerCommunicatorAdmin object "+ "with the timeout "+timeout); } this.timeout = timeout; timestamp = 0; if (timeout < Long.MAX_VALUE) { Runnable timeoutTask = new Timeout(); final Thread t = new Thread(null, timeoutTask, "JMX-Server-Admin-Timeout", 0, false); t.setName("JMX server connection timeout " + t.getId()); // If you change this name you will need to change a unit test // (NoServerTimeoutTest) t.setDaemon(true); t.start(); } } /** * Tells that a new request message is received. * A caller of this method should always call the method * <code>rspOutgoing</code> to inform that a response is sent out * for the received request. * @return the value of the termination flag: * true if the connection is already being terminated, * false otherwise. */ public boolean reqIncoming() { if (logger.traceOn()) { logger.trace("reqIncoming", "Receive a new request."); } synchronized(lock) { if (terminated) { logger.warning("reqIncoming", "The server has decided to close " + "this client connection."); } ++currentJobs; return terminated; } } /** * Tells that a response is sent out for a received request. * @return the value of the termination flag: * true if the connection is already being terminated, * false otherwise. */ public boolean rspOutgoing() { if (logger.traceOn()) { logger.trace("reqIncoming", "Finish a request."); } synchronized(lock) { if (--currentJobs == 0) { timestamp = System.currentTimeMillis(); logtime("Admin: Timestamp=",timestamp); // tells the adminor to restart waiting with timeout lock.notify(); } return terminated; } } /** * Called by this class to tell an implementation to do stop. */ protected abstract void doStop(); /** * Terminates this object. * Called only by outside, so do not need to call doStop */ public void terminate() { if (logger.traceOn()) { logger.trace("terminate", "terminate the ServerCommunicatorAdmin object."); } synchronized(lock) { if (terminated) { return; } terminated = true; // tell Timeout to terminate lock.notify(); } } // -------------------------------------------------------------- // private classes // -------------------------------------------------------------- private class Timeout implements Runnable { public void run() { boolean stopping = false; synchronized(lock) { if (timestamp == 0) timestamp = System.currentTimeMillis(); logtime("Admin: timeout=",timeout); logtime("Admin: Timestamp=",timestamp); while(!terminated) { try { // wait until there is no more job while(!terminated && currentJobs != 0) { if (logger.traceOn()) { logger.trace("Timeout-run", "Waiting without timeout."); } lock.wait(); } if (terminated) return; final long remaining = timeout - (System.currentTimeMillis() - timestamp); logtime("Admin: remaining timeout=",remaining); if (remaining > 0) { if (logger.traceOn()) { logger.trace("Timeout-run", "Waiting with timeout: "+ remaining + " ms remaining"); } lock.wait(remaining); } if (currentJobs > 0) continue; final long elapsed = System.currentTimeMillis() - timestamp; logtime("Admin: elapsed=",elapsed); if (!terminated && elapsed > timeout) { if (logger.traceOn()) { logger.trace("Timeout-run", "timeout elapsed"); } logtime("Admin: timeout elapsed! "+ elapsed+">",timeout); // stopping terminated = true; stopping = true; break; } } catch (InterruptedException ire) { logger.warning("Timeout-run","Unexpected Exception: "+ ire); logger.debug("Timeout-run",ire); return; } } } if (stopping) { if (logger.traceOn()) { logger.trace("Timeout-run", "Call the doStop."); } doStop(); } } } private void logtime(String desc,long time) { timelogger.trace("synchro",desc+time); } // -------------------------------------------------------------- // private variables // -------------------------------------------------------------- private long timestamp; private final int[] lock = new int[0]; private int currentJobs = 0; private long timeout; // state issue private boolean terminated = false; private static final ClassLogger logger = new ClassLogger("javax.management.remote.misc", "ServerCommunicatorAdmin"); private static final ClassLogger timelogger = new ClassLogger("javax.management.remote.timeout", "ServerCommunicatorAdmin"); }
⏎ com/sun/jmx/remote/internal/ServerCommunicatorAdmin.java
Or download all of them as a single archive file:
File name: java.management-11.0.1-src.zip File size: 828174 bytes Release date: 2018-11-04 Download
⇒ JDK 11 java.management.rmi.jmod - Management RMI Module
2020-04-30, 97851👍, 0💬
Popular Posts:
XStream is a simple library to serialize objects to XML and back again. JAR File Size and Download L...
JRE 8 rt.jar is the JAR file for JRE 8 RT (Runtime) libraries. JRE (Java Runtime) 8 is the runtime e...
What Is javaws.jar in JRE (Java Runtime Environment) 8? javaws.jar in JRE (Java Runtime Environment)...
What Is junit-3.8.1.jar? junit-3.8.1.jar is the version 3.8.1 of JUnit JAR library file. JUnit is a ...
commons-lang-2.6.jar is the JAR file for Apache Commons Lang 2.6, which provides a host of helper ut...