mirror of https://github.com/OpenIdentityPlatform/OpenDJ.git
blame | history | patch | commit | commitdiff | ignore whitespace
Chris Ridd
22.10.2014 3405f64393cd4c4b06fdaf53b679baf68b2e8866 
 opendj-sdk/opends/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;


@@ -1088,6 +1085,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);


      newSession = replSessionSecurity.createClientSession(socket, timeoutMS);