Searched defs:rsd (Results 1 - 8 of 8) sorted by relevance

/forgerock/opendj-b2.6/src/server/org/opends/server/replication/server/
H A DECLServerHandler.java147 ReplicationServerDomain rsd; field in class:ECLServerHandler.DomainContext
177 buffer.append("[ [active=").append(active).append("] [rsd=")
178 .append(rsd).append("] [nextMsg=").append(nextMsg).append("(")
287 return rsd.unRegisterHandler(mh);
295 rsd.stopServer(mh);
735 ReplicationServerDomain rsd = rsdi.next();
738 if (rsd == this.replicationServerDomain)
742 if (excludedServiceIDs.contains(rsd.getBaseDn()))
746 startStatesFromProvidedCookie.remove(rsd.getBaseDn());
751 if (rsd
[all...]
H A DReplicationBackend.java341 ReplicationServerDomain rsd = rcachei.next();
342 retNum += rsd.getChangesCount();
708 private void processContainer(ReplicationServerDomain rsd, argument
713 for (int serverId : rsd.getServers())
743 ReplicationIterator ri = rsd.getChangelogIterator(serverId,
790 rsd.getBaseDn());
1357 ReplicationServerDomain rsd = rsdi.next();
1360 baseDN = DN.decode(rsd.getBaseDn() + "," + BASE_DN);
1365 searchContainers.add(rsd);
H A DServerHandler.java998 * @param rsd The provided replication server domain.
1000 protected void setReplicationServerDomain(ReplicationServerDomain rsd) argument
1002 this.replicationServerDomain = rsd;
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/server/
H A DECLServerHandler.java147 ReplicationServerDomain rsd; field in class:ECLServerHandler.DomainContext
177 buffer.append("[ [active=").append(active).append("] [rsd=")
178 .append(rsd).append("] [nextMsg=").append(nextMsg).append("(")
287 return rsd.unRegisterHandler(mh);
295 rsd.stopServer(mh);
735 ReplicationServerDomain rsd = rsdi.next();
738 if (rsd == this.replicationServerDomain)
742 if (excludedServiceIDs.contains(rsd.getBaseDn()))
746 startStatesFromProvidedCookie.remove(rsd.getBaseDn());
751 if (rsd
[all...]
H A DReplicationBackend.java341 ReplicationServerDomain rsd = rcachei.next();
342 retNum += rsd.getChangesCount();
708 private void processContainer(ReplicationServerDomain rsd, argument
713 for (int serverId : rsd.getServers())
743 ReplicationIterator ri = rsd.getChangelogIterator(serverId,
790 rsd.getBaseDn());
1357 ReplicationServerDomain rsd = rsdi.next();
1360 baseDN = DN.decode(rsd.getBaseDn() + "," + BASE_DN);
1365 searchContainers.add(rsd);
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/server/
H A DECLServerHandler.java147 ReplicationServerDomain rsd; field in class:ECLServerHandler.DomainContext
177 buffer.append("[ [active=").append(active).append("] [rsd=")
178 .append(rsd).append("] [nextMsg=").append(nextMsg).append("(")
287 return rsd.unRegisterHandler(mh);
295 rsd.stopServer(mh);
735 ReplicationServerDomain rsd = rsdi.next();
738 if (rsd == this.replicationServerDomain)
742 if (excludedServiceIDs.contains(rsd.getBaseDn()))
746 startStatesFromProvidedCookie.remove(rsd.getBaseDn());
751 if (rsd
[all...]
H A DReplicationBackend.java341 ReplicationServerDomain rsd = rcachei.next();
342 retNum += rsd.getChangesCount();
708 private void processContainer(ReplicationServerDomain rsd, argument
713 for (int serverId : rsd.getServers())
743 ReplicationIterator ri = rsd.getChangelogIterator(serverId,
790 rsd.getBaseDn());
1357 ReplicationServerDomain rsd = rsdi.next();
1360 baseDN = DN.decode(rsd.getBaseDn() + "," + BASE_DN);
1365 searchContainers.add(rsd);
H A DServerHandler.java998 * @param rsd The provided replication server domain.
1000 protected void setReplicationServerDomain(ReplicationServerDomain rsd) argument
1002 this.replicationServerDomain = rsd;

Completed in 213 milliseconds