This is an automated email from the ASF dual-hosted git repository.
mikexue pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-eventmesh.git
The following commit(s) were added to refs/heads/master by this push:
new 6a8293a76 removed static parameter 'threadNum'
new 51bed70aa Merge pull request #3436 from ibrijesh/fix_patch_3254
6a8293a76 is described below
commit 6a8293a76b8464fbbcbf930ab20654cddb031d86
Author: Brijesh Yadav <[email protected]>
AuthorDate: Sun Mar 12 22:06:12 2023 +0530
removed static parameter 'threadNum'
---
.../eventmesh/runtime/boot/AbstractRemotingServer.java | 14 +++++++-------
1 file changed, 7 insertions(+), 7 deletions(-)
diff --git
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/AbstractRemotingServer.java
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/AbstractRemotingServer.java
index 858ed6993..a73e28ebc 100644
---
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/AbstractRemotingServer.java
+++
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/AbstractRemotingServer.java
@@ -88,22 +88,22 @@ public abstract class AbstractRemotingServer {
}
- private void buildIOGroup(final String threadPrefix, final int threadNum) {
+ private void buildIOGroup(final String threadPrefix) {
if (useEpoll()) {
- ioGroup = new EpollEventLoopGroup(threadNum, new
EventMeshThreadFactory(threadPrefix + "-NettyEpoll-IO"));
+ ioGroup = new EpollEventLoopGroup(MAX_THREADS, new
EventMeshThreadFactory(threadPrefix + "-NettyEpoll-IO"));
} else {
- ioGroup = new NioEventLoopGroup(threadNum, new
EventMeshThreadFactory(threadPrefix + "-NettyNio-IO"));
+ ioGroup = new NioEventLoopGroup(MAX_THREADS, new
EventMeshThreadFactory(threadPrefix + "-NettyNio-IO"));
}
}
- private void buildWorkerGroup(final String threadPrefix, final int
threadNum) {
- workerGroup = new NioEventLoopGroup(threadNum, new
EventMeshThreadFactory(threadPrefix + "-worker"));
+ private void buildWorkerGroup(final String threadPrefix) {
+ workerGroup = new NioEventLoopGroup(MAX_THREADS, new
EventMeshThreadFactory(threadPrefix + "-worker"));
}
public void init(final String threadPrefix) throws Exception {
buildBossGroup(threadPrefix);
- buildIOGroup(threadPrefix, MAX_THREADS);
- buildWorkerGroup(threadPrefix, MAX_THREADS);
+ buildIOGroup(threadPrefix);
+ buildWorkerGroup(threadPrefix);
}
public void shutdown() throws Exception {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
