From 1f8ab40fba40a59b0a7f58c659914d46dc6ef6aa Mon Sep 17 00:00:00 2001
From: Chris Ridd <chris.ridd@forgerock.com>
Date: Mon, 22 Sep 2014 10:25:35 +0000
Subject: [PATCH] Forward port OPENDJ-1565 CR-4564: Optionally bind to a local address
---
opendj3-server-dev/src/server/org/opends/server/replication/service/ReplicationBroker.java | 10 ++++++----
1 files changed, 6 insertions(+), 4 deletions(-)
diff --git a/opendj3-server-dev/src/server/org/opends/server/replication/service/ReplicationBroker.java b/opendj3-server-dev/src/server/org/opends/server/replication/service/ReplicationBroker.java
index 2b88d91..c37bdda 100644
--- a/opendj3-server-dev/src/server/org/opends/server/replication/service/ReplicationBroker.java
+++ b/opendj3-server-dev/src/server/org/opends/server/replication/service/ReplicationBroker.java
@@ -30,10 +30,7 @@
import java.math.BigDecimal;
import java.math.MathContext;
import java.math.RoundingMode;
-import java.net.ConnectException;
-import java.net.Socket;
-import java.net.SocketException;
-import java.net.SocketTimeoutException;
+import java.net.*;
import java.util.*;
import java.util.Map.Entry;
import java.util.concurrent.ConcurrentSkipListMap;
@@ -1121,6 +1118,11 @@
socket = new Socket();
socket.setReceiveBufferSize(1000000);
socket.setTcpNoDelay(true);
+ if (config.getSourceAddress() != null)
+ {
+ InetSocketAddress local = new InetSocketAddress(config.getSourceAddress(), 0);
+ socket.bind(local);
+ }
int timeoutMS = MultimasterReplication.getConnectionTimeoutMS();
socket.connect(HostPort.valueOf(serverURL).toInetSocketAddress(),
timeoutMS);
--
Gitblit v1.10.0