| | |
| | | |
| | | |
| | | |
| | | // Indicates whether this connection handler is currently stopped. |
| | | /** Indicates whether this connection handler is currently stopped. */ |
| | | private volatile boolean isStopped; |
| | | |
| | | // Indicates whether we should stop this connection handler. |
| | | /** Indicates whether we should stop this connection handler. */ |
| | | private volatile boolean stopRequested; |
| | | |
| | | // The path to the directory to watch for new LDIF files. |
| | | /** The path to the directory to watch for new LDIF files. */ |
| | | private File ldifDirectory; |
| | | |
| | | // The internal client connection that will be used for all processing. |
| | | /** The internal client connection that will be used for all processing. */ |
| | | private InternalClientConnection conn; |
| | | |
| | | // The current configuration for this LDIF connection handler. |
| | | /** The current configuration for this LDIF connection handler. */ |
| | | private LDIFConnectionHandlerCfg currentConfig; |
| | | |
| | | // The thread used to run the connection handler. |
| | | /** The thread used to run the connection handler. */ |
| | | private Thread connectionHandlerThread; |
| | | |
| | | // Help to not warn permanently and fullfill the log file |
| | | // in debug mode. |
| | | /** Help to not warn permanently and fullfill the log file in debug mode. */ |
| | | private boolean alreadyWarn; |
| | | |
| | | |
| | |
| | | |
| | | |
| | | |
| | | /** |
| | | * {@inheritDoc} |
| | | */ |
| | | /** {@inheritDoc} */ |
| | | @Override |
| | | public void initializeConnectionHandler(LDIFConnectionHandlerCfg |
| | | configuration) |
| | |
| | | |
| | | |
| | | |
| | | /** |
| | | * {@inheritDoc} |
| | | */ |
| | | /** {@inheritDoc} */ |
| | | @Override |
| | | public void finalizeConnectionHandler(LocalizableMessage finalizeReason) |
| | | { |
| | |
| | | |
| | | |
| | | |
| | | /** |
| | | * {@inheritDoc} |
| | | */ |
| | | /** {@inheritDoc} */ |
| | | @Override |
| | | public String getConnectionHandlerName() |
| | | { |
| | |
| | | |
| | | |
| | | |
| | | /** |
| | | * {@inheritDoc} |
| | | */ |
| | | /** {@inheritDoc} */ |
| | | @Override |
| | | public String getProtocol() |
| | | { |
| | |
| | | |
| | | |
| | | |
| | | /** |
| | | * {@inheritDoc} |
| | | */ |
| | | /** {@inheritDoc} */ |
| | | @Override |
| | | public Collection<HostPort> getListeners() |
| | | { |
| | |
| | | |
| | | |
| | | |
| | | /** |
| | | * {@inheritDoc} |
| | | */ |
| | | /** {@inheritDoc} */ |
| | | @Override |
| | | public Collection<ClientConnection> getClientConnections() |
| | | { |
| | |
| | | |
| | | |
| | | |
| | | /** |
| | | * {@inheritDoc} |
| | | */ |
| | | /** {@inheritDoc} */ |
| | | @Override |
| | | public void run() |
| | | { |
| | |
| | | |
| | | |
| | | |
| | | /** |
| | | * {@inheritDoc} |
| | | */ |
| | | /** {@inheritDoc} */ |
| | | @Override |
| | | public void toString(StringBuilder buffer) |
| | | { |
| | |
| | | |
| | | |
| | | |
| | | /** |
| | | * {@inheritDoc} |
| | | */ |
| | | /** {@inheritDoc} */ |
| | | @Override |
| | | public boolean isConfigurationAcceptable(ConnectionHandlerCfg configuration, |
| | | List<LocalizableMessage> unacceptableReasons) |
| | |
| | | |
| | | |
| | | |
| | | /** |
| | | * {@inheritDoc} |
| | | */ |
| | | /** {@inheritDoc} */ |
| | | public boolean isConfigurationChangeAcceptable( |
| | | LDIFConnectionHandlerCfg configuration, |
| | | List<LocalizableMessage> unacceptableReasons) |
| | |
| | | |
| | | |
| | | |
| | | /** |
| | | * {@inheritDoc} |
| | | */ |
| | | /** {@inheritDoc} */ |
| | | public ConfigChangeResult applyConfigurationChange( |
| | | LDIFConnectionHandlerCfg configuration) |
| | | { |
| | |
| | | |
| | | |
| | | |
| | | /** |
| | | * {@inheritDoc} |
| | | */ |
| | | /** {@inheritDoc} */ |
| | | @Override |
| | | public DN getComponentEntryDN() |
| | | { |
| | |
| | | |
| | | |
| | | |
| | | /** |
| | | * {@inheritDoc} |
| | | */ |
| | | /** {@inheritDoc} */ |
| | | public String getClassName() |
| | | { |
| | | return LDIFConnectionHandler.class.getName(); |
| | |
| | | |
| | | |
| | | |
| | | /** |
| | | * {@inheritDoc} |
| | | */ |
| | | /** {@inheritDoc} */ |
| | | public LinkedHashMap<String,String> getAlerts() |
| | | { |
| | | LinkedHashMap<String,String> alerts = new LinkedHashMap<String,String>(); |