Searched refs:degradedStatusThreshold (Results 1 - 25 of 47) sorted by relevance

12

/forgerock/opendj2/src/server/org/opends/server/replication/protocol/
H A DReplServerStartDSMsg.java57 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 DReplServerStartMsg.java55 * 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 DReplServerStartDSMsg.java57 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 DReplServerStartMsg.java55 * 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 DReplServerStartDSMsg.java57 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 DReplServerStartMsg.java55 * 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 DStatusAnalyzer.java60 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 DReplicationServer.java136 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 DReplServerFakeConfiguration.java61 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 DReplServerFakeConfiguration.java63 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 DReplServerFakeConfiguration.java61 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 DStatusAnalyzer.java60 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 DReplicationServer.java136 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 DReplServerFakeConfiguration.java65 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 DReplServerFakeConfiguration.java65 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 DReplServerFakeConfiguration.java64 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 DReplServerStartDSMsg.java58 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 DReplServerStartMsg.java56 * 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 DReplServerStartDSMsg.java58 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 DReplServerStartMsg.java56 * 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 DReplServerStartDSMsg.java58 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 DReplServerStartMsg.java56 * 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 DReplicationBroker.java392 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 DReplicationBroker.java392 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 DReplicationBroker.java383 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...]

Completed in 71 milliseconds

12