Searched refs:rsInfo (Results 1 - 25 of 57) sorted by relevance

123

/forgerock/opendj-b2.6/src/server/org/opends/server/replication/common/
H A DRSInfo.java122 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 DRSInfo.java122 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 DRSInfo.java122 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 DRSInfo.java127 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 DRSInfo.java127 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 DRSInfo.java127 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 DReplicationBroker.java79 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 DReplicationBroker.java79 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 DReplicationBroker.java76 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 DComputeBestServerTest.java915 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 DComputeBestServerTest.java915 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 DReplicationBroker.java513 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 DReplicationBrokerTest.java60 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 DReplicationBrokerTest.java60 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 DReplicationBrokerTest.java60 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 DTopologyMsg.java245 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 DTopologyMsg.java245 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 DTopologyMsg.java244 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 DTopologyMsg.java251 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 DTopologyMsg.java251 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 DTopologyMsg.java251 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 DReplicationServerHandler.java447 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 DReplicationBroker.java513 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 DReplicationBroker.java513 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 DReplicationServerHandler.java516 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();

Completed in 83 milliseconds

123