| /forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/ |
| H A D | ProtocolCompatibilityTest.java | 127 assertEquals(msg.getServerId(), newMsg.getServerId());
150 assertEquals(msg.getServerId(), vlastMsg.getServerId());
878 assertEquals(msg.getServerId(), serverId);
904 assertEquals(msg.getServerId(), serverId);
|
| /forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/ |
| H A D | ProtocolCompatibilityTest.java | 153 assertEquals(msg.getServerId(), newMsg.getServerId());
177 assertEquals(msg.getServerId(), vlastMsg.getServerId());
960 assertEquals(msg.getServerId(), serverId);
986 assertEquals(msg.getServerId(), serverId);
|
| /forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/ |
| H A D | ProtocolCompatibilityTest.java | 127 assertEquals(msg.getServerId(), newMsg.getServerId());
150 assertEquals(msg.getServerId(), vlastMsg.getServerId());
878 assertEquals(msg.getServerId(), serverId);
904 assertEquals(msg.getServerId(), serverId);
|
| /forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/ |
| H A D | ProtocolCompatibilityTest.java | 153 assertEquals(msg.getServerId(), newMsg.getServerId());
177 assertEquals(msg.getServerId(), vlastMsg.getServerId());
960 assertEquals(msg.getServerId(), serverId);
986 assertEquals(msg.getServerId(), serverId);
|
| /forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/protocol/ |
| H A D | ProtocolCompatibilityTest.java | 132 assertEquals(msg.getServerId(), newMsg.getServerId());
155 assertEquals(msg.getServerId(), vlastMsg.getServerId());
882 assertEquals(msg.getServerId(), serverId);
908 assertEquals(msg.getServerId(), serverId);
|
| /forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/service/ |
| H A D | ReplicationDomainTest.java | 399 if (remoteDS.getDsId() != domain2.getServerId())
642 if (remoteDS.getDsId() != domain1.getServerId())
|
| /forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
| H A D | ReplicationServerLoadBalancingTest.java | 314 int curRsId = repServer.getServerId();
366 int curRsId = repServer.getServerId();
|
| /forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/server/changelog/je/ |
| H A D | ChangeNumberIndexerTest.java | 110 + "\"" + baseDN + " " + getCSN().getServerId() + "\""
632 replicaDBCursors.get(Pair.of(msg.getBaseDN(), msg.getCSN().getServerId()));
|
| /forgerock/opendj2/src/server/org/opends/server/replication/server/changelog/je/ |
| H A D | ReplicationDB.java | 811 replicationServer.getServerId(),
905 return csn.getServerId() == 0 && csn.getSeqnum() == 0;
|
| /forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/service/ |
| H A D | ReplicationDomainTest.java | 399 if (remoteDS.getDsId() != domain2.getServerId())
642 if (remoteDS.getDsId() != domain1.getServerId())
|
| /forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
| H A D | ReplicationServerLoadBalancingTest.java | 314 int curRsId = repServer.getServerId();
366 int curRsId = repServer.getServerId();
|
| /forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/server/changelog/je/ |
| H A D | ChangeNumberIndexerTest.java | 110 + "\"" + baseDN + " " + getCSN().getServerId() + "\""
632 replicaDBCursors.get(Pair.of(msg.getBaseDN(), msg.getCSN().getServerId()));
|
| /forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/service/ |
| H A D | ReplicationDomainTest.java | 399 if (remoteDS.getDsId() != domain2.getServerId())
642 if (remoteDS.getDsId() != domain1.getServerId())
|
| /forgerock/opendj2-hg/src/server/org/opends/server/replication/server/changelog/je/ |
| H A D | ReplicationDB.java | 811 replicationServer.getServerId(),
905 return csn.getServerId() == 0 && csn.getSeqnum() == 0;
|
| /forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/plugin/ |
| H A D | ReplicationServerLoadBalancingTest.java | 313 int curRsId = repServer.getServerId();
365 int curRsId = repServer.getServerId();
|
| /forgerock/opendj-b2.6/src/server/org/opends/server/replication/plugin/ |
| H A D | PersistentServerState.java | 441 if ((cn != null) && (cn.getServerId() == serverId))
|
| /forgerock/opendj-b2.6/src/server/org/opends/server/replication/protocol/ |
| H A D | MonitorMsg.java | 294 serverId = cn.getServerId();
|
| /forgerock/opendj2.6.2/src/server/org/opends/server/replication/plugin/ |
| H A D | PersistentServerState.java | 441 if ((cn != null) && (cn.getServerId() == serverId))
|
| /forgerock/opendj2.6.2/src/server/org/opends/server/replication/protocol/ |
| H A D | MonitorMsg.java | 289 serverId = cn.getServerId();
|
| /forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/plugin/ |
| H A D | PersistentServerState.java | 441 if ((cn != null) && (cn.getServerId() == serverId))
|
| /forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/protocol/ |
| H A D | MonitorMsg.java | 294 serverId = cn.getServerId();
|
| /forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/changelog/file/ |
| H A D | FileReplicaDB.java | 224 CSN actualStartCSN = (startCSN != null && startCSN.getServerId() == serverId) ? startCSN : null;
|
| /forgerock/opendj2/src/server/org/opends/server/replication/plugin/ |
| H A D | LDAPReplicationDomain.java | 345 super("Replica DS(" + getServerId()
391 super("Replica DS(" + getServerId()
499 state = new PersistentServerState(getBaseDN(), getServerId(),
1542 getBaseDNString(), Integer.toString(getServerId()));
3206 getGenerator().adjust(state.getMaxCSN(getServerId()));
4098 CSN replServerMaxCSN = rsState.getCSN(getServerId());
4108 CSN ourMaxCSN = state.getMaxCSN(getServerId());
4178 CSN endCSN = new CSN(missingChangesDelta, 0xffffffff, getServerId());
4278 final Integer serverId = fromCSN.getServerId();
4446 if (source >= -1 && source != getServerId())
[all...] |
| /forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/ |
| H A D | GenerationIdTest.java | 348 debugInfo("Connecting DS1 to replicate to RS" + getRSNumber(rs) + "(" + rs.getServerId() + ")");
411 debugInfo("Disconnect DS1 from RS" + getRSNumber(rs) + "(" + rs.getServerId() + ")");
447 debugInfo("disconnectFromReplServer: " + rs.getServerId(), e);
|
| H A D | InitOnLineTest.java | 418 final int serverId = broker.getServerId();
1014 log(testCase + " " + server2.getServerId() + " wait target " + Thread.currentThread());
1042 log(testCase + " " + server.getServerId() + " receives " + msgrcv);
|