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 java.management.jmod - Management Module
JDK 17 java.management.jmod is the JMOD file for JDK 17 Management module.
JDK 17 Management module compiled class files are stored in \fyicenter\jdk-17.0.5\jmods\java.management.jmod.
JDK 17 Management module compiled class files are also linked and stored in the \fyicenter\jdk-17.0.5\lib\modules JImage file.
JDK 17 Management module source code files are stored in \fyicenter\jdk-17.0.5\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/ClientCommunicatorAdmin.java
/* * Copyright (c) 2003, 2012, Oracle and/or its affiliates. All rights reserved. * ORACLE PROPRIETARY/CONFIDENTIAL. Use is subject to license terms. * * * * * * * * * * * * * * * * * * * * */ package com.sun.jmx.remote.internal; import java.io.IOException; import java.io.InterruptedIOException; import com.sun.jmx.remote.util.ClassLogger; import com.sun.jmx.remote.util.EnvHelp; public abstract class ClientCommunicatorAdmin { private static volatile long threadNo = 1; public ClientCommunicatorAdmin(long period) { this.period = period; if (period > 0) { checker = new Checker(); Thread t = new Thread(null, checker, "JMX client heartbeat " + (++threadNo), 0, false); t.setDaemon(true); t.start(); } else checker = null; } /** * Called by a client to inform of getting an IOException. */ public void gotIOException (IOException ioe) throws IOException { restart(ioe); } /** * Called by this class to check a client connection. */ protected abstract void checkConnection() throws IOException; /** * Tells a client to re-start again. */ protected abstract void doStart() throws IOException; /** * Tells a client to stop because failing to call checkConnection. */ protected abstract void doStop(); /** * Terminates this object. */ public void terminate() { synchronized(lock) { if (state == TERMINATED) { return; } state = TERMINATED; lock.notifyAll(); if (checker != null) checker.stop(); } } private void restart(IOException ioe) throws IOException { // check state synchronized(lock) { if (state == TERMINATED) { throw new IOException("The client has been closed."); } else if (state == FAILED) { // already failed to re-start by another thread throw ioe; } else if (state == RE_CONNECTING) { // restart process has been called by another thread // we need to wait while(state == RE_CONNECTING) { try { lock.wait(); } catch (InterruptedException ire) { // be asked to give up InterruptedIOException iioe = new InterruptedIOException(ire.toString()); EnvHelp.initCause(iioe, ire); throw iioe; } } if (state == TERMINATED) { throw new IOException("The client has been closed."); } else if (state != CONNECTED) { // restarted is failed by another thread throw ioe; } return; } else { state = RE_CONNECTING; lock.notifyAll(); } } // re-starting try { doStart(); synchronized(lock) { if (state == TERMINATED) { throw new IOException("The client has been closed."); } state = CONNECTED; lock.notifyAll(); } return; } catch (Exception e) { logger.warning("restart", "Failed to restart: " + e); logger.debug("restart",e); synchronized(lock) { if (state == TERMINATED) { throw new IOException("The client has been closed."); } state = FAILED; lock.notifyAll(); } try { doStop(); } catch (Exception eee) { // OK. // We know there is a problem. } terminate(); throw ioe; } } // -------------------------------------------------------------- // private varaibles // -------------------------------------------------------------- private class Checker implements Runnable { public void run() { myThread = Thread.currentThread(); while (state != TERMINATED && !myThread.isInterrupted()) { try { Thread.sleep(period); } catch (InterruptedException ire) { // OK. // We will check the state at the following steps } if (state == TERMINATED || myThread.isInterrupted()) { break; } try { checkConnection(); } catch (Exception e) { synchronized(lock) { if (state == TERMINATED || myThread.isInterrupted()) { break; } } e = (Exception)EnvHelp.getCause(e); if (e instanceof IOException && !(e instanceof InterruptedIOException)) { try { gotIOException((IOException)e); } catch (Exception ee) { logger.warning("Checker-run", "Failed to check connection: "+ e); logger.warning("Checker-run", "stopping"); logger.debug("Checker-run",e); break; } } else { logger.warning("Checker-run", "Failed to check the connection: " + e); logger.debug("Checker-run",e); // XXX stop checking? break; } } } if (logger.traceOn()) { logger.trace("Checker-run", "Finished."); } } private void stop() { if (myThread != null && myThread != Thread.currentThread()) { myThread.interrupt(); } } private Thread myThread; } // -------------------------------------------------------------- // private variables // -------------------------------------------------------------- private final Checker checker; private long period; // state private static final int CONNECTED = 0; private static final int RE_CONNECTING = 1; private static final int FAILED = 2; private static final int TERMINATED = 3; private int state = CONNECTED; private final int[] lock = new int[0]; private static final ClassLogger logger = new ClassLogger("javax.management.remote.misc", "ClientCommunicatorAdmin"); }
⏎ com/sun/jmx/remote/internal/ClientCommunicatorAdmin.java
Or download all of them as a single archive file:
File name: java.management-17.0.5-src.zip File size: 850134 bytes Release date: 2022-09-13 Download
⇒ JDK 17 java.management.rmi.jmod - Management RMI Module
2023-09-23, 11208👍, 0💬
Popular Posts:
What Is ojdbc7.jar for Oracle 12c R1? ojdbc7.jar for Oracle 12c R1 is the JAR files of ojdbc.jar, JD...
JDK 11 jdk.internal.vm.compiler .jmodis the JMOD file for JDK 11 Internal VM Compiler module. JDK 11...
The Jakarta-ORO Java classes are a set of text-processing Java classes that provide Perl5 compatible...
JRE 8 rt.jar is the JAR file for JRE 8 RT (Runtime) libraries. JRE (Java Runtime) 8 is the runtime e...
maven-core-3.8.6.jar is the JAR file for Apache Maven 3.8.6 Core module. Apache Maven is a software ...