| | |
| | | private ReplicationServer server; |
| | | |
| | | /** |
| | | * The configuration of this backend. |
| | | */ |
| | | private BackendCfg cfg; |
| | | |
| | | /** |
| | | * The number of milliseconds between job progress reports. |
| | | */ |
| | | private long progressInterval = 10000; |
| | |
| | | if (config != null) |
| | | { |
| | | Validator.ensureTrue(config instanceof BackendCfg); |
| | | cfg = (BackendCfg)config; |
| | | BackendCfg cfg = (BackendCfg) config; |
| | | DN[] newBaseDNs = new DN[cfg.getBaseDN().size()]; |
| | | cfg.getBaseDN().toArray(newBaseDNs); |
| | | setBaseDNs(newBaseDNs); |
| | |
| | | attrs); |
| | | ldifWriter.writeChangeRecord(changeRecord); |
| | | } |
| | | catch (Exception e) {} |
| | | catch (Exception e) { /* do nothing */ } |
| | | |
| | | for (ReplicationServerDomain exportContainer : exportContainers) |
| | | { |
| | |
| | | for (int serverId : rsd.getServers()) |
| | | { |
| | | if (exportConfig != null && exportConfig.isCancelled()) |
| | | { |
| | | { // Abort if cancelled |
| | | break; |
| | | } |
| | | |
| | |
| | | while (ri.getChange() != null) |
| | | { |
| | | if (exportConfig != null && exportConfig.isCancelled()) |
| | | { |
| | | { // abort if cancelled |
| | | break; |
| | | } |
| | | if (searchOperation != null) |
| | |
| | | LDIFWriter ldifWriter2 = writer.getLDIFWriter(); |
| | | ldifWriter2.writeChangeRecord(changeRecord); |
| | | LDIFReader reader = writer.getLDIFReader(); |
| | | Entry modDNEntry = reader.readEntry(); |
| | | entry = modDNEntry; |
| | | entry = reader.readEntry(); |
| | | } |
| | | } |
| | | |