/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/common/ |
H A D | ServerStateTest.java | 65 ServerState serverState = new ServerState() ; 68 // serverState.loadState() ; 72 assertFalse(serverState.update((ChangeNumber)null)); 73 assertTrue(serverState.update(cn)); 74 assertFalse(serverState.update(cn)); 80 assertTrue(serverState.update(cn1)) ; 81 assertTrue(serverState.update(cn2)) ; 82 assertTrue(serverState.update(cn3)) ; 86 Set<String> stringSet = serverState.toStringSet(); 91 assertEquals(cn2.compareTo(serverState [all...] |
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/common/ |
H A D | ServerStateTest.java | 65 ServerState serverState = new ServerState() ; 68 // serverState.loadState() ; 72 assertFalse(serverState.update((ChangeNumber)null)); 73 assertTrue(serverState.update(cn)); 74 assertFalse(serverState.update(cn)); 80 assertTrue(serverState.update(cn1)) ; 81 assertTrue(serverState.update(cn2)) ; 82 assertTrue(serverState.update(cn3)) ; 86 Set<String> stringSet = serverState.toStringSet(); 91 assertEquals(cn2.compareTo(serverState [all...] |
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/common/ |
H A D | ServerStateTest.java | 65 ServerState serverState = new ServerState() ; 68 // serverState.loadState() ; 72 assertFalse(serverState.update((ChangeNumber)null)); 73 assertTrue(serverState.update(cn)); 74 assertFalse(serverState.update(cn)); 80 assertTrue(serverState.update(cn1)) ; 81 assertTrue(serverState.update(cn2)) ; 82 assertTrue(serverState.update(cn3)) ; 86 Set<String> stringSet = serverState.toStringSet(); 91 assertEquals(cn2.compareTo(serverState [all...] |
/forgerock/opendj2/src/server/org/opends/server/replication/protocol/ |
H A D | ReplServerStartMsg.java | 44 private final ServerState serverState; field in class:ReplServerStartMsg 74 * @param serverState our ServerState for this baseDN. 83 ServerState serverState, 94 this.serverState = serverState; 115 * <degradedStatusThreshold><serverState> 128 serverState = scanner.nextServerStateMustComeLast(); 160 * Get the serverState. 161 * @return Returns the serverState. 165 return this.serverState; 81 ReplServerStartMsg(int serverId, String serverURL, DN baseDN, int windowSize, ServerState serverState, long generationId, boolean sslEncryption, byte groupId, int degradedStatusThreshold) argument [all...] |
H A D | ReplServerStartDSMsg.java | 44 private final ServerState serverState; field in class:ReplServerStartDSMsg 76 * @param serverState our ServerState for this baseDN. 88 ServerState serverState, 101 this.serverState = serverState; 124 * <serverState> 134 serverState = scanner.nextServerStateMustComeLast(); 166 * Get the serverState. 167 * @return Returns the serverState. 171 return this.serverState; 86 ReplServerStartDSMsg(int serverId, String serverURL, DN baseDN, int windowSize, ServerState serverState, long generationId, boolean sslEncryption, byte groupId, int degradedStatusThreshold, int weight, int connectedDSNumber) argument [all...] |
H A D | ServerStartMsg.java | 50 private final ServerState serverState; field in class:ServerStartMsg 75 * @param serverState The state of this server. 82 int windowSize, long heartbeatInterval, ServerState serverState, 98 this.serverState = serverState; 125 serverState = scanner.nextServerStateMustComeLast(); 198 return serverState; 218 builder.appendServerStateMustComeLast(serverState); 271 "\nserverState: " + serverState + 81 ServerStartMsg(int serverId2, String serverURL, DN baseDN, int windowSize, long heartbeatInterval, ServerState serverState, long generationId, boolean sslEncryption, byte groupId) argument
|
/forgerock/opendj2-hg/src/server/org/opends/server/replication/protocol/ |
H A D | ReplServerStartMsg.java | 44 private final ServerState serverState; field in class:ReplServerStartMsg 74 * @param serverState our ServerState for this baseDN. 83 ServerState serverState, 94 this.serverState = serverState; 115 * <degradedStatusThreshold><serverState> 128 serverState = scanner.nextServerStateMustComeLast(); 160 * Get the serverState. 161 * @return Returns the serverState. 165 return this.serverState; 81 ReplServerStartMsg(int serverId, String serverURL, DN baseDN, int windowSize, ServerState serverState, long generationId, boolean sslEncryption, byte groupId, int degradedStatusThreshold) argument [all...] |
H A D | ReplServerStartDSMsg.java | 44 private final ServerState serverState; field in class:ReplServerStartDSMsg 76 * @param serverState our ServerState for this baseDN. 88 ServerState serverState, 101 this.serverState = serverState; 124 * <serverState> 134 serverState = scanner.nextServerStateMustComeLast(); 166 * Get the serverState. 167 * @return Returns the serverState. 171 return this.serverState; 86 ReplServerStartDSMsg(int serverId, String serverURL, DN baseDN, int windowSize, ServerState serverState, long generationId, boolean sslEncryption, byte groupId, int degradedStatusThreshold, int weight, int connectedDSNumber) argument [all...] |
H A D | ServerStartMsg.java | 50 private final ServerState serverState; field in class:ServerStartMsg 75 * @param serverState The state of this server. 82 int windowSize, long heartbeatInterval, ServerState serverState, 98 this.serverState = serverState; 125 serverState = scanner.nextServerStateMustComeLast(); 198 return serverState; 218 builder.appendServerStateMustComeLast(serverState); 271 "\nserverState: " + serverState + 81 ServerStartMsg(int serverId2, String serverURL, DN baseDN, int windowSize, long heartbeatInterval, ServerState serverState, long generationId, boolean sslEncryption, byte groupId) argument
|
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/protocol/ |
H A D | ReplServerStartMsg.java | 44 private final ServerState serverState; field in class:ReplServerStartMsg 74 * @param serverState our ServerState for this baseDN. 83 ServerState serverState, 94 this.serverState = serverState; 115 * <degradedStatusThreshold><serverState> 128 serverState = scanner.nextServerStateMustComeLast(); 160 * Get the serverState. 161 * @return Returns the serverState. 165 return this.serverState; 81 ReplServerStartMsg(int serverId, String serverURL, DN baseDN, int windowSize, ServerState serverState, long generationId, boolean sslEncryption, byte groupId, int degradedStatusThreshold) argument [all...] |
H A D | ReplServerStartDSMsg.java | 44 private final ServerState serverState; field in class:ReplServerStartDSMsg 76 * @param serverState our ServerState for this baseDN. 88 ServerState serverState, 101 this.serverState = serverState; 124 * <serverState> 134 serverState = scanner.nextServerStateMustComeLast(); 166 * Get the serverState. 167 * @return Returns the serverState. 171 return this.serverState; 86 ReplServerStartDSMsg(int serverId, String serverURL, DN baseDN, int windowSize, ServerState serverState, long generationId, boolean sslEncryption, byte groupId, int degradedStatusThreshold, int weight, int connectedDSNumber) argument [all...] |
H A D | ServerStartMsg.java | 50 private final ServerState serverState; field in class:ServerStartMsg 75 * @param serverState The state of this server. 82 int windowSize, long heartbeatInterval, ServerState serverState, 98 this.serverState = serverState; 125 serverState = scanner.nextServerStateMustComeLast(); 198 return serverState; 218 builder.appendServerStateMustComeLast(serverState); 271 "\nserverState: " + serverState + 81 ServerStartMsg(int serverId2, String serverURL, DN baseDN, int windowSize, long heartbeatInterval, ServerState serverState, long generationId, boolean sslEncryption, byte groupId) argument
|
/forgerock/opendj2/src/server/org/opends/server/replication/common/ |
H A D | MultiDomainServerState.java | 110 ServerState serverState = list.get(baseDN); 111 if (serverState == null) 113 serverState = new ServerState(); 114 final ServerState existingSS = list.putIfAbsent(baseDN, serverState); 117 serverState = existingSS; 120 return serverState.update(csn); 129 * @param serverState 130 * The provided serverState. 132 public void update(DN baseDN, ServerState serverState) argument 134 for (CSN csn : serverState) 150 replace(DN baseDN, ServerState serverState) argument [all...] |
H A D | ServerState.java | 123 * @param serverState the server state to use for the update. 126 public boolean update(ServerState serverState) argument 128 if (serverState == null) 134 for (CSN csn : serverState.serverIdToCSN.values()) 170 * @param serverState The ServerState. 174 public boolean reload(ServerState serverState) { argument 175 if (serverState == null) { 180 return update(serverState); 310 * Check that all the CSNs in the covered serverState are also in this 311 * serverState [all...] |
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/common/ |
H A D | ServerStateTest.java | 64 ServerState serverState = new ServerState() ; 67 // serverState.loadState() ; 71 assertFalse(serverState.update((CSN)null)); 72 assertTrue(serverState.update(csn)); 73 assertFalse(serverState.update(csn)); 78 assertTrue(serverState.update(csn1)); 79 assertTrue(serverState.update(csn2)); 80 assertTrue(serverState.update(csn3)); 84 Set<String> stringSet = serverState.toStringSet(); 89 assertEquals(csn2.compareTo(serverState [all...] |
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/common/ |
H A D | ServerStateTest.java | 64 ServerState serverState = new ServerState() ; 67 // serverState.loadState() ; 71 assertFalse(serverState.update((CSN)null)); 72 assertTrue(serverState.update(csn)); 73 assertFalse(serverState.update(csn)); 78 assertTrue(serverState.update(csn1)); 79 assertTrue(serverState.update(csn2)); 80 assertTrue(serverState.update(csn3)); 84 Set<String> stringSet = serverState.toStringSet(); 89 assertEquals(csn2.compareTo(serverState [all...] |
/forgerock/opendj2-hg/src/server/org/opends/server/replication/common/ |
H A D | MultiDomainServerState.java | 110 ServerState serverState = list.get(baseDN); 111 if (serverState == null) 113 serverState = new ServerState(); 114 final ServerState existingSS = list.putIfAbsent(baseDN, serverState); 117 serverState = existingSS; 120 return serverState.update(csn); 129 * @param serverState 130 * The provided serverState. 132 public void update(DN baseDN, ServerState serverState) argument 134 for (CSN csn : serverState) 150 replace(DN baseDN, ServerState serverState) argument [all...] |
H A D | ServerState.java | 123 * @param serverState the server state to use for the update. 126 public boolean update(ServerState serverState) argument 128 if (serverState == null) 134 for (CSN csn : serverState.serverIdToCSN.values()) 170 * @param serverState The ServerState. 174 public boolean reload(ServerState serverState) { argument 175 if (serverState == null) { 180 return update(serverState); 310 * Check that all the CSNs in the covered serverState are also in this 311 * serverState [all...] |
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/common/ |
H A D | MultiDomainServerState.java | 120 ServerState serverState = list.get(baseDN); 121 if (serverState == null) 123 serverState = new ServerState(); 124 final ServerState existingSS = list.putIfAbsent(baseDN, serverState); 127 serverState = existingSS; 130 return serverState.update(csn); 139 * @param serverState 140 * The provided serverState. 142 public void update(DN baseDN, ServerState serverState) argument 144 for (CSN csn : serverState) 160 replace(DN baseDN, ServerState serverState) argument [all...] |
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/common/ |
H A D | ServerStateTest.java | 64 ServerState serverState = new ServerState() ; 67 // serverState.loadState() ; 71 assertFalse(serverState.update((CSN)null)); 72 assertTrue(serverState.update(csn)); 73 assertFalse(serverState.update(csn)); 78 assertTrue(serverState.update(csn1)); 79 assertTrue(serverState.update(csn2)); 80 assertTrue(serverState.update(csn3)); 84 Set<String> stringSet = serverState.toStringSet(); 89 assertEquals(csn2.compareTo(serverState [all...] |
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/protocol/ |
H A D | ReplServerStartMsg.java | 45 private ServerState serverState; field in class:ReplServerStartMsg 75 * @param serverState our ServerState for this baseDn. 84 ServerState serverState, 98 this.serverState = serverState; 131 * <degradedStatusThreshold><serverState> 188 serverState = new ServerState(in, pos, in.length - 1); 210 * <serverState> 256 serverState = new ServerState(in, pos, in.length - 1); 292 * Get the serverState 82 ReplServerStartMsg(int serverId, String serverURL, String baseDn, int windowSize, ServerState serverState, long generationId, boolean sslEncryption, byte groupId, int degradedStatusThreshold) argument [all...] |
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/protocol/ |
H A D | ReplServerStartMsg.java | 45 private ServerState serverState; field in class:ReplServerStartMsg 75 * @param serverState our ServerState for this baseDn. 84 ServerState serverState, 98 this.serverState = serverState; 131 * <degradedStatusThreshold><serverState> 188 serverState = new ServerState(in, pos, in.length - 1); 210 * <serverState> 256 serverState = new ServerState(in, pos, in.length - 1); 292 * Get the serverState 82 ReplServerStartMsg(int serverId, String serverURL, String baseDn, int windowSize, ServerState serverState, long generationId, boolean sslEncryption, byte groupId, int degradedStatusThreshold) argument [all...] |
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/protocol/ |
H A D | ReplServerStartMsg.java | 45 private ServerState serverState; field in class:ReplServerStartMsg 75 * @param serverState our ServerState for this baseDn. 84 ServerState serverState, 98 this.serverState = serverState; 131 * <degradedStatusThreshold><serverState> 188 serverState = new ServerState(in, pos, in.length - 1); 210 * <serverState> 256 serverState = new ServerState(in, pos, in.length - 1); 292 * Get the serverState 82 ReplServerStartMsg(int serverId, String serverURL, String baseDn, int windowSize, ServerState serverState, long generationId, boolean sslEncryption, byte groupId, int degradedStatusThreshold) argument [all...] |
/forgerock/opendj2/src/server/org/opends/server/replication/server/ |
H A D | MessageHandler.java | 111 * Specifies the current serverState of this handler. 113 private ServerState serverState; field in class:MessageHandler 409 cursor = replicationServerDomain.getCursorFrom(serverState); 477 cursor = replicationServerDomain.getCursorFrom(serverState); 532 return ServerState.diffChanges(latestState, serverState); 543 return serverState; 602 * Set the initial value of the serverState for this handler. 605 * @param serverState the provided serverState. 608 public void setInitialServerState(ServerState serverState) argument [all...] |
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/ |
H A D | MessageHandler.java | 111 * Specifies the current serverState of this handler. 113 private ServerState serverState; field in class:MessageHandler 409 cursor = replicationServerDomain.getCursorFrom(serverState); 477 cursor = replicationServerDomain.getCursorFrom(serverState); 532 return ServerState.diffChanges(latestState, serverState); 543 return serverState; 602 * Set the initial value of the serverState for this handler. 605 * @param serverState the provided serverState. 608 public void setInitialServerState(ServerState serverState) argument [all...] |