| | |
| | | import org.opends.server.replication.common.CSN; |
| | | import org.opends.server.replication.common.MultiDomainServerState; |
| | | import org.opends.server.replication.common.ServerState; |
| | | import org.opends.server.replication.plugin.MultimasterReplication; |
| | | import org.opends.server.replication.protocol.UpdateMsg; |
| | | import org.opends.server.replication.server.ChangelogState; |
| | | import org.opends.server.replication.server.ReplicationServer; |
| | |
| | | return previousValue; |
| | | } |
| | | |
| | | // we just created a new domain => update all cursors |
| | | for (MultiDomainDBCursor cursor : registeredMultiDomainCursors) |
| | | if (MultimasterReplication.isECLEnabledDomain(baseDN)) |
| | | { |
| | | cursor.addDomain(baseDN, null); |
| | | // we just created a new domain => update all cursors |
| | | for (MultiDomainDBCursor cursor : registeredMultiDomainCursors) |
| | | { |
| | | cursor.addDomain(baseDN, null); |
| | | } |
| | | } |
| | | return newValue; |
| | | } |
| | |
| | | */ |
| | | public void clearDB() throws ChangelogException |
| | | { |
| | | if (debugEnabled()) |
| | | { |
| | | TRACER.debugInfo("clear the FileChangelogDB"); |
| | | } |
| | | if (!dbDirectory.exists()) |
| | | { |
| | | return; |
| | |
| | | } |
| | | } |
| | | |
| | | for (final Map<Integer, FileReplicaDB> domainMap: domainToReplicaDBs.values()) |
| | | for (final Map<Integer, FileReplicaDB> domainMap : domainToReplicaDBs.values()) |
| | | { |
| | | for (final FileReplicaDB replicaDB : domainMap.values()) |
| | | { |