You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by aa...@apache.org on 2019/08/24 10:31:25 UTC
[pulsar] 01/03: Fix Port Manager
This is an automated email from the ASF dual-hosted git repository.
aahmed pushed a commit to branch github_exp2
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit a3f924ffe07265e8e8c810f5d1bd12570c402768
Author: Ali Ahmed <al...@gmail.com>
AuthorDate: Thu Aug 22 18:23:42 2019 -0700
Fix Port Manager
---
.../src/test/java/org/apache/bookkeeper/test/PortManager.java | 8 ++++++--
1 file changed, 6 insertions(+), 2 deletions(-)
diff --git a/managed-ledger/src/test/java/org/apache/bookkeeper/test/PortManager.java b/managed-ledger/src/test/java/org/apache/bookkeeper/test/PortManager.java
index a18cc04..65c11f5 100644
--- a/managed-ledger/src/test/java/org/apache/bookkeeper/test/PortManager.java
+++ b/managed-ledger/src/test/java/org/apache/bookkeeper/test/PortManager.java
@@ -21,6 +21,8 @@ package org.apache.bookkeeper.test;
import java.io.FileReader;
import java.io.FileWriter;
import java.io.IOException;
+import java.net.InetAddress;
+import java.net.InetSocketAddress;
import java.net.ServerSocket;
import java.nio.CharBuffer;
import java.nio.channels.FileChannel;
@@ -37,7 +39,7 @@ public class PortManager {
private static final String lockFilename = System.getProperty("test.lockFilename",
"/tmp/pulsar-test-port-manager.lock");
- private static final int basePort = Integer.valueOf(System.getProperty("test.basePort", "15000"));
+ private static final int basePort = Integer.parseInt(System.getProperty("test.basePort", "15000"));
private static final int maxPort = 32000;
@@ -95,7 +97,9 @@ public class PortManager {
port = basePort;
}
- try (ServerSocket ss = new ServerSocket(port)) {
+ try (ServerSocket ss = new ServerSocket()) {
+ ss.setReuseAddress(false);
+ ss.bind(new InetSocketAddress(InetAddress.getByName("localhost"), port), 1);
ss.close();
// Give it some time to truly close the connection
Thread.sleep(100);