| | |
| | | import java.util.Map; |
| | | import java.util.Set; |
| | | |
| | | import javax.naming.NamingException; |
| | | |
| | | import org.forgerock.i18n.LocalizableMessage; |
| | | import org.forgerock.i18n.slf4j.LocalizedLogger; |
| | | import org.forgerock.opendj.ldap.DN; |
| | |
| | | { |
| | | updateReplicas(server, candidateReplicas, updatedReplicas); |
| | | } |
| | | catch (NamingException | IOException e) |
| | | catch (IOException e) |
| | | { |
| | | server.setLastException(new TopologyCacheException( |
| | | TopologyCacheException.Type.GENERIC_READING_SERVER, e)); |
| | |
| | | private void updateReplicas(ServerDescriptor replicationServer, |
| | | Collection<ReplicaDescriptor> candidateReplicas, |
| | | Collection<ReplicaDescriptor> updatedReplicas) |
| | | throws NamingException, IOException |
| | | throws IOException |
| | | { |
| | | ServerLoader loader = getServerLoader(replicationServer.getAdsProperties()); |
| | | // only replicas have "server-id", but not replication servers |
| | |
| | | } |
| | | } |
| | | |
| | | private void setMissingChanges(ReplicaDescriptor replica, SearchResultEntry sr) throws NamingException |
| | | private void setMissingChanges(ReplicaDescriptor replica, SearchResultEntry sr) |
| | | { |
| | | Integer value = asInteger(sr, "missing-changes"); |
| | | if (value != null) |
| | |
| | | } |
| | | } |
| | | |
| | | private void setAgeOfOldestMissingChange(ReplicaDescriptor replica, SearchResultEntry sr) throws NamingException |
| | | private void setAgeOfOldestMissingChange(ReplicaDescriptor replica, SearchResultEntry sr) |
| | | { |
| | | String s = firstValueAsString(sr, "approx-older-change-not-synchronized-millis"); |
| | | if (s != null) |