From e74d325d90cb9edcfc023dafec587b5aafd0d259 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=82=85=E5=86=B2?= Date: Wed, 1 Nov 2017 09:43:18 +0800 Subject: [PATCH 1/4] #ROCKETMQ-308# nameserver socket buffer use default value. --- .../java/org/apache/rocketmq/namesrv/NamesrvStartup.java | 9 --------- 1 file changed, 9 deletions(-) diff --git a/namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvStartup.java b/namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvStartup.java index f49d2b31ffe..d1c4fd3c391 100644 --- a/namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvStartup.java +++ b/namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvStartup.java @@ -49,15 +49,6 @@ public static void main(String[] args) { public static NamesrvController main0(String[] args) { System.setProperty(RemotingCommand.REMOTING_VERSION_KEY, Integer.toString(MQVersion.CURRENT_VERSION)); - - if (null == System.getProperty(NettySystemConfig.COM_ROCKETMQ_REMOTING_SOCKET_SNDBUF_SIZE)) { - NettySystemConfig.socketSndbufSize = 4096; - } - - if (null == System.getProperty(NettySystemConfig.COM_ROCKETMQ_REMOTING_SOCKET_RCVBUF_SIZE)) { - NettySystemConfig.socketRcvbufSize = 4096; - } - try { //PackageConflictDetect.detectFastjson(); From 9cd4b8572bdc63a89f7c11d1c0c3f3b5cb7985b9 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=82=85=E5=86=B2?= Date: Wed, 1 Nov 2017 09:55:08 +0800 Subject: [PATCH 2/4] #ROCKETMQ-308# delete unused import --- .../main/java/org/apache/rocketmq/namesrv/NamesrvStartup.java | 1 - 1 file changed, 1 deletion(-) diff --git a/namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvStartup.java b/namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvStartup.java index d1c4fd3c391..a8ee0e08ed5 100644 --- a/namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvStartup.java +++ b/namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvStartup.java @@ -32,7 +32,6 @@ import org.apache.rocketmq.common.constant.LoggerName; import org.apache.rocketmq.common.namesrv.NamesrvConfig; import org.apache.rocketmq.remoting.netty.NettyServerConfig; -import org.apache.rocketmq.remoting.netty.NettySystemConfig; import org.apache.rocketmq.remoting.protocol.RemotingCommand; import org.apache.rocketmq.srvutil.ServerUtil; import org.apache.rocketmq.srvutil.ShutdownHookThread; From e9fcb072baa479af8a6c186e74d663fbc205ba2d Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=82=85=E5=86=B2?= Date: Wed, 1 Nov 2017 09:43:18 +0800 Subject: [PATCH 3/4] [ROCKETMQ-308] nameserver socket buffer use default value. --- .../java/org/apache/rocketmq/namesrv/NamesrvStartup.java | 9 --------- 1 file changed, 9 deletions(-) diff --git a/namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvStartup.java b/namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvStartup.java index f49d2b31ffe..d1c4fd3c391 100644 --- a/namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvStartup.java +++ b/namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvStartup.java @@ -49,15 +49,6 @@ public static void main(String[] args) { public static NamesrvController main0(String[] args) { System.setProperty(RemotingCommand.REMOTING_VERSION_KEY, Integer.toString(MQVersion.CURRENT_VERSION)); - - if (null == System.getProperty(NettySystemConfig.COM_ROCKETMQ_REMOTING_SOCKET_SNDBUF_SIZE)) { - NettySystemConfig.socketSndbufSize = 4096; - } - - if (null == System.getProperty(NettySystemConfig.COM_ROCKETMQ_REMOTING_SOCKET_RCVBUF_SIZE)) { - NettySystemConfig.socketRcvbufSize = 4096; - } - try { //PackageConflictDetect.detectFastjson(); From 3bcefffee9ce996243b39995ffcd02bffc52e0b7 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=82=85=E5=86=B2?= Date: Wed, 1 Nov 2017 09:55:08 +0800 Subject: [PATCH 4/4] [ROCKETMQ-308] delete unused import --- .../main/java/org/apache/rocketmq/namesrv/NamesrvStartup.java | 1 - 1 file changed, 1 deletion(-) diff --git a/namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvStartup.java b/namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvStartup.java index d1c4fd3c391..a8ee0e08ed5 100644 --- a/namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvStartup.java +++ b/namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvStartup.java @@ -32,7 +32,6 @@ import org.apache.rocketmq.common.constant.LoggerName; import org.apache.rocketmq.common.namesrv.NamesrvConfig; import org.apache.rocketmq.remoting.netty.NettyServerConfig; -import org.apache.rocketmq.remoting.netty.NettySystemConfig; import org.apache.rocketmq.remoting.protocol.RemotingCommand; import org.apache.rocketmq.srvutil.ServerUtil; import org.apache.rocketmq.srvutil.ShutdownHookThread;