Searched refs:connectedDSNumber (Results 1 - 15 of 15) sorted by relevance

/forgerock/opendj2/src/server/org/opends/server/replication/protocol/
H A DReplServerStartDSMsg.java67 private final int connectedDSNumber; field in class:ReplServerStartDSMsg
83 * @param connectedDSNumber Number of currently connected DS to the
94 int connectedDSNumber)
106 this.connectedDSNumber = connectedDSNumber;
123 * <degradedStatusThreshold><weight><connectedDSNumber>
133 connectedDSNumber = scanner.nextIntUTF8();
180 * <degradedStatusThreshold><weight><connectedDSNumber>
192 builder.appendIntUTF8(connectedDSNumber);
253 "\nconnectedDSNumber: " + connectedDSNumber;
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...]
/forgerock/opendj2-hg/src/server/org/opends/server/replication/protocol/
H A DReplServerStartDSMsg.java67 private final int connectedDSNumber; field in class:ReplServerStartDSMsg
83 * @param connectedDSNumber Number of currently connected DS to the
94 int connectedDSNumber)
106 this.connectedDSNumber = connectedDSNumber;
123 * <degradedStatusThreshold><weight><connectedDSNumber>
133 connectedDSNumber = scanner.nextIntUTF8();
180 * <degradedStatusThreshold><weight><connectedDSNumber>
192 builder.appendIntUTF8(connectedDSNumber);
253 "\nconnectedDSNumber: " + connectedDSNumber;
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...]
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/protocol/
H A DReplServerStartDSMsg.java67 private final int connectedDSNumber; field in class:ReplServerStartDSMsg
83 * @param connectedDSNumber Number of currently connected DS to the
94 int connectedDSNumber)
106 this.connectedDSNumber = connectedDSNumber;
123 * <degradedStatusThreshold><weight><connectedDSNumber>
133 connectedDSNumber = scanner.nextIntUTF8();
180 * <degradedStatusThreshold><weight><connectedDSNumber>
192 builder.appendIntUTF8(connectedDSNumber);
253 "\nconnectedDSNumber: " + connectedDSNumber;
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...]
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/protocol/
H A DReplServerStartDSMsg.java68 private int connectedDSNumber = -1; field in class:ReplServerStartDSMsg
84 * @param connectedDSNumber Number of currently connected DS to the
95 int connectedDSNumber)
110 this.connectedDSNumber = connectedDSNumber;
130 * <degradedStatusThreshold><weight><connectedDSNumber>
194 connectedDSNumber = Integer.valueOf(connectedDSNumberString);
257 * <degradedStatusThreshold><weight><connectedDSNumber>
272 String.valueOf(connectedDSNumber).getBytes("UTF-8");
374 "\nconnectedDSNumber: " + connectedDSNumber;
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...]
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/protocol/
H A DReplServerStartDSMsg.java68 private int connectedDSNumber = -1; field in class:ReplServerStartDSMsg
84 * @param connectedDSNumber Number of currently connected DS to the
95 int connectedDSNumber)
110 this.connectedDSNumber = connectedDSNumber;
130 * <degradedStatusThreshold><weight><connectedDSNumber>
194 connectedDSNumber = Integer.valueOf(connectedDSNumberString);
257 * <degradedStatusThreshold><weight><connectedDSNumber>
272 String.valueOf(connectedDSNumber).getBytes("UTF-8");
374 "\nconnectedDSNumber: " + connectedDSNumber;
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...]
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/protocol/
H A DReplServerStartDSMsg.java68 private int connectedDSNumber = -1; field in class:ReplServerStartDSMsg
84 * @param connectedDSNumber Number of currently connected DS to the
95 int connectedDSNumber)
110 this.connectedDSNumber = connectedDSNumber;
130 * <degradedStatusThreshold><weight><connectedDSNumber>
194 connectedDSNumber = Integer.valueOf(connectedDSNumberString);
257 * <degradedStatusThreshold><weight><connectedDSNumber>
272 String.valueOf(connectedDSNumber).getBytes("UTF-8");
374 "\nconnectedDSNumber: " + connectedDSNumber;
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...]
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/service/
H A DReplicationBroker.java496 private int connectedDSNumber = 0; field in class:ReplicationBroker.ReplicationServerInfo
589 this.connectedDSNumber = replServerStartDSMsg.getConnectedDSNumber();
694 * @return the connectedDSNumber. Null if this object is a wrapper for
699 return connectedDSNumber;
716 this.connectedDSNumber = connectedDSs.size();
741 this.connectedDSNumber = connectedDSs.size();
/forgerock/opendj2/src/server/org/opends/server/replication/service/
H A DReplicationBroker.java394 private int connectedDSNumber = 0; field in class:ReplicationBroker.ReplicationServerInfo
484 this.connectedDSNumber = msg.getConnectedDSNumber();
505 this.connectedDSNumber = connectedDSs.size();
614 * @return the connectedDSNumber. Null if this object is a wrapper for
619 return connectedDSNumber;
642 this.connectedDSNumber = connectedDSs.size();
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/service/
H A DReplicationBroker.java496 private int connectedDSNumber = 0; field in class:ReplicationBroker.ReplicationServerInfo
589 this.connectedDSNumber = replServerStartDSMsg.getConnectedDSNumber();
694 * @return the connectedDSNumber. Null if this object is a wrapper for
699 return connectedDSNumber;
716 this.connectedDSNumber = connectedDSs.size();
741 this.connectedDSNumber = connectedDSs.size();
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/service/
H A DReplicationBroker.java496 private int connectedDSNumber = 0; field in class:ReplicationBroker.ReplicationServerInfo
589 this.connectedDSNumber = replServerStartDSMsg.getConnectedDSNumber();
694 * @return the connectedDSNumber. Null if this object is a wrapper for
699 return connectedDSNumber;
716 this.connectedDSNumber = connectedDSs.size();
741 this.connectedDSNumber = connectedDSs.size();
/forgerock/opendj2-hg/src/server/org/opends/server/replication/service/
H A DReplicationBroker.java394 private int connectedDSNumber = 0; field in class:ReplicationBroker.ReplicationServerInfo
484 this.connectedDSNumber = msg.getConnectedDSNumber();
505 this.connectedDSNumber = connectedDSs.size();
614 * @return the connectedDSNumber. Null if this object is a wrapper for
619 return connectedDSNumber;
642 this.connectedDSNumber = connectedDSs.size();
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/service/
H A DReplicationBroker.java385 private int connectedDSNumber; field in class:ReplicationBroker.ReplicationServerInfo
475 this.connectedDSNumber = msg.getConnectedDSNumber();
496 this.connectedDSNumber = connectedDSs.size();
605 * @return the connectedDSNumber. Null if this object is a wrapper for
610 return connectedDSNumber;
633 this.connectedDSNumber = connectedDSs.size();
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/
H A DSynchronizationMsgTest.java926 int weight, int connectedDSNumber) throws Exception
930 true, groupId, degTh, weight, connectedDSNumber);
924 replServerStartDSMsgTest(int serverId, String baseDN, int window, String url, ServerState state, long genId, byte groupId, int degTh, int weight, int connectedDSNumber) argument
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/
H A DSynchronizationMsgTest.java926 int weight, int connectedDSNumber) throws Exception
930 true, groupId, degTh, weight, connectedDSNumber);
924 replServerStartDSMsgTest(int serverId, String baseDN, int window, String url, ServerState state, long genId, byte groupId, int degTh, int weight, int connectedDSNumber) argument
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/
H A DSynchronizationMsgTest.java926 int weight, int connectedDSNumber) throws Exception
930 true, groupId, degTh, weight, connectedDSNumber);
924 replServerStartDSMsgTest(int serverId, String baseDN, int window, String url, ServerState state, long genId, byte groupId, int degTh, int weight, int connectedDSNumber) argument

Completed in 121 milliseconds