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 jdk.management.agent.jmod - Management Agent Module
JDK 11 jdk.management.agent.jmod is the JMOD file for JDK 11 Management Agent module.
JDK 11 Management Agent module compiled class files are stored in \fyicenter\jdk-11.0.1\jmods\jdk.management.agent.jmod.
JDK 11 Management Agent module compiled class files are also linked and stored in the \fyicenter\jdk-11.0.1\lib\modules JImage file.
JDK 11 Management Agent module source code files are stored in \fyicenter\jdk-11.0.1\lib\src.zip\jdk.management.agent.
You can click and view the content of each source code file in the list below.
✍: FYIcenter
⏎ sun/management/jdp/JdpController.java
/* * Copyright (c) 2013, 2018, Oracle and/or its affiliates. All rights reserved. * ORACLE PROPRIETARY/CONFIDENTIAL. Use is subject to license terms. * * * * * * * * * * * * * * * * * * * * */ package sun.management.jdp; import java.io.IOException; import java.lang.management.ManagementFactory; import java.lang.management.RuntimeMXBean; import java.lang.reflect.Field; import java.lang.reflect.Method; import java.net.InetAddress; import java.net.UnknownHostException; import java.util.UUID; /** * JdpController is responsible to create and manage a broadcast loop. * * <p> Other part of code has no access to broadcast loop and have to use * provided static methods * {@link #startDiscoveryService(InetAddress,int,String,String) startDiscoveryService} * and {@link #stopDiscoveryService() stopDiscoveryService} * <p>{@link #startDiscoveryService(InetAddress,int,String,String) startDiscoveryService} could be called multiple * times as it stops the running service if it is necessary. * Call to {@link #stopDiscoveryService() stopDiscoveryService} * ignored if service isn't run. * * * <p> System properties below could be used to control broadcast loop behavior. * Property below have to be set explicitly in command line. It's not possible to * set it in management.config file. Careless changes of these properties could * lead to security or network issues. * <ul> * <li>com.sun.management.jdp.ttl - set ttl for broadcast packet</li> * <li>com.sun.management.jdp.pause - set broadcast interval in seconds</li> * <li>com.sun.management.jdp.source_addr - an address of interface to use for broadcast</li> * </ul> * * <p>null parameters values are filtered out on {@link JdpPacketWriter} level and * corresponding keys are not placed to packet. */ public final class JdpController { private static class JDPControllerRunner implements Runnable { private final JdpJmxPacket packet; private final JdpBroadcaster bcast; private final int pause; private volatile boolean shutdown = false; private JDPControllerRunner(JdpBroadcaster bcast, JdpJmxPacket packet, int pause) { this.bcast = bcast; this.packet = packet; this.pause = pause; } @Override public void run() { try { while (!shutdown) { bcast.sendPacket(packet); try { Thread.sleep(this.pause); } catch (InterruptedException e) { // pass } } } catch (IOException e) { // pass; } // It's not possible to re-use controller, // nevertheless reset shutdown variable try { stop(); bcast.shutdown(); } catch (IOException ex) { // pass - ignore IOException during shutdown } } public void stop() { shutdown = true; } } private static JDPControllerRunner controller = null; private JdpController(){ // Don't allow to instantiate this class. } // Utility to handle optional system properties // Parse an integer from string or return default if provided string is null private static int getInteger(String val, int dflt, String msg) throws JdpException { try { return (val == null) ? dflt : Integer.parseInt(val); } catch (NumberFormatException ex) { throw new JdpException(msg); } } // Parse an inet address from string or return default if provided string is null private static InetAddress getInetAddress(String val, InetAddress dflt, String msg) throws JdpException { try { return (val == null) ? dflt : InetAddress.getByName(val); } catch (UnknownHostException ex) { throw new JdpException(msg); } } // Get the process id of the current running Java process private static Long getProcessId() { try { // Get the current process id return ProcessHandle.current().pid(); } catch(UnsupportedOperationException ex) { return null; } } /** * Starts discovery service * * @param address - multicast group address * @param port - udp port to use * @param instanceName - name of running JVM instance * @param url - JMX service url * @throws IOException */ public static synchronized void startDiscoveryService(InetAddress address, int port, String instanceName, String url) throws IOException, JdpException { // Limit packet to local subnet by default int ttl = getInteger( System.getProperty("com.sun.management.jdp.ttl"), 1, "Invalid jdp packet ttl"); // Broadcast once a 5 seconds by default int pause = getInteger( System.getProperty("com.sun.management.jdp.pause"), 5, "Invalid jdp pause"); // Converting seconds to milliseconds pause = pause * 1000; // Allow OS to choose broadcast source InetAddress sourceAddress = getInetAddress( System.getProperty("com.sun.management.jdp.source_addr"), null, "Invalid source address provided"); // Generate session id UUID id = UUID.randomUUID(); JdpJmxPacket packet = new JdpJmxPacket(id, url); // Don't broadcast whole command line for security reason. // Strip everything after first space String javaCommand = System.getProperty("sun.java.command"); if (javaCommand != null) { String[] arr = javaCommand.split(" ", 2); packet.setMainClass(arr[0]); } // Put optional explicit java instance name to packet, if user doesn't specify // it the key is skipped. PacketWriter is responsible to skip keys having null value. packet.setInstanceName(instanceName); // Set rmi server hostname if it explicitly specified by user with // java.rmi.server.hostname String rmiHostname = System.getProperty("java.rmi.server.hostname"); packet.setRmiHostname(rmiHostname); // Set broadcast interval packet.setBroadcastInterval(Integer.toString(pause)); // Set process id Long pid = getProcessId(); if (pid != null) { packet.setProcessId(pid.toString()); } JdpBroadcaster bcast = new JdpBroadcaster(address, sourceAddress, port, ttl); // Stop discovery service if it's already running stopDiscoveryService(); controller = new JDPControllerRunner(bcast, packet, pause); Thread t = new Thread(null, controller, "JDP broadcaster", 0, false); t.setDaemon(true); t.start(); } /** * Stop running discovery service, * it's safe to attempt to stop not started service */ public static synchronized void stopDiscoveryService() { if ( controller != null ){ controller.stop(); controller = null; } } }
⏎ sun/management/jdp/JdpController.java
Or download all of them as a single archive file:
File name: jdk.management.agent-11.0.1-src.zip File size: 39186 bytes Release date: 2018-11-04 Download
⇒ JDK 11 jdk.management.jfr.jmod - Management JFR Module
2020-06-21, 12035👍, 0💬
Popular Posts:
The JMX technology provides the tools for building distributed, Web-based, modular and dynamic solut...
JasperReports, the world's most popular open source business intelligence and reporting engine and J...
JDK 11 jdk.dynalink.jmod is the JMOD file for JDK 11 Dynamic Linking module. JDK 11 Dynamic Linking ...
The Java Naming and Directory Interface (JNDI) is part of the Java platform, providing applications ...
JDK 11 java.desktop.jmod is the JMOD file for JDK 11 Desktop module. JDK 11 Desktop module compiled ...