/forgerock/opendj2/src/server/org/opends/server/replication/protocol/ |
H A D | ReplServerStartDSMsg.java | 67 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 D | ReplServerStartDSMsg.java | 67 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 D | ReplServerStartDSMsg.java | 67 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 D | ReplServerStartDSMsg.java | 68 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 D | ReplServerStartDSMsg.java | 68 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 D | ReplServerStartDSMsg.java | 68 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 D | ReplicationBroker.java | 496 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 D | ReplicationBroker.java | 394 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 D | ReplicationBroker.java | 496 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 D | ReplicationBroker.java | 496 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 D | ReplicationBroker.java | 394 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 D | ReplicationBroker.java | 385 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 D | SynchronizationMsgTest.java | 926 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 D | SynchronizationMsgTest.java | 926 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 D | SynchronizationMsgTest.java | 926 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
|