You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by te...@apache.org on 2022/05/11 08:55:52 UTC
[pulsar] branch master updated: [improve][broker] Enable SO_REUSEADDR on listen sockets for broker,proxy (#15517)
This is an automated email from the ASF dual-hosted git repository.
technoboy pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new 6bd98e8266c [improve][broker] Enable SO_REUSEADDR on listen sockets for broker,proxy (#15517)
6bd98e8266c is described below
commit 6bd98e8266ce2b6f8b45a66dd6a64d3daa1e6b53
Author: Cong Zhao <zh...@apache.org>
AuthorDate: Wed May 11 16:55:42 2022 +0800
[improve][broker] Enable SO_REUSEADDR on listen sockets for broker,proxy (#15517)
---
.../src/main/java/org/apache/pulsar/broker/service/BrokerService.java | 2 ++
.../src/main/java/org/apache/pulsar/proxy/server/ProxyService.java | 2 ++
2 files changed, 4 insertions(+)
diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java
index 6a8892c646d..8873eb0992c 100644
--- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java
+++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java
@@ -420,6 +420,7 @@ public class BrokerService implements Closeable {
ServerBootstrap bootstrap;
if (useSeparateThreadPool) {
bootstrap = new ServerBootstrap();
+ bootstrap.option(ChannelOption.SO_REUSEADDR, true);
bootstrap.childOption(ChannelOption.ALLOCATOR, PulsarByteBufAllocator.DEFAULT);
bootstrap.childOption(ChannelOption.TCP_NODELAY, true);
bootstrap.childOption(ChannelOption.RCVBUF_ALLOCATOR,
@@ -445,6 +446,7 @@ public class BrokerService implements Closeable {
private ServerBootstrap defaultServerBootstrap() {
ServerBootstrap bootstrap = new ServerBootstrap();
+ bootstrap.option(ChannelOption.SO_REUSEADDR, true);
bootstrap.childOption(ChannelOption.ALLOCATOR, PulsarByteBufAllocator.DEFAULT);
bootstrap.group(acceptorGroup, workerGroup);
bootstrap.childOption(ChannelOption.TCP_NODELAY, true);
diff --git a/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ProxyService.java b/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ProxyService.java
index 1960b5143a0..4aa572f5964 100644
--- a/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ProxyService.java
+++ b/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ProxyService.java
@@ -215,6 +215,7 @@ public class ProxyService implements Closeable {
}
ServerBootstrap bootstrap = new ServerBootstrap();
+ bootstrap.option(ChannelOption.SO_REUSEADDR, true);
bootstrap.childOption(ChannelOption.ALLOCATOR, PulsarByteBufAllocator.DEFAULT);
bootstrap.group(acceptorGroup, workerGroup);
bootstrap.childOption(ChannelOption.TCP_NODELAY, true);
@@ -302,6 +303,7 @@ public class ProxyService implements Closeable {
boolean useSeparateThreadPool = proxyConfig.isUseSeparateThreadPoolForProxyExtensions();
if (useSeparateThreadPool) {
bootstrap = new ServerBootstrap();
+ bootstrap.option(ChannelOption.SO_REUSEADDR, true);
bootstrap.childOption(ChannelOption.ALLOCATOR, PulsarByteBufAllocator.DEFAULT);
bootstrap.childOption(ChannelOption.TCP_NODELAY, true);
bootstrap.childOption(ChannelOption.RCVBUF_ALLOCATOR,