| | |
| | | */ |
| | | private static int replayThreadNumber = 10; |
| | | |
| | | private boolean isRegistered = false; |
| | | |
| | | /** |
| | | * Finds the domain for a given DN. |
| | | * |
| | |
| | | } |
| | | |
| | | domains.put(domain.getBaseDN(), domain); |
| | | domain.start(); |
| | | return domain; |
| | | } |
| | | |
| | |
| | | { |
| | | try |
| | | { |
| | | createNewDomain(configuration); |
| | | ReplicationDomain rd = createNewDomain(configuration); |
| | | if (isRegistered) |
| | | { |
| | | rd.start(); |
| | | } |
| | | return new ConfigChangeResult(ResultCode.SUCCESS, false); |
| | | } catch (ConfigException e) |
| | | { |
| | |
| | | @Override |
| | | public void finalizeSynchronizationProvider() |
| | | { |
| | | isRegistered = false; |
| | | |
| | | // shutdown all the domains |
| | | for (ReplicationDomain domain : domains.values()) |
| | | { |
| | |
| | | |
| | | return new ConfigChangeResult(ResultCode.SUCCESS, false); |
| | | } |
| | | |
| | | /** |
| | | * {@inheritDoc} |
| | | */ |
| | | public void completeSynchronizationProvider() |
| | | { |
| | | isRegistered = true; |
| | | |
| | | // start all the domains |
| | | for (ReplicationDomain domain : domains.values()) |
| | | { |
| | | domain.start(); |
| | | } |
| | | } |
| | | } |
| | | |
| | | |