Searched defs:replicationServerId (Results 1 - 18 of 18) sorted by relevance

/forgerock/opendj-b2.6/src/server/org/opends/server/replication/server/
H A DLightweightServerHandler.java72 private int replicationServerId = -1; field in class:LightweightServerHandler
105 * @param replicationServerId The serverId of the RS this remote DS is
122 int replicationServerId, int serverId, String serverUrl,
130 this.replicationServerId = replicationServerId;
159 return new DSInfo(serverId, serverUrl, replicationServerId, generationId,
121 LightweightServerHandler(ReplicationServerHandler replServerHandler, int replicationServerId, int serverId, String serverUrl, long generationId, byte groupId, ServerStatus status, List<String> refUrls, boolean assuredFlag, AssuredMode assuredMode, byte safeDataLevel, Set<String> eclInclude, Set<String> eclIncludeForDeletes, short protocolVersion) argument
H A DReplicationServerHandler.java120 replicationServerId, replicationServerURL, getServiceId(),
134 * @param replicationServerId The hosting local RS serverId.
142 int replicationServerId,
146 super(session, queueSize, replicationServerURL, replicationServerId,
138 ReplicationServerHandler( Session session, int queueSize, String replicationServerURL, int replicationServerId, ReplicationServer replicationServer, int rcvWindowSize) argument
H A DDataServerHandler.java88 * @param replicationServerId The serverID of the hosting RS.
96 int replicationServerId,
100 super(session, queueSize, replicationServerURL, replicationServerId,
615 startMsg = new ReplServerStartMsg(replicationServerId,
625 startMsg = new ReplServerStartDSMsg(replicationServerId,
644 return new DSInfo(serverId, serverURL, replicationServerId, generationId,
92 DataServerHandler( Session session, int queueSize, String replicationServerURL, int replicationServerId, ReplicationServer replicationServer, int rcvWindowSize) argument
H A DMessageHandler.java91 protected int replicationServerId; field in class:MessageHandler
140 * @param replicationServerId The ID of the hosting replication server.
146 int replicationServerId,
152 this.replicationServerId = replicationServerId;
727 return this.replicationServerId;
143 MessageHandler( int queueSize, String replicationServerURL, int replicationServerId, ReplicationServer replicationServer) argument
H A DECLServerHandler.java364 startMsg = new ReplServerStartMsg(replicationServerId,
374 startMsg = new ReplServerStartDSMsg(replicationServerId,
389 * @param replicationServerId The hosting local RS serverId.
397 int replicationServerId,
401 super(session, queueSize, replicationServerURL, replicationServerId,
418 * @param replicationServerId The hosting local RS serverId.
425 int replicationServerId,
431 super(null, 1, replicationServerURL, replicationServerId,
835 replicationServerURL, replicationServerId, replicationServer);
393 ECLServerHandler( Session session, int queueSize, String replicationServerURL, int replicationServerId, ReplicationServer replicationServer, int rcvWindowSize) argument
423 ECLServerHandler( String replicationServerURL, int replicationServerId, ReplicationServer replicationServer, StartECLSessionMsg startECLSessionMsg) argument
H A DServerHandler.java245 * @param replicationServerId The serverId of the hosting replication server.
253 int replicationServerId,
258 replicationServerId, replicationServer);
906 replicationServerId);
249 ServerHandler( Session session, int queueSize, String replicationServerURL, int replicationServerId, ReplicationServer replicationServer, int rcvWindowSize) argument
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/server/
H A DDataServerHandler.java87 * @param replicationServerId The serverID of the hosting RS.
95 int replicationServerId,
99 super(session, queueSize, replicationServerURL, replicationServerId,
584 startMsg = new ReplServerStartMsg(replicationServerId,
594 startMsg = new ReplServerStartDSMsg(replicationServerId,
613 return new DSInfo(serverId, serverURL, replicationServerId, generationId,
91 DataServerHandler( Session session, int queueSize, String replicationServerURL, int replicationServerId, ReplicationServer replicationServer, int rcvWindowSize) argument
H A DLightweightServerHandler.java72 private int replicationServerId = -1; field in class:LightweightServerHandler
105 * @param replicationServerId The serverId of the RS this remote DS is
122 int replicationServerId, int serverId, String serverUrl,
130 this.replicationServerId = replicationServerId;
159 return new DSInfo(serverId, serverUrl, replicationServerId, generationId,
121 LightweightServerHandler(ReplicationServerHandler replServerHandler, int replicationServerId, int serverId, String serverUrl, long generationId, byte groupId, ServerStatus status, List<String> refUrls, boolean assuredFlag, AssuredMode assuredMode, byte safeDataLevel, Set<String> eclInclude, Set<String> eclIncludeForDeletes, short protocolVersion) argument
H A DReplicationServerHandler.java120 replicationServerId, replicationServerURL, getServiceId(),
134 * @param replicationServerId The hosting local RS serverId.
142 int replicationServerId,
146 super(session, queueSize, replicationServerURL, replicationServerId,
138 ReplicationServerHandler( Session session, int queueSize, String replicationServerURL, int replicationServerId, ReplicationServer replicationServer, int rcvWindowSize) argument
H A DMessageHandler.java91 protected int replicationServerId; field in class:MessageHandler
140 * @param replicationServerId The ID of the hosting replication server.
146 int replicationServerId,
152 this.replicationServerId = replicationServerId;
727 return this.replicationServerId;
143 MessageHandler( int queueSize, String replicationServerURL, int replicationServerId, ReplicationServer replicationServer) argument
H A DECLServerHandler.java364 startMsg = new ReplServerStartMsg(replicationServerId,
374 startMsg = new ReplServerStartDSMsg(replicationServerId,
389 * @param replicationServerId The hosting local RS serverId.
397 int replicationServerId,
401 super(session, queueSize, replicationServerURL, replicationServerId,
418 * @param replicationServerId The hosting local RS serverId.
425 int replicationServerId,
431 super(null, 1, replicationServerURL, replicationServerId,
835 replicationServerURL, replicationServerId, replicationServer);
393 ECLServerHandler( Session session, int queueSize, String replicationServerURL, int replicationServerId, ReplicationServer replicationServer, int rcvWindowSize) argument
423 ECLServerHandler( String replicationServerURL, int replicationServerId, ReplicationServer replicationServer, StartECLSessionMsg startECLSessionMsg) argument
H A DServerHandler.java247 * @param replicationServerId The serverId of the hosting replication server.
255 int replicationServerId,
260 replicationServerId, replicationServer);
908 replicationServerId);
251 ServerHandler( Session session, int queueSize, String replicationServerURL, int replicationServerId, ReplicationServer replicationServer, int rcvWindowSize) argument
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/server/
H A DLightweightServerHandler.java72 private int replicationServerId = -1; field in class:LightweightServerHandler
105 * @param replicationServerId The serverId of the RS this remote DS is
122 int replicationServerId, int serverId, String serverUrl,
130 this.replicationServerId = replicationServerId;
159 return new DSInfo(serverId, serverUrl, replicationServerId, generationId,
121 LightweightServerHandler(ReplicationServerHandler replServerHandler, int replicationServerId, int serverId, String serverUrl, long generationId, byte groupId, ServerStatus status, List<String> refUrls, boolean assuredFlag, AssuredMode assuredMode, byte safeDataLevel, Set<String> eclInclude, Set<String> eclIncludeForDeletes, short protocolVersion) argument
H A DReplicationServerHandler.java120 replicationServerId, replicationServerURL, getServiceId(),
134 * @param replicationServerId The hosting local RS serverId.
142 int replicationServerId,
146 super(session, queueSize, replicationServerURL, replicationServerId,
138 ReplicationServerHandler( Session session, int queueSize, String replicationServerURL, int replicationServerId, ReplicationServer replicationServer, int rcvWindowSize) argument
H A DDataServerHandler.java88 * @param replicationServerId The serverID of the hosting RS.
96 int replicationServerId,
100 super(session, queueSize, replicationServerURL, replicationServerId,
615 startMsg = new ReplServerStartMsg(replicationServerId,
625 startMsg = new ReplServerStartDSMsg(replicationServerId,
644 return new DSInfo(serverId, serverURL, replicationServerId, generationId,
92 DataServerHandler( Session session, int queueSize, String replicationServerURL, int replicationServerId, ReplicationServer replicationServer, int rcvWindowSize) argument
H A DMessageHandler.java91 protected int replicationServerId; field in class:MessageHandler
140 * @param replicationServerId The ID of the hosting replication server.
146 int replicationServerId,
152 this.replicationServerId = replicationServerId;
727 return this.replicationServerId;
143 MessageHandler( int queueSize, String replicationServerURL, int replicationServerId, ReplicationServer replicationServer) argument
H A DECLServerHandler.java364 startMsg = new ReplServerStartMsg(replicationServerId,
374 startMsg = new ReplServerStartDSMsg(replicationServerId,
389 * @param replicationServerId The hosting local RS serverId.
397 int replicationServerId,
401 super(session, queueSize, replicationServerURL, replicationServerId,
418 * @param replicationServerId The hosting local RS serverId.
425 int replicationServerId,
431 super(null, 1, replicationServerURL, replicationServerId,
835 replicationServerURL, replicationServerId, replicationServer);
393 ECLServerHandler( Session session, int queueSize, String replicationServerURL, int replicationServerId, ReplicationServer replicationServer, int rcvWindowSize) argument
423 ECLServerHandler( String replicationServerURL, int replicationServerId, ReplicationServer replicationServer, StartECLSessionMsg startECLSessionMsg) argument
H A DServerHandler.java245 * @param replicationServerId The serverId of the hosting replication server.
253 int replicationServerId,
258 replicationServerId, replicationServer);
906 replicationServerId);
249 ServerHandler( Session session, int queueSize, String replicationServerURL, int replicationServerId, ReplicationServer replicationServer, int rcvWindowSize) argument

Completed in 92 milliseconds