/forgerock/opendj2/src/server/org/opends/server/replication/protocol/ |
H A D | ReplServerStartDSMsg.java | 57 private int degradedStatusThreshold = -1; field in class:ReplServerStartDSMsg 81 * @param degradedStatusThreshold The degraded status threshold 92 int degradedStatusThreshold, 104 this.degradedStatusThreshold = degradedStatusThreshold; 123 * <degradedStatusThreshold><weight><connectedDSNumber> 131 degradedStatusThreshold =scanner.nextIntUTF8(); 180 * <degradedStatusThreshold><weight><connectedDSNumber> 190 builder.appendIntUTF8(degradedStatusThreshold); 225 return degradedStatusThreshold; 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 232 setDegradedStatusThreshold(int degradedStatusThreshold) argument [all...] |
H A D | ReplServerStartMsg.java | 55 * degradedStatusThreshold value being used only by a DS, it could be removed 65 private int degradedStatusThreshold = -1; field in class:ReplServerStartMsg 79 * @param degradedStatusThreshold The degraded status threshold 87 int degradedStatusThreshold) 97 this.degradedStatusThreshold = degradedStatusThreshold; 115 * <degradedStatusThreshold><serverState> 125 degradedStatusThreshold = scanner.nextIntUTF8(); 191 * <degradedStatusThreshold><serverState> 199 builder.appendIntUTF8(degradedStatusThreshold); 81 ReplServerStartMsg(int serverId, String serverURL, DN baseDN, int windowSize, ServerState serverState, long generationId, boolean sslEncryption, byte groupId, int degradedStatusThreshold) argument 240 setDegradedStatusThreshold(int degradedStatusThreshold) argument [all...] |
/forgerock/opendj2-hg/src/server/org/opends/server/replication/protocol/ |
H A D | ReplServerStartDSMsg.java | 57 private int degradedStatusThreshold = -1; field in class:ReplServerStartDSMsg 81 * @param degradedStatusThreshold The degraded status threshold 92 int degradedStatusThreshold, 104 this.degradedStatusThreshold = degradedStatusThreshold; 123 * <degradedStatusThreshold><weight><connectedDSNumber> 131 degradedStatusThreshold =scanner.nextIntUTF8(); 180 * <degradedStatusThreshold><weight><connectedDSNumber> 190 builder.appendIntUTF8(degradedStatusThreshold); 225 return degradedStatusThreshold; 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 232 setDegradedStatusThreshold(int degradedStatusThreshold) argument [all...] |
H A D | ReplServerStartMsg.java | 55 * degradedStatusThreshold value being used only by a DS, it could be removed 65 private int degradedStatusThreshold = -1; field in class:ReplServerStartMsg 79 * @param degradedStatusThreshold The degraded status threshold 87 int degradedStatusThreshold) 97 this.degradedStatusThreshold = degradedStatusThreshold; 115 * <degradedStatusThreshold><serverState> 125 degradedStatusThreshold = scanner.nextIntUTF8(); 191 * <degradedStatusThreshold><serverState> 199 builder.appendIntUTF8(degradedStatusThreshold); 81 ReplServerStartMsg(int serverId, String serverURL, DN baseDN, int windowSize, ServerState serverState, long generationId, boolean sslEncryption, byte groupId, int degradedStatusThreshold) argument 240 setDegradedStatusThreshold(int degradedStatusThreshold) argument [all...] |
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/protocol/ |
H A D | ReplServerStartDSMsg.java | 57 private int degradedStatusThreshold = -1; field in class:ReplServerStartDSMsg 81 * @param degradedStatusThreshold The degraded status threshold 92 int degradedStatusThreshold, 104 this.degradedStatusThreshold = degradedStatusThreshold; 123 * <degradedStatusThreshold><weight><connectedDSNumber> 131 degradedStatusThreshold =scanner.nextIntUTF8(); 180 * <degradedStatusThreshold><weight><connectedDSNumber> 190 builder.appendIntUTF8(degradedStatusThreshold); 225 return degradedStatusThreshold; 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 232 setDegradedStatusThreshold(int degradedStatusThreshold) argument [all...] |
H A D | ReplServerStartMsg.java | 55 * degradedStatusThreshold value being used only by a DS, it could be removed 65 private int degradedStatusThreshold = -1; field in class:ReplServerStartMsg 79 * @param degradedStatusThreshold The degraded status threshold 87 int degradedStatusThreshold) 97 this.degradedStatusThreshold = degradedStatusThreshold; 115 * <degradedStatusThreshold><serverState> 125 degradedStatusThreshold = scanner.nextIntUTF8(); 191 * <degradedStatusThreshold><serverState> 199 builder.appendIntUTF8(degradedStatusThreshold); 81 ReplServerStartMsg(int serverId, String serverURL, DN baseDN, int windowSize, ServerState serverState, long generationId, boolean sslEncryption, byte groupId, int degradedStatusThreshold) argument 240 setDegradedStatusThreshold(int degradedStatusThreshold) argument [all...] |
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/server/ |
H A D | StatusAnalyzer.java | 60 private volatile int degradedStatusThreshold = -1; field in class:StatusAnalyzer 73 * @param degradedStatusThreshold The pending changes threshold value to be 77 int degradedStatusThreshold) 85 this.degradedStatusThreshold = degradedStatusThreshold; 147 if (degradedStatusThreshold > 0) 153 if (nChanges >= degradedStatusThreshold) 250 * @param degradedStatusThreshold The new threshold value. 252 public void setDegradedStatusThreshold(int degradedStatusThreshold) argument 258 degradedStatusThreshold); 76 StatusAnalyzer(ReplicationServerDomain replicationServerDomain, int degradedStatusThreshold) argument [all...] |
H A D | ReplicationServer.java | 136 private int degradedStatusThreshold = 5000; field in class:ReplicationServer 247 degradedStatusThreshold = configuration.getDegradedStatusThreshold(); 1059 if (degradedStatusThreshold != configuration 1062 int oldThresholdValue = degradedStatusThreshold; 1063 degradedStatusThreshold = configuration 1067 if (degradedStatusThreshold == 0) 1075 domain.updateStatusAnalyzer(degradedStatusThreshold); 1508 return degradedStatusThreshold;
|
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/server/ |
H A D | ReplServerFakeConfiguration.java | 61 private int degradedStatusThreshold = 5000; field in class:ReplServerFakeConfiguration 117 int groupId, long assuredTimeout, int degradedStatusThreshold) 122 this.degradedStatusThreshold = degradedStatusThreshold; 131 int groupId, long assuredTimeout, int degradedStatusThreshold, int weight) 134 groupId, assuredTimeout, degradedStatusThreshold); 247 return degradedStatusThreshold; 250 public void setDegradedStatusThreshold(int degradedStatusThreshold) argument 252 this.degradedStatusThreshold = degradedStatusThreshold; 114 ReplServerFakeConfiguration( int port, String dirName, int purgeDelay, int serverId, int queueSize, int windowSize, SortedSet<String> servers, int groupId, long assuredTimeout, int degradedStatusThreshold) argument 128 ReplServerFakeConfiguration( int port, String dirName, int purgeDelay, int serverId, int queueSize, int windowSize, SortedSet<String> servers, int groupId, long assuredTimeout, int degradedStatusThreshold, int weight) argument [all...] |
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/server/ |
H A D | ReplServerFakeConfiguration.java | 63 private int degradedStatusThreshold = 5000; field in class:ReplServerFakeConfiguration 119 int groupId, long assuredTimeout, int degradedStatusThreshold) 124 this.degradedStatusThreshold = degradedStatusThreshold; 133 int groupId, long assuredTimeout, int degradedStatusThreshold, int weight) 136 groupId, assuredTimeout, degradedStatusThreshold); 257 return degradedStatusThreshold; 260 public void setDegradedStatusThreshold(int degradedStatusThreshold) argument 262 this.degradedStatusThreshold = degradedStatusThreshold; 116 ReplServerFakeConfiguration( int port, String dirName, int purgeDelay, int serverId, int queueSize, int windowSize, SortedSet<String> servers, int groupId, long assuredTimeout, int degradedStatusThreshold) argument 130 ReplServerFakeConfiguration( int port, String dirName, int purgeDelay, int serverId, int queueSize, int windowSize, SortedSet<String> servers, int groupId, long assuredTimeout, int degradedStatusThreshold, int weight) argument [all...] |
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/server/ |
H A D | ReplServerFakeConfiguration.java | 61 private int degradedStatusThreshold = 5000; field in class:ReplServerFakeConfiguration 117 int groupId, long assuredTimeout, int degradedStatusThreshold) 122 this.degradedStatusThreshold = degradedStatusThreshold; 131 int groupId, long assuredTimeout, int degradedStatusThreshold, int weight) 134 groupId, assuredTimeout, degradedStatusThreshold); 247 return degradedStatusThreshold; 250 public void setDegradedStatusThreshold(int degradedStatusThreshold) argument 252 this.degradedStatusThreshold = degradedStatusThreshold; 114 ReplServerFakeConfiguration( int port, String dirName, int purgeDelay, int serverId, int queueSize, int windowSize, SortedSet<String> servers, int groupId, long assuredTimeout, int degradedStatusThreshold) argument 128 ReplServerFakeConfiguration( int port, String dirName, int purgeDelay, int serverId, int queueSize, int windowSize, SortedSet<String> servers, int groupId, long assuredTimeout, int degradedStatusThreshold, int weight) argument [all...] |
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/server/ |
H A D | StatusAnalyzer.java | 60 private volatile int degradedStatusThreshold = -1; field in class:StatusAnalyzer 73 * @param degradedStatusThreshold The pending changes threshold value to be 77 int degradedStatusThreshold) 85 this.degradedStatusThreshold = degradedStatusThreshold; 147 if (degradedStatusThreshold > 0) 153 if (nChanges >= degradedStatusThreshold) 250 * @param degradedStatusThreshold The new threshold value. 252 public void setDegradedStatusThreshold(int degradedStatusThreshold) argument 258 degradedStatusThreshold); 76 StatusAnalyzer(ReplicationServerDomain replicationServerDomain, int degradedStatusThreshold) argument [all...] |
H A D | ReplicationServer.java | 136 private int degradedStatusThreshold = 5000; field in class:ReplicationServer 247 degradedStatusThreshold = configuration.getDegradedStatusThreshold(); 1059 if (degradedStatusThreshold != configuration 1062 int oldThresholdValue = degradedStatusThreshold; 1063 degradedStatusThreshold = configuration 1067 if (degradedStatusThreshold == 0) 1075 domain.updateStatusAnalyzer(degradedStatusThreshold); 1508 return degradedStatusThreshold;
|
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/server/ |
H A D | ReplServerFakeConfiguration.java | 65 private int degradedStatusThreshold = 5000; field in class:ReplServerFakeConfiguration 126 SortedSet<String> servers, int groupId, long assuredTimeout, int degradedStatusThreshold) 131 this.degradedStatusThreshold = degradedStatusThreshold; 140 SortedSet<String> servers, int groupId, long assuredTimeout, int degradedStatusThreshold, int weight) 143 servers, groupId, assuredTimeout, degradedStatusThreshold); 276 return degradedStatusThreshold; 279 public void setDegradedStatusThreshold(int degradedStatusThreshold) argument 281 this.degradedStatusThreshold = degradedStatusThreshold; 123 ReplServerFakeConfiguration( int port, String dirName, ReplicationDBImplementation dbImpl, int purgeDelay, int serverId, int queueSize, int windowSize, SortedSet<String> servers, int groupId, long assuredTimeout, int degradedStatusThreshold) argument 137 ReplServerFakeConfiguration( int port, String dirName, ReplicationDBImplementation dbImpl, int purgeDelay, int serverId, int queueSize, int windowSize, SortedSet<String> servers, int groupId, long assuredTimeout, int degradedStatusThreshold, int weight) argument [all...] |
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/server/ |
H A D | ReplServerFakeConfiguration.java | 65 private int degradedStatusThreshold = 5000; field in class:ReplServerFakeConfiguration 126 SortedSet<String> servers, int groupId, long assuredTimeout, int degradedStatusThreshold) 131 this.degradedStatusThreshold = degradedStatusThreshold; 140 SortedSet<String> servers, int groupId, long assuredTimeout, int degradedStatusThreshold, int weight) 143 servers, groupId, assuredTimeout, degradedStatusThreshold); 276 return degradedStatusThreshold; 279 public void setDegradedStatusThreshold(int degradedStatusThreshold) argument 281 this.degradedStatusThreshold = degradedStatusThreshold; 123 ReplServerFakeConfiguration( int port, String dirName, ReplicationDBImplementation dbImpl, int purgeDelay, int serverId, int queueSize, int windowSize, SortedSet<String> servers, int groupId, long assuredTimeout, int degradedStatusThreshold) argument 137 ReplServerFakeConfiguration( int port, String dirName, ReplicationDBImplementation dbImpl, int purgeDelay, int serverId, int queueSize, int windowSize, SortedSet<String> servers, int groupId, long assuredTimeout, int degradedStatusThreshold, int weight) argument [all...] |
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/server/ |
H A D | ReplServerFakeConfiguration.java | 64 private int degradedStatusThreshold = 5000; field in class:ReplServerFakeConfiguration 117 SortedSet<String> servers, int groupId, long assuredTimeout, int degradedStatusThreshold) 122 this.degradedStatusThreshold = degradedStatusThreshold; 128 SortedSet<String> servers, int groupId, long assuredTimeout, int degradedStatusThreshold, int weight) 131 servers, groupId, assuredTimeout, degradedStatusThreshold); 224 return degradedStatusThreshold; 227 public void setDegradedStatusThreshold(int degradedStatusThreshold) argument 229 this.degradedStatusThreshold = degradedStatusThreshold; 115 ReplServerFakeConfiguration( int port, String dirName, int purgeDelay, int serverId, int queueSize, int windowSize, SortedSet<String> servers, int groupId, long assuredTimeout, int degradedStatusThreshold) argument 126 ReplServerFakeConfiguration( int port, String dirName, int purgeDelay, int serverId, int queueSize, int windowSize, SortedSet<String> servers, int groupId, long assuredTimeout, int degradedStatusThreshold, int weight) argument [all...] |
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/protocol/ |
H A D | ReplServerStartDSMsg.java | 58 private int degradedStatusThreshold = -1; field in class:ReplServerStartDSMsg 82 * @param degradedStatusThreshold The degraded status threshold 93 int degradedStatusThreshold, 108 this.degradedStatusThreshold = degradedStatusThreshold; 130 * <degradedStatusThreshold><weight><connectedDSNumber> 177 degradedStatusThreshold = 257 * <degradedStatusThreshold><weight><connectedDSNumber> 268 String.valueOf(degradedStatusThreshold).getBytes("UTF-8"); 344 return degradedStatusThreshold; 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 351 setDegradedStatusThreshold(int degradedStatusThreshold) argument [all...] |
H A D | ReplServerStartMsg.java | 56 * degradedStatusThreshold value being used only by a DS, it could be removed 66 private int degradedStatusThreshold = -1; field in class:ReplServerStartMsg 80 * @param degradedStatusThreshold The degraded status threshold 88 int degradedStatusThreshold) 101 this.degradedStatusThreshold = degradedStatusThreshold; 131 * <degradedStatusThreshold><serverState> 177 degradedStatusThreshold = 316 * <degradedStatusThreshold><serverState> 327 String.valueOf(degradedStatusThreshold) 82 ReplServerStartMsg(int serverId, String serverURL, String baseDn, int windowSize, ServerState serverState, long generationId, boolean sslEncryption, byte groupId, int degradedStatusThreshold) argument 400 setDegradedStatusThreshold(int degradedStatusThreshold) argument [all...] |
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/protocol/ |
H A D | ReplServerStartDSMsg.java | 58 private int degradedStatusThreshold = -1; field in class:ReplServerStartDSMsg 82 * @param degradedStatusThreshold The degraded status threshold 93 int degradedStatusThreshold, 108 this.degradedStatusThreshold = degradedStatusThreshold; 130 * <degradedStatusThreshold><weight><connectedDSNumber> 177 degradedStatusThreshold = 257 * <degradedStatusThreshold><weight><connectedDSNumber> 268 String.valueOf(degradedStatusThreshold).getBytes("UTF-8"); 344 return degradedStatusThreshold; 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 351 setDegradedStatusThreshold(int degradedStatusThreshold) argument [all...] |
H A D | ReplServerStartMsg.java | 56 * degradedStatusThreshold value being used only by a DS, it could be removed 66 private int degradedStatusThreshold = -1; field in class:ReplServerStartMsg 80 * @param degradedStatusThreshold The degraded status threshold 88 int degradedStatusThreshold) 101 this.degradedStatusThreshold = degradedStatusThreshold; 131 * <degradedStatusThreshold><serverState> 177 degradedStatusThreshold = 316 * <degradedStatusThreshold><serverState> 327 String.valueOf(degradedStatusThreshold) 82 ReplServerStartMsg(int serverId, String serverURL, String baseDn, int windowSize, ServerState serverState, long generationId, boolean sslEncryption, byte groupId, int degradedStatusThreshold) argument 400 setDegradedStatusThreshold(int degradedStatusThreshold) argument [all...] |
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/protocol/ |
H A D | ReplServerStartDSMsg.java | 58 private int degradedStatusThreshold = -1; field in class:ReplServerStartDSMsg 82 * @param degradedStatusThreshold The degraded status threshold 93 int degradedStatusThreshold, 108 this.degradedStatusThreshold = degradedStatusThreshold; 130 * <degradedStatusThreshold><weight><connectedDSNumber> 177 degradedStatusThreshold = 257 * <degradedStatusThreshold><weight><connectedDSNumber> 268 String.valueOf(degradedStatusThreshold).getBytes("UTF-8"); 344 return degradedStatusThreshold; 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 351 setDegradedStatusThreshold(int degradedStatusThreshold) argument [all...] |
H A D | ReplServerStartMsg.java | 56 * degradedStatusThreshold value being used only by a DS, it could be removed 66 private int degradedStatusThreshold = -1; field in class:ReplServerStartMsg 80 * @param degradedStatusThreshold The degraded status threshold 88 int degradedStatusThreshold) 101 this.degradedStatusThreshold = degradedStatusThreshold; 131 * <degradedStatusThreshold><serverState> 177 degradedStatusThreshold = 316 * <degradedStatusThreshold><serverState> 327 String.valueOf(degradedStatusThreshold) 82 ReplServerStartMsg(int serverId, String serverURL, String baseDn, int windowSize, ServerState serverState, long generationId, boolean sslEncryption, byte groupId, int degradedStatusThreshold) argument 400 setDegradedStatusThreshold(int degradedStatusThreshold) argument [all...] |
/forgerock/opendj2/src/server/org/opends/server/replication/service/ |
H A D | ReplicationBroker.java | 392 private final int degradedStatusThreshold; field in class:ReplicationBroker.ReplicationServerInfo 463 this.degradedStatusThreshold = msg.getDegradedStatusThreshold(); 483 this.degradedStatusThreshold = msg.getDegradedStatusThreshold(); 507 this.degradedStatusThreshold = -1; 595 * @return the degradedStatusThreshold 599 return degradedStatusThreshold; 1008 * @param degradedStatusThreshold The degraded status threshold of the RS 1013 ServerState rsState, int degradedStatusThreshold, long dsGenId) 1050 if (degradedStatusThreshold > 0 && nChanges >= degradedStatusThreshold) 1012 computeInitialServerStatus(long rsGenId, ServerState rsState, int degradedStatusThreshold, long dsGenId) argument [all...] |
/forgerock/opendj2-hg/src/server/org/opends/server/replication/service/ |
H A D | ReplicationBroker.java | 392 private final int degradedStatusThreshold; field in class:ReplicationBroker.ReplicationServerInfo 463 this.degradedStatusThreshold = msg.getDegradedStatusThreshold(); 483 this.degradedStatusThreshold = msg.getDegradedStatusThreshold(); 507 this.degradedStatusThreshold = -1; 595 * @return the degradedStatusThreshold 599 return degradedStatusThreshold; 1008 * @param degradedStatusThreshold The degraded status threshold of the RS 1013 ServerState rsState, int degradedStatusThreshold, long dsGenId) 1050 if (degradedStatusThreshold > 0 && nChanges >= degradedStatusThreshold) 1012 computeInitialServerStatus(long rsGenId, ServerState rsState, int degradedStatusThreshold, long dsGenId) argument [all...] |
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/service/ |
H A D | ReplicationBroker.java | 383 private final int degradedStatusThreshold; field in class:ReplicationBroker.ReplicationServerInfo 454 this.degradedStatusThreshold = msg.getDegradedStatusThreshold(); 474 this.degradedStatusThreshold = msg.getDegradedStatusThreshold(); 498 this.degradedStatusThreshold = -1; 586 * @return the degradedStatusThreshold 590 return degradedStatusThreshold; 993 * @param degradedStatusThreshold The degraded status threshold of the RS 998 ServerState rsState, int degradedStatusThreshold, long dsGenId) 1035 if (degradedStatusThreshold > 0 && nChanges >= degradedStatusThreshold) 997 computeInitialServerStatus(long rsGenId, ServerState rsState, int degradedStatusThreshold, long dsGenId) argument [all...] |