| | |
| | | private final InternalClientConnection conn = getRootConnection(); |
| | | private final AtomicBoolean shutdown = new AtomicBoolean(); |
| | | private volatile boolean disabled; |
| | | private volatile boolean stateSavingDisabled; |
| | | |
| | | /** |
| | | * This list is used to temporary store operations that needs to be replayed |
| | |
| | | synchronized (this) |
| | | { |
| | | wait(1000); |
| | | if (!disabled && !stateSavingDisabled) |
| | | if (!disabled && !ieRunning()) |
| | | { |
| | | // save the ServerState |
| | | state.save(); |
| | | } |
| | | } |
| | |
| | | */ |
| | | private void preBackendImport(Backend<?> backend) throws DirectoryException |
| | | { |
| | | // Stop saving state |
| | | stateSavingDisabled = true; |
| | | |
| | | // Prevent the processing of the backend finalisation event as the import will disable the attached backend |
| | | ignoreBackendInitializationEvent = true; |
| | | |
| | |
| | | // Process import |
| | | preBackendImport(backend); |
| | | backend.importLDIF(importConfig, DirectoryServer.getInstance().getServerContext()); |
| | | |
| | | stateSavingDisabled = false; |
| | | } |
| | | catch(Exception e) |
| | | { |