| | |
| | | import org.opends.server.replication.plugin.MultimasterReplication; |
| | | import org.opends.server.replication.plugin.ReplicationServerListener; |
| | | import org.opends.server.replication.protocol.*; |
| | | import org.opends.server.replication.server.changelog.api.ChangelogException; |
| | | import org.opends.server.replication.server.changelog.api.ReplicaDBCursor; |
| | | import org.opends.server.types.*; |
| | | import org.opends.server.util.*; |
| | |
| | | private void writeChangesAfterCSN(ReplicationServerDomain rsDomain, |
| | | final LDIFExportConfig exportConfig, LDIFWriter ldifWriter, |
| | | SearchOperation searchOperation, final CSN previousCSN) |
| | | throws DirectoryException |
| | | { |
| | | if (exportConfig != null && exportConfig.isCancelled()) |
| | | { // Abort if cancelled |
| | |
| | | cursor.next(); |
| | | } |
| | | } |
| | | catch (ChangelogException e) |
| | | { |
| | | throw new DirectoryException(ResultCode.OPERATIONS_ERROR, e); |
| | | } |
| | | finally |
| | | { |
| | | close(cursor); |