| | |
| | | { |
| | | for (ReplicationCache exportContainer : exportContainers) |
| | | { |
| | | if (exportConfig.isCancelled()) |
| | | { |
| | | break; |
| | | } |
| | | processContainer(exportContainer, exportConfig, ldifWriter, null); |
| | | } |
| | | } |
| | |
| | | |
| | | for (ReplicationCache exportContainer : exportContainers) |
| | | { |
| | | if (exportConfig != null && exportConfig.isCancelled()) |
| | | { |
| | | break; |
| | | } |
| | | |
| | | attributes.clear(); |
| | | ldapAttrList.clear(); |
| | | |
| | |
| | | // Walk through the servers |
| | | for (Short serverId : rc.getServers()) |
| | | { |
| | | if (exportConfig != null && exportConfig.isCancelled()) |
| | | { |
| | | break; |
| | | } |
| | | |
| | | ReplicationIterator ri = rc.getChangelogIterator(serverId, |
| | | null); |
| | | |
| | |
| | | // Walk through the changes |
| | | while (ri.getChange() != null) |
| | | { |
| | | if (exportConfig != null && exportConfig.isCancelled()) |
| | | { |
| | | break; |
| | | } |
| | | UpdateMessage msg = ri.getChange(); |
| | | processChange(msg, exportConfig, ldifWriter, searchOperation); |
| | | if (!ri.next()) |