Searched refs:getRsServerId (Results 1 - 24 of 24) sorted by relevance

/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DReplicationServerLoadBalancingTest.java454 assertEquals(rd[0].getRsServerId(), RS1_ID);
467 assertEquals(rd[1].getRsServerId(), RS2_ID);
480 assertEquals(rd[2].getRsServerId(), RS3_ID);
486 int ds4ConnectedRsId = rd[3].getRsServerId();
496 int ds5ConnectedRsId = rd[4].getRsServerId();
505 int ds6ConnectedRsId = rd[5].getRsServerId();
878 assertEquals(rd[0].getRsServerId(), RS1_ID);
893 assertEquals(rd[1].getRsServerId(), RS2_ID);
901 int rsId = rd[dsIsIndex].getRsServerId();
915 assertEquals(rd[dsIsIndex].getRsServerId(), rsI
[all...]
H A DTopologyViewTest.java1020 final DSInfo dsInfo = new DSInfo(rd.getServerId(), "dummy:1234", rd.getRsServerId(),
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DReplicationServerLoadBalancingTest.java454 assertEquals(rd[0].getRsServerId(), RS1_ID);
467 assertEquals(rd[1].getRsServerId(), RS2_ID);
480 assertEquals(rd[2].getRsServerId(), RS3_ID);
486 int ds4ConnectedRsId = rd[3].getRsServerId();
496 int ds5ConnectedRsId = rd[4].getRsServerId();
505 int ds6ConnectedRsId = rd[5].getRsServerId();
878 assertEquals(rd[0].getRsServerId(), RS1_ID);
893 assertEquals(rd[1].getRsServerId(), RS2_ID);
901 int rsId = rd[dsIsIndex].getRsServerId();
915 assertEquals(rd[dsIsIndex].getRsServerId(), rsI
[all...]
H A DTopologyViewTest.java1020 final DSInfo dsInfo = new DSInfo(rd.getServerId(), "dummy:1234", rd.getRsServerId(),
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/plugin/
H A DReplicationServerLoadBalancingTest.java453 assertEquals(rd[0].getRsServerId(), RS1_ID);
466 assertEquals(rd[1].getRsServerId(), RS2_ID);
479 assertEquals(rd[2].getRsServerId(), RS3_ID);
485 int ds4ConnectedRsId = rd[3].getRsServerId();
495 int ds5ConnectedRsId = rd[4].getRsServerId();
504 int ds6ConnectedRsId = rd[5].getRsServerId();
877 assertEquals(rd[0].getRsServerId(), RS1_ID);
892 assertEquals(rd[1].getRsServerId(), RS2_ID);
900 int rsId = rd[dsIsIndex].getRsServerId();
914 assertEquals(rd[dsIsIndex].getRsServerId(), rsI
[all...]
H A DTopologyViewTest.java1023 final DSInfo dsInfo = new DSInfo(rd.getServerId(), "dummy:1234", rd.getRsServerId(),
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DReplicationServerLoadBalancingTest.java615 assertEquals(rd[0].getRsServerId(), RS1_ID);
631 assertEquals(rd[1].getRsServerId(), RS2_ID);
647 assertEquals(rd[2].getRsServerId(), RS3_ID);
655 int ds4ConnectedRsId = rd[3].getRsServerId();
667 int ds5ConnectedRsId = rd[4].getRsServerId();
678 int ds6ConnectedRsId = rd[5].getRsServerId();
1087 assertEquals(rd[0].getRsServerId(), RS1_ID);
1103 assertEquals(rd[1].getRsServerId(), RS2_ID);
1113 int rsId = rd[dsIsIndex].getRsServerId();
1129 assertEquals(rd[dsIsIndex].getRsServerId(), rsI
[all...]
H A DTopologyViewTest.java1130 int rsId = rd.getRsServerId();
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DReplicationServerLoadBalancingTest.java615 assertEquals(rd[0].getRsServerId(), RS1_ID);
631 assertEquals(rd[1].getRsServerId(), RS2_ID);
647 assertEquals(rd[2].getRsServerId(), RS3_ID);
655 int ds4ConnectedRsId = rd[3].getRsServerId();
667 int ds5ConnectedRsId = rd[4].getRsServerId();
678 int ds6ConnectedRsId = rd[5].getRsServerId();
1087 assertEquals(rd[0].getRsServerId(), RS1_ID);
1103 assertEquals(rd[1].getRsServerId(), RS2_ID);
1113 int rsId = rd[dsIsIndex].getRsServerId();
1129 assertEquals(rd[dsIsIndex].getRsServerId(), rsI
[all...]
H A DTopologyViewTest.java1130 int rsId = rd.getRsServerId();
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DReplicationServerLoadBalancingTest.java615 assertEquals(rd[0].getRsServerId(), RS1_ID);
631 assertEquals(rd[1].getRsServerId(), RS2_ID);
647 assertEquals(rd[2].getRsServerId(), RS3_ID);
655 int ds4ConnectedRsId = rd[3].getRsServerId();
667 int ds5ConnectedRsId = rd[4].getRsServerId();
678 int ds6ConnectedRsId = rd[5].getRsServerId();
1087 assertEquals(rd[0].getRsServerId(), RS1_ID);
1103 assertEquals(rd[1].getRsServerId(), RS2_ID);
1113 int rsId = rd[dsIsIndex].getRsServerId();
1129 assertEquals(rd[dsIsIndex].getRsServerId(), rsI
[all...]
H A DTopologyViewTest.java1130 int rsId = rd.getRsServerId();
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/service/
H A DReplicationDomain.java612 public int getRsServerId() method in class:ReplicationDomain
614 return broker.getRsServerId();
2033 Integer.toString(broker.getRsServerId())));
2063 Integer.toString(broker.getRsServerId())));
3384 broker.getRsServerId());
3390 broker.getRsServerId());
H A DReplicationBroker.java307 public Integer getRsServerId() method in class:ReplicationBroker
2151 getRsServerId(), baseDn, session, heartbeatInterval);
2242 + " with RSid=" + this.getRsServerId() + " genid=" + this.generationID);
2658 publish(new MonitorRequestMsg(serverId, getRsServerId()));
3061 + this.baseDn + "\" to RS(" + this.getRsServerId()
/forgerock/opendj2/src/server/org/opends/server/replication/service/
H A DReplicationDomain.java703 public int getRsServerId() method in class:ReplicationDomain
705 return broker.getRsServerId();
2120 Integer.toString(broker.getRsServerId())));
2148 Integer.toString(broker.getRsServerId())));
3398 broker.getRsServerId());
3404 broker.getRsServerId());
H A DReplicationBroker.java305 public int getRsServerId() method in class:ReplicationBroker
877 final int rsServerId = getRsServerId();
2493 receiveTopo(topoMsg, getRsServerId());
2655 publish(new MonitorRequestMsg(getServerId(), getRsServerId()));
2707 + getRsServerId() + ")");
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/service/
H A DReplicationDomain.java613 public int getRsServerId() method in class:ReplicationDomain
615 return broker.getRsServerId();
2034 Integer.toString(broker.getRsServerId())));
2064 Integer.toString(broker.getRsServerId())));
3388 broker.getRsServerId());
3394 broker.getRsServerId());
H A DReplicationBroker.java307 public Integer getRsServerId() method in class:ReplicationBroker
2409 getRsServerId(), baseDn, session, heartbeatInterval);
2500 + getRsServerId() + ") genId=" + this.generationID);
2921 publish(new MonitorRequestMsg(serverId, getRsServerId()));
3321 + this.baseDn + "\" to RS(" + this.getRsServerId()
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/service/
H A DReplicationDomain.java612 public int getRsServerId() method in class:ReplicationDomain
614 return broker.getRsServerId();
2033 Integer.toString(broker.getRsServerId())));
2063 Integer.toString(broker.getRsServerId())));
3384 broker.getRsServerId());
3390 broker.getRsServerId());
H A DReplicationBroker.java307 public Integer getRsServerId() method in class:ReplicationBroker
2151 getRsServerId(), baseDn, session, heartbeatInterval);
2242 + " with RSid=" + this.getRsServerId() + " genid=" + this.generationID);
2658 publish(new MonitorRequestMsg(serverId, getRsServerId()));
3061 + this.baseDn + "\" to RS(" + this.getRsServerId()
/forgerock/opendj2-hg/src/server/org/opends/server/replication/service/
H A DReplicationDomain.java703 public int getRsServerId() method in class:ReplicationDomain
705 return broker.getRsServerId();
2120 Integer.toString(broker.getRsServerId())));
2148 Integer.toString(broker.getRsServerId())));
3398 broker.getRsServerId());
3404 broker.getRsServerId());
H A DReplicationBroker.java305 public int getRsServerId() method in class:ReplicationBroker
877 final int rsServerId = getRsServerId();
2493 receiveTopo(topoMsg, getRsServerId());
2655 publish(new MonitorRequestMsg(getServerId(), getRsServerId()));
2707 + getRsServerId() + ")");
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/service/
H A DReplicationDomain.java673 public int getRsServerId() method in class:ReplicationDomain
675 return broker.getRsServerId();
2090 ERR_INIT_RS_DISCONNECTION_DURING_EXPORT.get(broker.getRsServerId()));
2120 ERR_INIT_RS_DISCONNECTION_DURING_EXPORT.get(broker.getRsServerId()));
3357 broker.getRsServerId());
3363 broker.getRsServerId());
H A DReplicationBroker.java296 public int getRsServerId() method in class:ReplicationBroker
865 final int rsServerId = getRsServerId();
2467 receiveTopo(topoMsg, getRsServerId());
2620 publish(new MonitorRequestMsg(getServerId(), getRsServerId()));
2670 debugInfo("is stopping and will close the connection to RS(" + getRsServerId() + ")");

Completed in 123 milliseconds