| /forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/ |
| H A D | MessageHandler.java | 95 /** Specifies the current serverState of this handler. */
96 private ServerState serverState; field in class:MessageHandler
375 try (DBCursor<UpdateMsg> cursor = replicationServerDomain.getCursorFrom(serverState);)
429 try (DBCursor<UpdateMsg> cursor = replicationServerDomain.getCursorFrom(serverState))
481 return ServerState.diffChanges(latestState, serverState);
492 return serverState;
536 * Set the initial value of the serverState for this handler.
539 * @param serverState the provided serverState.
542 public void setInitialServerState(ServerState serverState) argument
[all...] |
| /forgerock/opendj-b2.6/src/server/org/opends/server/replication/protocol/ |
| H A D | ReplServerStartDSMsg.java | 45 private ServerState serverState; field in class:ReplServerStartDSMsg
77 * @param serverState our ServerState for this baseDn.
89 ServerState serverState,
105 this.serverState = serverState;
131 * <serverState>
204 serverState = new ServerState(in, pos, in.length - 1);
240 * Get the serverState.
241 * @return Returns the serverState.
245 return this.serverState;
87 ReplServerStartDSMsg(int serverId, String serverURL, String baseDn, int windowSize, ServerState serverState, long generationId, boolean sslEncryption, byte groupId, int degradedStatusThreshold, int weight, int connectedDSNumber) argument
[all...] |
| H A D | ServerStartECLMsg.java | 48 private ServerState serverState = null; field in class:ServerStartECLMsg
75 * @param serverState The state of this server.
85 ServerState serverState,
100 this.serverState = serverState;
186 serverState = new ServerState(in, pos, in.length - 1);
245 return serverState;
270 byte[] byteServerState = serverState.getBytes();
362 "\nserverState: " + serverState +
81 ServerStartECLMsg(String serverURL, int maxReceiveDelay, int maxReceiveQueue, int maxSendDelay, int maxSendQueue, int windowSize, long heartbeatInterval, ServerState serverState, long generationId, boolean sslEncryption, byte groupId) argument
|
| H A D | ServerStartMsg.java | 50 private ServerState serverState = null; field in class:ServerStartMsg
75 * @param serverState The state of this server.
82 int windowSize, long heartbeatInterval, ServerState serverState,
98 this.serverState = serverState;
200 serverState = new ServerState(in, pos, in.length - 1);
277 return serverState;
304 byte[] byteServerState = serverState.getBytes();
403 "\nserverState: " + serverState +
81 ServerStartMsg(int serverId2, String serverURL, String baseDn, int windowSize, long heartbeatInterval, ServerState serverState, long generationId, boolean sslEncryption, byte groupId) argument
|
| /forgerock/opendj2.6.2/src/server/org/opends/server/replication/protocol/ |
| H A D | ReplServerStartDSMsg.java | 45 private ServerState serverState; field in class:ReplServerStartDSMsg
77 * @param serverState our ServerState for this baseDn.
89 ServerState serverState,
105 this.serverState = serverState;
131 * <serverState>
204 serverState = new ServerState(in, pos, in.length - 1);
240 * Get the serverState.
241 * @return Returns the serverState.
245 return this.serverState;
87 ReplServerStartDSMsg(int serverId, String serverURL, String baseDn, int windowSize, ServerState serverState, long generationId, boolean sslEncryption, byte groupId, int degradedStatusThreshold, int weight, int connectedDSNumber) argument
[all...] |
| H A D | ServerStartECLMsg.java | 48 private ServerState serverState = null; field in class:ServerStartECLMsg
75 * @param serverState The state of this server.
85 ServerState serverState,
100 this.serverState = serverState;
186 serverState = new ServerState(in, pos, in.length - 1);
245 return serverState;
270 byte[] byteServerState = serverState.getBytes();
362 "\nserverState: " + serverState +
81 ServerStartECLMsg(String serverURL, int maxReceiveDelay, int maxReceiveQueue, int maxSendDelay, int maxSendQueue, int windowSize, long heartbeatInterval, ServerState serverState, long generationId, boolean sslEncryption, byte groupId) argument
|
| H A D | ServerStartMsg.java | 50 private ServerState serverState = null; field in class:ServerStartMsg
75 * @param serverState The state of this server.
82 int windowSize, long heartbeatInterval, ServerState serverState,
98 this.serverState = serverState;
200 serverState = new ServerState(in, pos, in.length - 1);
277 return serverState;
304 byte[] byteServerState = serverState.getBytes();
403 "\nserverState: " + serverState +
81 ServerStartMsg(int serverId2, String serverURL, String baseDn, int windowSize, long heartbeatInterval, ServerState serverState, long generationId, boolean sslEncryption, byte groupId) argument
|
| /forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/protocol/ |
| H A D | ReplServerStartDSMsg.java | 45 private ServerState serverState; field in class:ReplServerStartDSMsg
77 * @param serverState our ServerState for this baseDn.
89 ServerState serverState,
105 this.serverState = serverState;
131 * <serverState>
204 serverState = new ServerState(in, pos, in.length - 1);
240 * Get the serverState.
241 * @return Returns the serverState.
245 return this.serverState;
87 ReplServerStartDSMsg(int serverId, String serverURL, String baseDn, int windowSize, ServerState serverState, long generationId, boolean sslEncryption, byte groupId, int degradedStatusThreshold, int weight, int connectedDSNumber) argument
[all...] |
| H A D | ServerStartECLMsg.java | 48 private ServerState serverState = null; field in class:ServerStartECLMsg
75 * @param serverState The state of this server.
85 ServerState serverState,
100 this.serverState = serverState;
186 serverState = new ServerState(in, pos, in.length - 1);
245 return serverState;
270 byte[] byteServerState = serverState.getBytes();
362 "\nserverState: " + serverState +
81 ServerStartECLMsg(String serverURL, int maxReceiveDelay, int maxReceiveQueue, int maxSendDelay, int maxSendQueue, int windowSize, long heartbeatInterval, ServerState serverState, long generationId, boolean sslEncryption, byte groupId) argument
|
| H A D | ServerStartMsg.java | 50 private ServerState serverState = null; field in class:ServerStartMsg
75 * @param serverState The state of this server.
82 int windowSize, long heartbeatInterval, ServerState serverState,
98 this.serverState = serverState;
200 serverState = new ServerState(in, pos, in.length - 1);
277 return serverState;
304 byte[] byteServerState = serverState.getBytes();
403 "\nserverState: " + serverState +
81 ServerStartMsg(int serverId2, String serverURL, String baseDn, int windowSize, long heartbeatInterval, ServerState serverState, long generationId, boolean sslEncryption, byte groupId) argument
|
| /forgerock/opendj-b2.6/src/server/org/opends/server/replication/server/ |
| H A D | MessageHandler.java | 117 * Specifies the current serverState of this handler.
119 private ServerState serverState; field in class:MessageHandler
316 ChangeNumber lastCsn = serverState
500 ChangeNumber lastCsn = serverState.getMaxChangeNumber(serverId);
577 return ServerState.diffChanges(dbState, serverState);
589 return serverState;
639 * Set the initial value of the serverState for this handler.
642 * @param serverState the provided serverState.
645 public void setInitialServerState(ServerState serverState) argument
[all...] |
| /forgerock/opendj2.6.2/src/server/org/opends/server/replication/server/ |
| H A D | MessageHandler.java | 117 * Specifies the current serverState of this handler.
119 private ServerState serverState; field in class:MessageHandler
316 ChangeNumber lastCsn = serverState
500 ChangeNumber lastCsn = serverState.getMaxChangeNumber(serverId);
577 return ServerState.diffChanges(dbState, serverState);
589 return serverState;
639 * Set the initial value of the serverState for this handler.
642 * @param serverState the provided serverState.
645 public void setInitialServerState(ServerState serverState) argument
[all...] |
| /forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/server/ |
| H A D | MessageHandler.java | 117 * Specifies the current serverState of this handler.
119 private ServerState serverState; field in class:MessageHandler
316 ChangeNumber lastCsn = serverState
500 ChangeNumber lastCsn = serverState.getMaxChangeNumber(serverId);
577 return ServerState.diffChanges(dbState, serverState);
589 return serverState;
639 * Set the initial value of the serverState for this handler.
642 * @param serverState the provided serverState.
645 public void setInitialServerState(ServerState serverState) argument
[all...] |
| /forgerock/opendj2/src/server/org/opends/server/replication/server/changelog/je/ |
| H A D | MultiDomainDBCursor.java | 95 final ServerState serverState = entry.getValue();
97 domainDB.getCursorFrom(baseDN, serverState, matchingStrategy, positionStrategy);
|
| /forgerock/opendj2-hg/src/server/org/opends/server/replication/server/changelog/je/ |
| H A D | MultiDomainDBCursor.java | 95 final ServerState serverState = entry.getValue();
97 domainDB.getCursorFrom(baseDN, serverState, matchingStrategy, positionStrategy);
|
| /forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/changelog/file/ |
| H A D | MultiDomainDBCursor.java | 85 final ServerState serverState = entry.getValue();
86 final DBCursor<UpdateMsg> domainDBCursor = domainDB.getCursorFrom(baseDN, serverState, options);
|
| /forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/common/ |
| H A D | ServerState.java | 129 * @param serverState the server state to use for the update.
132 public boolean update(ServerState serverState) argument
134 if (serverState == null)
140 for (CSN csn : serverState.serverIdToCSN.values())
176 * @param serverState The ServerState.
180 public boolean reload(ServerState serverState) { argument
181 if (serverState == null) {
186 return update(serverState);
336 * Check that all the CSNs in the covered serverState are also in this
337 * serverState
[all...] |
| /forgerock/opendj-b2.6/src/server/org/opends/server/replication/common/ |
| H A D | ServerState.java | 185 * @param serverState the server state to use for the update.
189 public boolean update(ServerState serverState) argument
191 if (serverState == null)
196 for (ChangeNumber cn : serverState.list.values())
210 * @param serverState The ServerState.
214 public boolean reload(ServerState serverState) { argument
215 if (serverState == null) {
224 for (Integer id : serverState) {
225 ChangeNumber maxChangeNumber = serverState.getMaxChangeNumber(id);
434 * Check that all the ChangeNumbers in the covered serverState ar
[all...] |
| H A D | MultiDomainServerState.java | 127 * @param serverState The provided serverState.
129 public void update(String serviceId, ServerState serverState) argument
131 list.put(serviceId,serverState.duplicate());
|
| /forgerock/opendj2.6.2/src/server/org/opends/server/replication/common/ |
| H A D | ServerState.java | 185 * @param serverState the server state to use for the update.
189 public boolean update(ServerState serverState) argument
191 if (serverState == null)
196 for (ChangeNumber cn : serverState.list.values())
210 * @param serverState The ServerState.
214 public boolean reload(ServerState serverState) { argument
215 if (serverState == null) {
224 for (Integer id : serverState) {
225 ChangeNumber maxChangeNumber = serverState.getMaxChangeNumber(id);
434 * Check that all the ChangeNumbers in the covered serverState ar
[all...] |
| H A D | MultiDomainServerState.java | 127 * @param serverState The provided serverState.
129 public void update(String serviceId, ServerState serverState) argument
131 list.put(serviceId,serverState.duplicate());
|
| /forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/common/ |
| H A D | ServerState.java | 185 * @param serverState the server state to use for the update.
189 public boolean update(ServerState serverState) argument
191 if (serverState == null)
196 for (ChangeNumber cn : serverState.list.values())
210 * @param serverState The ServerState.
214 public boolean reload(ServerState serverState) { argument
215 if (serverState == null) {
224 for (Integer id : serverState) {
225 ChangeNumber maxChangeNumber = serverState.getMaxChangeNumber(id);
434 * Check that all the ChangeNumbers in the covered serverState ar
[all...] |
| H A D | MultiDomainServerState.java | 127 * @param serverState The provided serverState.
129 public void update(String serviceId, ServerState serverState) argument
131 list.put(serviceId,serverState.duplicate());
|
| /forgerock/opendj2/src/server/org/opends/server/replication/protocol/ |
| H A D | ByteArrayBuilder.java | 298 * @param serverState
303 public ByteArrayBuilder appendServerStateMustComeLast(ServerState serverState) argument
305 final Map<Integer, CSN> serverIdToCSN = serverState.getServerIdToCSNMap();
|
| /forgerock/opendj2-hg/src/server/org/opends/server/replication/protocol/ |
| H A D | ByteArrayBuilder.java | 298 * @param serverState
303 public ByteArrayBuilder appendServerStateMustComeLast(ServerState serverState) argument
305 final Map<Integer, CSN> serverIdToCSN = serverState.getServerIdToCSNMap();
|