| /forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/protocol/ |
| H A D | ServerStartMsg.java | 132 public int getServerId() method in class:ServerStartMsg
|
| /forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/ |
| H A D | SafeReadExpectedAcksInfo.java | 158 int ackingServerId = ackingServer.getServerId();
|
| H A D | ServerHandler.java | 564 public int getServerId() method in class:ServerHandler
1175 getServerId(), session.getReadableRemoteAddress(), getBaseDN());
1178 getServerId(), session.getReadableRemoteAddress(), getBaseDN());
|
| /forgerock/opendj-b2.6/src/server/org/opends/server/replication/service/ |
| H A D | ReplicationMonitor.java | 78 return "Directory server DS(" + domain.getServerId() + ") "
122 domain.getServerId());
|
| H A D | ReplicationBroker.java | 316 public int getServerId() method in class:ReplicationBroker
558 this.serverId = replServerStartMsg.getServerId();
580 this.serverId = replServerStartDSMsg.getServerId();
632 public int getServerId() method in class:ReplicationBroker.ReplicationServerInfo
829 rsInfos.put(replicationServerInfo.getServerId(), replicationServerInfo);
951 .put(electedRsInfo.getServerId(), electedRsInfo);
1050 rsServerId = rsInfo.getServerId();
1470 domain.getEclIncludes(domain.getServerId()),
1471 domain.getEclIncludesForDeletes(domain.getServerId()));
2150 heartbeatMonitor = new HeartbeatMonitor(getServerId(),
[all...] |
| /forgerock/opendj2/src/server/org/opends/server/replication/server/ |
| H A D | MessageHandler.java | 413 if (connectedReplicaIds.contains(record.getCSN().getServerId()))
687 return this.replicationServer.getServerId();
|
| H A D | ServerHandler.java | 580 public int getServerId() method in class:ServerHandler
1198 getServerId(), session.getReadableRemoteAddress(), getBaseDNString());
1201 getServerId(), session.getReadableRemoteAddress(), getBaseDNString());
|
| /forgerock/opendj2/src/server/org/opends/server/replication/service/ |
| H A D | ReplicationMonitor.java | 74 return "Directory server DS(" + domain.getServerId() + ") "
105 addMonitorData(attributes, "server-id", domain.getServerId());
|
| /forgerock/opendj2.6.2/src/server/org/opends/server/replication/service/ |
| H A D | ReplicationMonitor.java | 78 return "Directory server DS(" + domain.getServerId() + ") "
122 domain.getServerId());
|
| /forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/service/ |
| H A D | ReplicationMonitor.java | 78 return "Directory server DS(" + domain.getServerId() + ") "
122 domain.getServerId());
|
| H A D | ReplicationBroker.java | 316 public int getServerId() method in class:ReplicationBroker
558 this.serverId = replServerStartMsg.getServerId();
580 this.serverId = replServerStartDSMsg.getServerId();
632 public int getServerId() method in class:ReplicationBroker.ReplicationServerInfo
829 rsInfos.put(replicationServerInfo.getServerId(), replicationServerInfo);
951 .put(electedRsInfo.getServerId(), electedRsInfo);
1050 rsServerId = rsInfo.getServerId();
1470 domain.getEclIncludes(domain.getServerId()),
1471 domain.getEclIncludesForDeletes(domain.getServerId()));
2150 heartbeatMonitor = new HeartbeatMonitor(getServerId(),
[all...] |
| /forgerock/opendj2-hg/src/server/org/opends/server/replication/server/ |
| H A D | MessageHandler.java | 413 if (connectedReplicaIds.contains(record.getCSN().getServerId()))
687 return this.replicationServer.getServerId();
|
| H A D | ServerHandler.java | 580 public int getServerId() method in class:ServerHandler
1198 getServerId(), session.getReadableRemoteAddress(), getBaseDNString());
1201 getServerId(), session.getReadableRemoteAddress(), getBaseDNString());
|
| /forgerock/opendj2-hg/src/server/org/opends/server/replication/service/ |
| H A D | ReplicationMonitor.java | 74 return "Directory server DS(" + domain.getServerId() + ") "
105 addMonitorData(attributes, "server-id", domain.getServerId());
|
| /forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/common/ |
| H A D | ChangeNumberTest.java | 295 CN2.getServerId()) ;
302 CN2.getServerId()) ;
308 CN1 = new ChangeNumber(CN2.getTime() ,0XFFFF +10,CN2.getServerId()) ;
|
| /forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/common/ |
| H A D | CSNTest.java | 253 csn1 = new CSN(csn2.getTime() +300 ,csn2.getSeqnum(), csn2.getServerId());
259 csn1 = new CSN(csn2.getTime() ,csn2.getSeqnum() +10, csn2.getServerId());
265 csn1 = new CSN(csn2.getTime() ,0XFFFF +10,csn2.getServerId());
|
| /forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/common/ |
| H A D | ChangeNumberTest.java | 295 CN2.getServerId()) ;
302 CN2.getServerId()) ;
308 CN1 = new ChangeNumber(CN2.getTime() ,0XFFFF +10,CN2.getServerId()) ;
|
| /forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/common/ |
| H A D | CSNTest.java | 253 csn1 = new CSN(csn2.getTime() +300 ,csn2.getSeqnum(), csn2.getServerId());
259 csn1 = new CSN(csn2.getTime() ,csn2.getSeqnum() +10, csn2.getServerId());
265 csn1 = new CSN(csn2.getTime() ,0XFFFF +10,csn2.getServerId());
|
| /forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/common/ |
| H A D | ChangeNumberTest.java | 295 CN2.getServerId()) ;
302 CN2.getServerId()) ;
308 CN1 = new ChangeNumber(CN2.getTime() ,0XFFFF +10,CN2.getServerId()) ;
|
| /forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/common/ |
| H A D | CSNTest.java | 253 csn1 = new CSN(csn2.getTime() +300 ,csn2.getSeqnum(), csn2.getServerId());
259 csn1 = new CSN(csn2.getTime() ,csn2.getSeqnum() +10, csn2.getServerId());
265 csn1 = new CSN(csn2.getTime() ,0XFFFF +10,csn2.getServerId());
|
| /forgerock/opendj-b2.6/src/server/org/opends/server/replication/common/ |
| H A D | ChangeNumber.java | 160 public int getServerId() method in class:ChangeNumber
|
| H A D | MultiDomainServerState.java | 104 int serverId = changeNumber.getServerId();
|
| /forgerock/opendj2/src/server/org/opends/server/replication/common/ |
| H A D | CSN.java | 179 public int getServerId() method in class:CSN
|
| /forgerock/opendj2/src/server/org/opends/server/replication/protocol/ |
| H A D | ByteArrayScanner.java | 372 if (serverId != csn.getServerId())
|
| /forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
| H A D | DomainFakeCfg.java | 194 public int getServerId() method in class:DomainFakeCfg
|