/forgerock/opendj-b2.6/src/server/org/opends/server/replication/common/ |
H A D | RSInfo.java | 122 RSInfo rsInfo = (RSInfo) obj; 123 return ((id == rsInfo.getId()) && 124 (generationId == rsInfo.getGenerationId()) && 125 (groupId == rsInfo.getGroupId()) && 126 (weight == rsInfo.getWeight()) && 127 (((serverUrl == null) && (rsInfo.getServerUrl() == null)) || 128 ((serverUrl != null) && (rsInfo.getServerUrl() != null) && 129 (serverUrl.equals(rsInfo.getServerUrl())))));
|
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/common/ |
H A D | RSInfo.java | 122 RSInfo rsInfo = (RSInfo) obj; 123 return ((id == rsInfo.getId()) && 124 (generationId == rsInfo.getGenerationId()) && 125 (groupId == rsInfo.getGroupId()) && 126 (weight == rsInfo.getWeight()) && 127 (((serverUrl == null) && (rsInfo.getServerUrl() == null)) || 128 ((serverUrl != null) && (rsInfo.getServerUrl() != null) && 129 (serverUrl.equals(rsInfo.getServerUrl())))));
|
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/common/ |
H A D | RSInfo.java | 122 RSInfo rsInfo = (RSInfo) obj; 123 return ((id == rsInfo.getId()) && 124 (generationId == rsInfo.getGenerationId()) && 125 (groupId == rsInfo.getGroupId()) && 126 (weight == rsInfo.getWeight()) && 127 (((serverUrl == null) && (rsInfo.getServerUrl() == null)) || 128 ((serverUrl != null) && (rsInfo.getServerUrl() != null) && 129 (serverUrl.equals(rsInfo.getServerUrl())))));
|
/forgerock/opendj2/src/server/org/opends/server/replication/common/ |
H A D | RSInfo.java | 127 final RSInfo rsInfo = (RSInfo) obj; 128 return rsServerId == rsInfo.getId() 129 && generationId == rsInfo.getGenerationId() 130 && groupId == rsInfo.getGroupId() 131 && weight == rsInfo.getWeight();
|
/forgerock/opendj2-hg/src/server/org/opends/server/replication/common/ |
H A D | RSInfo.java | 127 final RSInfo rsInfo = (RSInfo) obj; 128 return rsServerId == rsInfo.getId() 129 && generationId == rsInfo.getGenerationId() 130 && groupId == rsInfo.getGroupId() 131 && weight == rsInfo.getWeight();
|
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/common/ |
H A D | RSInfo.java | 127 final RSInfo rsInfo = (RSInfo) obj; 128 return rsServerId == rsInfo.getId() 129 && generationId == rsInfo.getGenerationId() 130 && groupId == rsInfo.getGroupId() 131 && weight == rsInfo.getWeight();
|
/forgerock/opendj2/src/server/org/opends/server/replication/service/ |
H A D | ReplicationBroker.java | 79 private final ReplicationServerInfo rsInfo; field in class:ReplicationBroker.ConnectedRS 86 this.rsInfo = null; 91 private ConnectedRS(ReplicationServerInfo rsInfo, Session session) argument 93 this.rsInfo = rsInfo; 112 return rsInfo != null ? rsInfo.getServerId() : -1; 117 return rsInfo != null ? rsInfo.getGroupId() : -1; 143 sb.append("connectedRS(serverId=").append(rsInfo 385 private RSInfo rsInfo; field in class:ReplicationBroker.ReplicationServerInfo 496 ReplicationServerInfo(RSInfo rsInfo, Set<Integer> connectedDSs) argument 637 update(RSInfo rsInfo, Set<Integer> connectedDSs) argument 1404 accept(Integer rsId, ReplicationServerInfo rsInfo) argument 1411 reject(ReplicationServerInfo rsInfo, Message reason) argument 3123 setLocallyConfiguredFlag(ReplicationServerInfo rsInfo, Set<String> configuredReplicationServerUrls) argument [all...] |
/forgerock/opendj2-hg/src/server/org/opends/server/replication/service/ |
H A D | ReplicationBroker.java | 79 private final ReplicationServerInfo rsInfo; field in class:ReplicationBroker.ConnectedRS 86 this.rsInfo = null; 91 private ConnectedRS(ReplicationServerInfo rsInfo, Session session) argument 93 this.rsInfo = rsInfo; 112 return rsInfo != null ? rsInfo.getServerId() : -1; 117 return rsInfo != null ? rsInfo.getGroupId() : -1; 143 sb.append("connectedRS(serverId=").append(rsInfo 385 private RSInfo rsInfo; field in class:ReplicationBroker.ReplicationServerInfo 496 ReplicationServerInfo(RSInfo rsInfo, Set<Integer> connectedDSs) argument 637 update(RSInfo rsInfo, Set<Integer> connectedDSs) argument 1404 accept(Integer rsId, ReplicationServerInfo rsInfo) argument 1411 reject(ReplicationServerInfo rsInfo, Message reason) argument 3123 setLocallyConfiguredFlag(ReplicationServerInfo rsInfo, Set<String> configuredReplicationServerUrls) argument [all...] |
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/service/ |
H A D | ReplicationBroker.java | 76 private final ReplicationServerInfo rsInfo; field in class:ReplicationBroker.ConnectedRS 83 this.rsInfo = null; 88 private ConnectedRS(ReplicationServerInfo rsInfo, Session session) argument 90 this.rsInfo = rsInfo; 109 return rsInfo != null ? rsInfo.getServerId() : -1; 114 return rsInfo != null ? rsInfo.getGroupId() : -1; 140 sb.append("connectedRS(serverId=").append(rsInfo 376 private RSInfo rsInfo; field in class:ReplicationBroker.ReplicationServerInfo 487 ReplicationServerInfo(RSInfo rsInfo, Set<Integer> connectedDSs) argument 628 update(RSInfo rsInfo, Set<Integer> connectedDSs) argument 1380 accept(Integer rsId, ReplicationServerInfo rsInfo) argument 1387 reject(ReplicationServerInfo rsInfo, LocalizableMessage reason) argument 3087 setLocallyConfiguredFlag(ReplicationServerInfo rsInfo, Set<String> configuredReplicationServerUrls) argument [all...] |
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
H A D | ComputeBestServerTest.java | 915 RSInfo rsInfo = null; 930 rsInfo = new RSInfo(11, "AwinnerHost:123", 0L, (byte)1, 1); 932 rsInfos.put(11, new ReplicationServerInfo(rsInfo, connectedDSs)); 948 rsInfo = new RSInfo(11, "BwinnerHost:123", 0L, (byte)1, 1); 950 rsInfos.put(11, new ReplicationServerInfo(rsInfo, connectedDSs)); 952 rsInfo = new RSInfo(12, "looserHost:456", 0L, (byte)1, 1); 954 rsInfos.put(12, new ReplicationServerInfo(rsInfo, connectedDSs)); 973 rsInfo = new RSInfo(11, "looserHost:123", 0L, (byte)1, 1); 976 rsInfos.put(11, new ReplicationServerInfo(rsInfo, connectedDSs)); 978 rsInfo [all...] |
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
H A D | ComputeBestServerTest.java | 915 RSInfo rsInfo = null; 930 rsInfo = new RSInfo(11, "AwinnerHost:123", 0L, (byte)1, 1); 932 rsInfos.put(11, new ReplicationServerInfo(rsInfo, connectedDSs)); 948 rsInfo = new RSInfo(11, "BwinnerHost:123", 0L, (byte)1, 1); 950 rsInfos.put(11, new ReplicationServerInfo(rsInfo, connectedDSs)); 952 rsInfo = new RSInfo(12, "looserHost:456", 0L, (byte)1, 1); 954 rsInfos.put(12, new ReplicationServerInfo(rsInfo, connectedDSs)); 973 rsInfo = new RSInfo(11, "looserHost:123", 0L, (byte)1, 1); 976 rsInfos.put(11, new ReplicationServerInfo(rsInfo, connectedDSs)); 978 rsInfo [all...] |
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/service/ |
H A D | ReplicationBroker.java | 513 ReplicationServerInfo rsInfo = newInstance(msg); 514 rsInfo.serverURL = server; 515 return rsInfo; 705 * @param rsInfo The RSinfo to use for the update 708 public ReplicationServerInfo(RSInfo rsInfo, List<Integer> connectedDSs) argument 710 this.serverId = rsInfo.getId(); 711 this.serverURL = rsInfo.getServerUrl(); 712 this.generationId = rsInfo.getGenerationId(); 713 this.groupId = rsInfo.getGroupId(); 714 this.weight = rsInfo 735 update(RSInfo rsInfo, List<Integer> connectedDSs) argument 1041 connectToReplicationServer(ReplicationServerInfo rsInfo, ServerStatus initStatus, TopologyMsg topologyMsg) argument 1665 accept(Integer rsId, ReplicationServerInfo rsInfo) argument 1672 reject(ReplicationServerInfo rsInfo, Message reason) argument [all...] |
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/service/ |
H A D | ReplicationBrokerTest.java | 60 private final ReplicationServerInfo CURRENT_RS = rsInfo(CURRENT_RS_ID, 62 private final ReplicationServerInfo MISSING_RS = rsInfo(MISSING_RS_ID, 64 private final ReplicationServerInfo ANOTHER_RS = rsInfo(ANOTHER_RS_ID); 74 private ReplicationServerInfo rsInfo(int rsServerId, Integer... dsIds) method in class:ReplicationBrokerTest 103 ReplicationServerInfo rsInfo, Integer... connectedDSs) 105 return assertContainsRSWithDSs(rsInfos, rsInfo, newSet(connectedDSs)); 110 ReplicationServerInfo rsInfo, Set<Integer> connectedDSs) 112 final ReplicationServerInfo info = find(rsInfos, rsInfo.toRSInfo()); 118 private ReplicationServerInfo find(Map<Integer, ReplicationServerInfo> rsInfos, RSInfo rsInfo) argument 122 if (info.getServerId() == rsInfo 101 assertContainsRSWithDSs( Map<Integer, ReplicationServerInfo> rsInfos, ReplicationServerInfo rsInfo, Integer... connectedDSs) argument 108 assertContainsRSWithDSs( Map<Integer, ReplicationServerInfo> rsInfos, ReplicationServerInfo rsInfo, Set<Integer> connectedDSs) argument [all...] |
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/service/ |
H A D | ReplicationBrokerTest.java | 60 private final ReplicationServerInfo CURRENT_RS = rsInfo(CURRENT_RS_ID, 62 private final ReplicationServerInfo MISSING_RS = rsInfo(MISSING_RS_ID, 64 private final ReplicationServerInfo ANOTHER_RS = rsInfo(ANOTHER_RS_ID); 74 private ReplicationServerInfo rsInfo(int rsServerId, Integer... dsIds) method in class:ReplicationBrokerTest 103 ReplicationServerInfo rsInfo, Integer... connectedDSs) 105 return assertContainsRSWithDSs(rsInfos, rsInfo, newSet(connectedDSs)); 110 ReplicationServerInfo rsInfo, Set<Integer> connectedDSs) 112 final ReplicationServerInfo info = find(rsInfos, rsInfo.toRSInfo()); 118 private ReplicationServerInfo find(Map<Integer, ReplicationServerInfo> rsInfos, RSInfo rsInfo) argument 122 if (info.getServerId() == rsInfo 101 assertContainsRSWithDSs( Map<Integer, ReplicationServerInfo> rsInfos, ReplicationServerInfo rsInfo, Integer... connectedDSs) argument 108 assertContainsRSWithDSs( Map<Integer, ReplicationServerInfo> rsInfos, ReplicationServerInfo rsInfo, Set<Integer> connectedDSs) argument [all...] |
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/service/ |
H A D | ReplicationBrokerTest.java | 60 private final ReplicationServerInfo CURRENT_RS = rsInfo(CURRENT_RS_ID, 62 private final ReplicationServerInfo MISSING_RS = rsInfo(MISSING_RS_ID, 64 private final ReplicationServerInfo ANOTHER_RS = rsInfo(ANOTHER_RS_ID); 74 private ReplicationServerInfo rsInfo(int rsServerId, Integer... dsIds) method in class:ReplicationBrokerTest 102 ReplicationServerInfo rsInfo, Integer... connectedDSs) 104 return assertContainsRSWithDSs(rsInfos, rsInfo, newHashSet(connectedDSs)); 109 ReplicationServerInfo rsInfo, Set<Integer> connectedDSs) 111 final ReplicationServerInfo info = find(rsInfos, rsInfo.toRSInfo()); 117 private ReplicationServerInfo find(Map<Integer, ReplicationServerInfo> rsInfos, RSInfo rsInfo) argument 121 if (info.getServerId() == rsInfo 100 assertContainsRSWithDSs( Map<Integer, ReplicationServerInfo> rsInfos, ReplicationServerInfo rsInfo, Integer... connectedDSs) argument 107 assertContainsRSWithDSs( Map<Integer, ReplicationServerInfo> rsInfos, ReplicationServerInfo rsInfo, Set<Integer> connectedDSs) argument [all...] |
/forgerock/opendj2/src/server/org/opends/server/replication/protocol/ |
H A D | TopologyMsg.java | 245 for (RSInfo rsInfo : rsInfos) 247 builder.appendIntUTF8(rsInfo.getId()); 248 builder.appendLongUTF8(rsInfo.getGenerationId()); 249 builder.appendByte(rsInfo.getGroupId()); 253 builder.appendString(rsInfo.getServerUrl()); 254 builder.appendIntUTF8(rsInfo.getWeight()); 272 for (RSInfo rsInfo : rsInfos) 274 rsStr += rsInfo + "\n----------------------------\n";
|
/forgerock/opendj2-hg/src/server/org/opends/server/replication/protocol/ |
H A D | TopologyMsg.java | 245 for (RSInfo rsInfo : rsInfos) 247 builder.appendIntUTF8(rsInfo.getId()); 248 builder.appendLongUTF8(rsInfo.getGenerationId()); 249 builder.appendByte(rsInfo.getGroupId()); 253 builder.appendString(rsInfo.getServerUrl()); 254 builder.appendIntUTF8(rsInfo.getWeight()); 272 for (RSInfo rsInfo : rsInfos) 274 rsStr += rsInfo + "\n----------------------------\n";
|
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/protocol/ |
H A D | TopologyMsg.java | 244 for (RSInfo rsInfo : rsInfos) 246 builder.appendIntUTF8(rsInfo.getId()); 247 builder.appendLongUTF8(rsInfo.getGenerationId()); 248 builder.appendByte(rsInfo.getGroupId()); 252 builder.appendString(rsInfo.getServerUrl()); 253 builder.appendIntUTF8(rsInfo.getWeight()); 271 for (RSInfo rsInfo : rsInfos) 273 rsStr += rsInfo + "\n----------------------------\n";
|
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/protocol/ |
H A D | TopologyMsg.java | 251 RSInfo rsInfo = new RSInfo(id, serverUrl, generationId, groupId, 253 rsList.add(rsInfo); 393 for (RSInfo rsInfo : rsList) 397 String.valueOf(rsInfo.getId()).getBytes("UTF-8"); 401 oStream.write(String.valueOf(rsInfo.getGenerationId()). 405 oStream.write(rsInfo.getGroupId()); 410 oStream.write(rsInfo.getServerUrl().getBytes("UTF-8")); 414 oStream.write(String.valueOf(rsInfo.getWeight()).getBytes("UTF-8")); 444 for (RSInfo rsInfo : rsList) 446 rsStr += rsInfo [all...] |
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/protocol/ |
H A D | TopologyMsg.java | 251 RSInfo rsInfo = new RSInfo(id, serverUrl, generationId, groupId, 253 rsList.add(rsInfo); 393 for (RSInfo rsInfo : rsList) 397 String.valueOf(rsInfo.getId()).getBytes("UTF-8"); 401 oStream.write(String.valueOf(rsInfo.getGenerationId()). 405 oStream.write(rsInfo.getGroupId()); 410 oStream.write(rsInfo.getServerUrl().getBytes("UTF-8")); 414 oStream.write(String.valueOf(rsInfo.getWeight()).getBytes("UTF-8")); 444 for (RSInfo rsInfo : rsList) 446 rsStr += rsInfo [all...] |
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/protocol/ |
H A D | TopologyMsg.java | 251 RSInfo rsInfo = new RSInfo(id, serverUrl, generationId, groupId, 253 rsList.add(rsInfo); 393 for (RSInfo rsInfo : rsList) 397 String.valueOf(rsInfo.getId()).getBytes("UTF-8"); 401 oStream.write(String.valueOf(rsInfo.getGenerationId()). 405 oStream.write(rsInfo.getGroupId()); 410 oStream.write(rsInfo.getServerUrl().getBytes("UTF-8")); 414 oStream.write(String.valueOf(rsInfo.getWeight()).getBytes("UTF-8")); 444 for (RSInfo rsInfo : rsList) 446 rsStr += rsInfo [all...] |
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/ |
H A D | ReplicationServerHandler.java | 447 RSInfo rsInfo = inTopoMsg.getRsInfos().get(0); 448 weight = rsInfo.getWeight(); 580 final RSInfo rsInfo = topoMsg.getRsInfos().get(0); 581 generationId = rsInfo.getGenerationId(); 582 groupId = rsInfo.getGroupId(); 583 weight = rsInfo.getWeight();
|
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/service/ |
H A D | ReplicationBroker.java | 513 ReplicationServerInfo rsInfo = newInstance(msg); 514 rsInfo.serverURL = server; 515 return rsInfo; 705 * @param rsInfo The RSinfo to use for the update 708 public ReplicationServerInfo(RSInfo rsInfo, List<Integer> connectedDSs) argument 710 this.serverId = rsInfo.getId(); 711 this.serverURL = rsInfo.getServerUrl(); 712 this.generationId = rsInfo.getGenerationId(); 713 this.groupId = rsInfo.getGroupId(); 714 this.weight = rsInfo 735 update(RSInfo rsInfo, List<Integer> connectedDSs) argument 1042 connectToReplicationServer(ReplicationServerInfo rsInfo, ServerStatus initStatus, TopologyMsg topologyMsg) argument [all...] |
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/service/ |
H A D | ReplicationBroker.java | 513 ReplicationServerInfo rsInfo = newInstance(msg); 514 rsInfo.serverURL = server; 515 return rsInfo; 705 * @param rsInfo The RSinfo to use for the update 708 public ReplicationServerInfo(RSInfo rsInfo, List<Integer> connectedDSs) argument 710 this.serverId = rsInfo.getId(); 711 this.serverURL = rsInfo.getServerUrl(); 712 this.generationId = rsInfo.getGenerationId(); 713 this.groupId = rsInfo.getGroupId(); 714 this.weight = rsInfo 735 update(RSInfo rsInfo, List<Integer> connectedDSs) argument 1042 connectToReplicationServer(ReplicationServerInfo rsInfo, ServerStatus initStatus, TopologyMsg topologyMsg) argument [all...] |
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/server/ |
H A D | ReplicationServerHandler.java | 516 RSInfo rsInfo = inTopoMsg.getRsList().get(0); 517 weight = rsInfo.getWeight(); 672 RSInfo rsInfo = rsInfos.get(0); 673 generationId = rsInfo.getGenerationId(); 674 groupId = rsInfo.getGroupId(); 675 weight = rsInfo.getWeight();
|