Searched refs:getServerId (Results 101 - 125 of 335) sorted by relevance

1234567891011>>

/forgerock/opendj2.6.2/src/server/org/opends/server/replication/common/
H A DServerState.java166 int id = changeNumber.getServerId();
445 ChangeNumber change = this.list.get(coveredChange.getServerId());
463 ChangeNumber change = this.list.get(covered.getServerId());
489 Integer id = change.getServerId();
569 Integer id = change.getServerId();
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/common/
H A DServerState.java166 int id = changeNumber.getServerId();
445 ChangeNumber change = this.list.get(coveredChange.getServerId());
463 ChangeNumber change = this.list.get(covered.getServerId());
489 Integer id = change.getServerId();
569 Integer id = change.getServerId();
/forgerock/opendj2/src/server/org/opends/server/replication/server/
H A DLightweightServerHandler.java102 public int getServerId() method in class:LightweightServerHandler
132 + " LWSH for remote server " + getServerId() + " connected to:"
H A DReplicationDomainMonitor.java170 final int serverId = rs.getServerId();
272 final int serverId = ds.getServerId();
351 int connectedServerId = ds.getServerId();
H A DSafeReadExpectedAcksInfo.java165 int ackingServerId = ackingServer.getServerId();
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/
H A DLightweightServerHandler.java102 public int getServerId() method in class:LightweightServerHandler
132 + " LWSH for remote server " + getServerId() + " connected to:"
H A DReplicationDomainMonitor.java170 final int serverId = rs.getServerId();
272 final int serverId = ds.getServerId();
351 int connectedServerId = ds.getServerId();
H A DSafeReadExpectedAcksInfo.java165 int ackingServerId = ackingServer.getServerId();
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/
H A DLightweightServerHandler.java102 public int getServerId() method in class:LightweightServerHandler
136 + " LWSH for remote server " + getServerId() + " connected to:"
H A DReplicationDomainMonitor.java169 final int serverId = rs.getServerId();
268 final int serverId = ds.getServerId();
346 int connectedServerId = ds.getServerId();
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/service/
H A DReplicationMonitor.java73 return "Directory server DS(" + domain.getServerId() + ") "
101 addMonitorData(attributes, "server-id", domain.getServerId());
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/common/
H A DServerState.java99 final int serverId = csn.getServerId();
165 if (serverIdToCSN.remove(expectedCSN.getServerId(), expectedCSN))
364 final CSN csn = this.serverIdToCSN.get(covered.getServerId());
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/service/
H A DReplicationBroker.java316 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);
950 .put(electedRsInfo.getServerId(), electedRsInfo);
1049 rsServerId = rsInfo.getServerId();
1470 domain.getEclIncludes(domain.getServerId()),
1471 domain.getEclIncludesForDeletes(domain.getServerId()));
1564 if (rsInfo.getServerId() !
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/backends/
H A DChangelogBackendTestCase.java225 broker = openReplicationSession(replicaId.getBaseDN(), replicaId.getServerId(), 100, replicationServerPort, 5000);
227 DomainFakeCfg domainConf = newFakeCfg(replicaId.getBaseDN(), replicaId.getServerId(), replicationServerPort);
385 CSN csn1 = new CSN(time, seqNum++, server1.getServerId());
386 CSN csn2 = new CSN(time, seqNum++, server2.getServerId());
387 CSN csn3 = new CSN(time, seqNum++, server2.getServerId());
388 CSN csn4 = new CSN(time, seqNum++, server1.getServerId());
420 CSN csn5 = new CSN(time, seqNum++, server1.getServerId());
438 CSN csn6 = new CSN(time, seqNum++, server3.getServerId());
439 CSN csn7 = new CSN(time, seqNum++, server4.getServerId());
440 CSN csn8 = new CSN(time, seqNum++, server3.getServerId());
[all...]
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/server/
H A DSafeReadExpectedAcksInfo.java162 int ackingServerId = ackingServer.getServerId();
/forgerock/opendj2/src/server/org/opends/server/replication/protocol/
H A DReplServerStartDSMsg.java141 public int getServerId() method in class:ReplServerStartDSMsg
H A DReplServerStartMsg.java135 public int getServerId() method in class:ReplServerStartMsg
H A DServerStartMsg.java132 public int getServerId() method in class:ServerStartMsg
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/server/
H A DSafeReadExpectedAcksInfo.java162 int ackingServerId = ackingServer.getServerId();
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/server/
H A DSafeReadExpectedAcksInfo.java162 int ackingServerId = ackingServer.getServerId();
/forgerock/opendj2-hg/src/server/org/opends/server/replication/protocol/
H A DReplServerStartDSMsg.java141 public int getServerId() method in class:ReplServerStartDSMsg
H A DReplServerStartMsg.java135 public int getServerId() method in class:ReplServerStartMsg
H A DServerStartMsg.java132 public int getServerId() method in class:ServerStartMsg
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/protocol/
H A DReplServerStartDSMsg.java141 public int getServerId() method in class:ReplServerStartDSMsg
H A DReplServerStartMsg.java135 public int getServerId() method in class:ReplServerStartMsg

Completed in 103 milliseconds

1234567891011>>