Merge branch 'opengoofy:develop' into develop

pull/1422/head
GRL-bxy 2 years ago committed by GitHub
commit f690f015b6
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

@ -26,10 +26,10 @@ coverage:
default: default:
informational: true informational: true
ignore: ignore:
- "hippo4j-example/.*" - "examples/.*"
- "docs/.*" - "docs/.*"
- "dev-support/.*" - "tests/.*"
- "hippo4j-ui/.*"
- "hippo4j-ui-new/.*"
- "checkstyle/.*" - "checkstyle/.*"
- "format/.*" - "format/.*"
- "threadpool/console-new/.*"
- "threadpool/console/.*"

7
.gitignore vendored

@ -7,7 +7,7 @@ target/
!**/dist/ !**/dist/
### Agent ### ### Agent ###
/hippo4j-agent/hippo4j-agent/ hippo4j-agent/
**/dependency-reduced-pom.xml **/dependency-reduced-pom.xml
### STS ### ### STS ###
@ -46,3 +46,8 @@ build/
docs/node_modules docs/node_modules
docs/build docs/build
docs/.docusaurus docs/.docusaurus
### Docker ###
docker/conf
docker/target

@ -5,7 +5,7 @@
<modelVersion>4.0.0</modelVersion> <modelVersion>4.0.0</modelVersion>
<parent> <parent>
<groupId>cn.hippo4j</groupId> <groupId>cn.hippo4j</groupId>
<artifactId>hippo4j-threadpool-agent</artifactId> <artifactId>hippo4j-agent</artifactId>
<version>${revision}</version> <version>${revision}</version>
</parent> </parent>
@ -29,7 +29,7 @@
</dependencies> </dependencies>
<build> <build>
<finalName>hippo4j-agent</finalName> <finalName>hippo4j-threadpool-agent</finalName>
<plugins> <plugins>
<plugin> <plugin>
<artifactId>maven-shade-plugin</artifactId> <artifactId>maven-shade-plugin</artifactId>
@ -109,7 +109,7 @@
<configuration> <configuration>
<target> <target>
<mkdir dir="${project.basedir}/../hippo4j-agent" /> <mkdir dir="${project.basedir}/../hippo4j-agent" />
<copy file="${project.build.directory}/hippo4j-agent.jar" tofile="${project.basedir}/../hippo4j-agent/hippo4j-agent.jar" overwrite="true" /> <copy file="${project.build.directory}/hippo4j-threadpool-agent.jar" tofile="${project.basedir}/../hippo4j-agent/hippo4j-threadpool-agent.jar" overwrite="true" />
<mkdir dir="${project.basedir}/../hippo4j-agent/config" /> <mkdir dir="${project.basedir}/../hippo4j-agent/config" />
<mkdir dir="${project.basedir}/../hippo4j-agent/logs" /> <mkdir dir="${project.basedir}/../hippo4j-agent/logs" />
<copydir src="${project.basedir}/../config" dest="${project.basedir}/../hippo4j-agent/config" forceoverwrite="true" /> <copydir src="${project.basedir}/../config" dest="${project.basedir}/../hippo4j-agent/config" forceoverwrite="true" />

@ -18,7 +18,6 @@
package cn.hippo4j.agent.bootstrap; package cn.hippo4j.agent.bootstrap;
import cn.hippo4j.agent.core.boot.AgentPackageNotFoundException; import cn.hippo4j.agent.core.boot.AgentPackageNotFoundException;
import cn.hippo4j.agent.core.boot.DefaultNamedThreadFactory;
import cn.hippo4j.agent.core.boot.ServiceManager; import cn.hippo4j.agent.core.boot.ServiceManager;
import cn.hippo4j.agent.core.conf.Config; import cn.hippo4j.agent.core.conf.Config;
import cn.hippo4j.agent.core.conf.SnifferConfigInitializer; import cn.hippo4j.agent.core.conf.SnifferConfigInitializer;
@ -49,15 +48,14 @@ import java.security.ProtectionDomain;
import java.util.Collections; import java.util.Collections;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
import static net.bytebuddy.matcher.ElementMatchers.nameContains; import static net.bytebuddy.matcher.ElementMatchers.nameContains;
import static net.bytebuddy.matcher.ElementMatchers.nameStartsWith; import static net.bytebuddy.matcher.ElementMatchers.nameStartsWith;
import static net.bytebuddy.matcher.ElementMatchers.not; import static net.bytebuddy.matcher.ElementMatchers.not;
/**
* Hippo4j Agent
*/
public class Hippo4jAgent { public class Hippo4jAgent {
private static ILog LOGGER = LogManager.getLogger(Hippo4jAgent.class); private static ILog LOGGER = LogManager.getLogger(Hippo4jAgent.class);
@ -151,6 +149,9 @@ public class Hippo4jAgent {
.addShutdownHook(new Thread(ServiceManager.INSTANCE::shutdown, "hippo4j service shutdown thread")); .addShutdownHook(new Thread(ServiceManager.INSTANCE::shutdown, "hippo4j service shutdown thread"));
} }
/**
* transformer
*/
private static class Transformer implements AgentBuilder.Transformer { private static class Transformer implements AgentBuilder.Transformer {
private PluginFinder pluginFinder; private PluginFinder pluginFinder;
@ -193,6 +194,9 @@ public class Hippo4jAgent {
return nameStartsWith("cn.hippo4j").and(not(nameStartsWith("cn.hippo4j.agent.toolkit."))); return nameStartsWith("cn.hippo4j").and(not(nameStartsWith("cn.hippo4j.agent.toolkit.")));
} }
/**
* listener
*/
private static class Listener implements AgentBuilder.Listener { private static class Listener implements AgentBuilder.Listener {
@Override @Override
@ -235,6 +239,9 @@ public class Hippo4jAgent {
} }
} }
/**
* redefinition listener
*/
private static class RedefinitionListener implements AgentBuilder.RedefinitionStrategy.Listener { private static class RedefinitionListener implements AgentBuilder.RedefinitionStrategy.Listener {
@Override @Override

@ -5,7 +5,7 @@
<modelVersion>4.0.0</modelVersion> <modelVersion>4.0.0</modelVersion>
<parent> <parent>
<groupId>cn.hippo4j</groupId> <groupId>cn.hippo4j</groupId>
<artifactId>hippo4j-threadpool-agent</artifactId> <artifactId>hippo4j-agent</artifactId>
<version>${revision}</version> <version>${revision}</version>
</parent> </parent>
@ -75,9 +75,13 @@
</dependency> </dependency>
<dependency> <dependency>
<groupId>cn.hippo4j</groupId> <groupId>cn.hippo4j</groupId>
<artifactId>hippo4j-threadpool-common</artifactId> <artifactId>hippo4j-threadpool-infra-common</artifactId>
<version>${project.version}</version>
</dependency>
<dependency>
<groupId>cn.hippo4j</groupId>
<artifactId>hippo4j-threadpool-dynamic-mode-config</artifactId>
<version>${project.version}</version> <version>${project.version}</version>
<scope>provided</scope>
</dependency> </dependency>
</dependencies> </dependencies>

Some files were not shown because too many files have changed in this diff Show More

Loading…
Cancel
Save