| | |
| | | new ConcurrentHashMap<String, ReplicationServerDomain>(); |
| | | |
| | | private String localURL = "null"; |
| | | private boolean shutdown = false; |
| | | private volatile boolean shutdown = false; |
| | | private ReplicationDbEnv dbEnv; |
| | | private int rcvWindow; |
| | | private int queueSize; |
| | |
| | | // Read incoming messages and create LDAP or ReplicationServer listener |
| | | // and Publisher. |
| | | |
| | | ProtocolSession session; |
| | | Socket newSocket = null; |
| | | |
| | | try |
| | | { |
| | | ProtocolSession session; |
| | | Socket newSocket = null; |
| | | try |
| | | { |
| | | newSocket = listenSocket.accept(); |
| | |
| | | if (debugEnabled()) |
| | | TRACER.debugInfo("RS " +getMonitorInstanceName()+ |
| | | " creates connect thread"); |
| | | connectThread = |
| | | new ReplicationServerConnectThread("Replication Server Connect " + |
| | | serverId , this); |
| | | connectThread = new ReplicationServerConnectThread(this); |
| | | connectThread.start(); |
| | | |
| | | if (debugEnabled()) |
| | | TRACER.debugInfo("RS " +getMonitorInstanceName()+ |
| | | " creates listen thread"); |
| | | |
| | | listenThread = |
| | | new ReplicationServerListenThread("Replication Server Listener " + |
| | | serverId , this); |
| | | listenThread = new ReplicationServerListenThread(this); |
| | | listenThread.start(); |
| | | |
| | | // Creates the ECL workflow elem so that DS (LDAPReplicationDomain) |
| | |
| | | listenSocket = new ServerSocket(); |
| | | listenSocket.bind(new InetSocketAddress(replicationPort)); |
| | | |
| | | listenThread = |
| | | new ReplicationServerListenThread( |
| | | "Replication Server Listener", this); |
| | | listenThread = new ReplicationServerListenThread(this); |
| | | listenThread.start(); |
| | | } |
| | | catch (IOException e) |