/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
H A D | ReplicationServerLoadBalancingTest.java | 454 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 D | TopologyViewTest.java | 1020 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 D | ReplicationServerLoadBalancingTest.java | 454 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 D | TopologyViewTest.java | 1020 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 D | ReplicationServerLoadBalancingTest.java | 453 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 D | TopologyViewTest.java | 1023 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 D | ReplicationServerLoadBalancingTest.java | 615 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 D | TopologyViewTest.java | 1130 int rsId = rd.getRsServerId();
|
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
H A D | ReplicationServerLoadBalancingTest.java | 615 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 D | TopologyViewTest.java | 1130 int rsId = rd.getRsServerId();
|
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
H A D | ReplicationServerLoadBalancingTest.java | 615 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 D | TopologyViewTest.java | 1130 int rsId = rd.getRsServerId();
|
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/service/ |
H A D | ReplicationDomain.java | 612 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 D | ReplicationBroker.java | 307 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 D | ReplicationDomain.java | 703 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 D | ReplicationBroker.java | 305 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 D | ReplicationDomain.java | 613 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 D | ReplicationBroker.java | 307 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 D | ReplicationDomain.java | 612 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 D | ReplicationBroker.java | 307 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 D | ReplicationDomain.java | 703 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 D | ReplicationBroker.java | 305 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 D | ReplicationDomain.java | 673 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 D | ReplicationBroker.java | 296 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() + ")");
|