/forgerock/opendj2.6.2/src/server/org/opends/server/replication/common/ |
H A D | ServerState.java | 166 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 D | ServerState.java | 166 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 D | LightweightServerHandler.java | 102 public int getServerId() method in class:LightweightServerHandler 132 + " LWSH for remote server " + getServerId() + " connected to:"
|
H A D | ReplicationDomainMonitor.java | 170 final int serverId = rs.getServerId(); 272 final int serverId = ds.getServerId(); 351 int connectedServerId = ds.getServerId();
|
H A D | SafeReadExpectedAcksInfo.java | 165 int ackingServerId = ackingServer.getServerId();
|
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/ |
H A D | LightweightServerHandler.java | 102 public int getServerId() method in class:LightweightServerHandler 132 + " LWSH for remote server " + getServerId() + " connected to:"
|
H A D | ReplicationDomainMonitor.java | 170 final int serverId = rs.getServerId(); 272 final int serverId = ds.getServerId(); 351 int connectedServerId = ds.getServerId();
|
H A D | SafeReadExpectedAcksInfo.java | 165 int ackingServerId = ackingServer.getServerId();
|
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/ |
H A D | LightweightServerHandler.java | 102 public int getServerId() method in class:LightweightServerHandler 136 + " LWSH for remote server " + getServerId() + " connected to:"
|
H A D | ReplicationDomainMonitor.java | 169 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 D | ReplicationMonitor.java | 73 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 D | ServerState.java | 99 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 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); 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 D | ChangelogBackendTestCase.java | 225 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 D | SafeReadExpectedAcksInfo.java | 162 int ackingServerId = ackingServer.getServerId();
|
/forgerock/opendj2/src/server/org/opends/server/replication/protocol/ |
H A D | ReplServerStartDSMsg.java | 141 public int getServerId() method in class:ReplServerStartDSMsg
|
H A D | ReplServerStartMsg.java | 135 public int getServerId() method in class:ReplServerStartMsg
|
H A D | ServerStartMsg.java | 132 public int getServerId() method in class:ServerStartMsg
|
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/server/ |
H A D | SafeReadExpectedAcksInfo.java | 162 int ackingServerId = ackingServer.getServerId();
|
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/server/ |
H A D | SafeReadExpectedAcksInfo.java | 162 int ackingServerId = ackingServer.getServerId();
|
/forgerock/opendj2-hg/src/server/org/opends/server/replication/protocol/ |
H A D | ReplServerStartDSMsg.java | 141 public int getServerId() method in class:ReplServerStartDSMsg
|
H A D | ReplServerStartMsg.java | 135 public int getServerId() method in class:ReplServerStartMsg
|
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/protocol/ |
H A D | ReplServerStartDSMsg.java | 141 public int getServerId() method in class:ReplServerStartDSMsg
|
H A D | ReplServerStartMsg.java | 135 public int getServerId() method in class:ReplServerStartMsg
|