| | |
| | | * |
| | | * Copyright 2006-2010 Sun Microsystems, Inc. |
| | | * Portions copyright 2012-2016 ForgeRock AS. |
| | | * Portions Copyright 2026 3A Systems, LLC. |
| | | */ |
| | | package com.forgerock.opendj.cli; |
| | | |
| | |
| | | * A supplement to the description for all subcommands of this tool, |
| | | * intended for use in generated reference documentation. |
| | | */ |
| | | private class DocSubcommandDescriptionSupplement implements DocDescriptionSupplement { |
| | | private static class DocSubcommandDescriptionSupplement implements DocDescriptionSupplement { |
| | | /** A supplement to the description intended for use in generated reference documentation. */ |
| | | private LocalizableMessage docDescriptionSupplement; |
| | | |
| | |
| | | private File outputDirectory; |
| | | |
| | | /** Holds documentation for an ACI. */ |
| | | private class Aci { |
| | | private static class Aci { |
| | | String name; |
| | | String description; |
| | | String definition; |
| | |
| | | * information: "Portions Copyright [year] [name of copyright owner]". |
| | | * |
| | | * Copyright 2015-2016 ForgeRock AS. |
| | | * Portions Copyright 2026 3A Systems, LLC. |
| | | */ |
| | | package org.forgerock.opendj.maven.doc; |
| | | |
| | |
| | | CoreSchemaSupportedLocales.getJvmSupportedLocaleNamesToOids(); |
| | | |
| | | /** Container for documentation regarding a locale. */ |
| | | private class LocaleDoc { |
| | | private static class LocaleDoc { |
| | | String tag; |
| | | String language; |
| | | String oid; |
| | |
| | | * This class is used when an XML request is malformed to retrieve the |
| | | * requestID value using an event XML parser. |
| | | */ |
| | | private class DSMLContentHandler extends DefaultHandler { |
| | | private static class DSMLContentHandler extends DefaultHandler { |
| | | private String requestID; |
| | | /** |
| | | * This function fetches the requestID value of the batchRequest xml |
| | |
| | | * This is defensive - we prevent entity resolving by configuration, but |
| | | * just in case, we ensure that nothing resolves. |
| | | */ |
| | | private class SafeEntityResolver implements EntityResolver |
| | | private static class SafeEntityResolver implements EntityResolver |
| | | { |
| | | @Override |
| | | public InputSource resolveEntity(String publicId, String systemId) |
| | |
| | | * |
| | | * Copyright 2010 Sun Microsystems, Inc. |
| | | * Portions Copyright 2012-2016 ForgeRock AS. |
| | | * Portions Copyright 2017-2024 3A Systems, LLC. |
| | | * Portions Copyright 2017-2026 3A Systems, LLC. |
| | | */ |
| | | package org.forgerock.opendj.grizzly; |
| | | |
| | |
| | | }; |
| | | } |
| | | |
| | | final class ClientConnectionImpl extends BaseFilter implements LDAPClientContext { |
| | | static final class ClientConnectionImpl extends BaseFilter implements LDAPClientContext { |
| | | |
| | | final class GrizzlyBackpressureSubscription implements Subscription { |
| | | static final class GrizzlyBackpressureSubscription implements Subscription { |
| | | private final AtomicLong pendingRequests = new AtomicLong(); |
| | | private final Subscriber<? super LdapRequestEnvelope> subscriber; |
| | | private FilterChainContext suspendedCtx; |
| | |
| | | } |
| | | |
| | | /** Upstream -> BlockingBackpressureSubscription -> Downstream. */ |
| | | private final class BlockingBackpressureSubscription implements Subscription, Processor<Response, Response> { |
| | | private static final class BlockingBackpressureSubscription implements Subscription, Processor<Response, Response> { |
| | | private final AtomicLong pendingRequests = new AtomicLong(); |
| | | private final AtomicInteger missedDrain = new AtomicInteger(); |
| | | private final BlockingQueue<Response> queue = new LinkedBlockingQueue<>(32); |
| | |
| | | * |
| | | * Copyright 2008-2010 Sun Microsystems, Inc. |
| | | * Portions Copyright 2011-2016 ForgeRock AS. |
| | | * Portions Copyright 2026 3A Systems, LLC. |
| | | */ |
| | | package org.opends.guitools.controlpanel.ui; |
| | | |
| | |
| | | * left. The class simply handles this particular case to not to have that |
| | | * inset for the 'All Base DNs' item. |
| | | */ |
| | | private class CustomComboBoxCellRenderer extends CustomListCellRenderer |
| | | private static class CustomComboBoxCellRenderer extends CustomListCellRenderer |
| | | { |
| | | private final LocalizableMessage ALL_BASE_DNS_STRING = INFO_CTRL_PANEL_ALL_BASE_DNS.get(); |
| | | |
| | |
| | | * |
| | | * Copyright 2008-2009 Sun Microsystems, Inc. |
| | | * Portions Copyright 2014-2016 ForgeRock AS. |
| | | * Portions Copyright 2026 3A Systems, LLC. |
| | | */ |
| | | |
| | | package org.opends.guitools.controlpanel.ui; |
| | |
| | | } |
| | | |
| | | /** The task in charge of updating the windows service configuration. */ |
| | | private class WindowsServiceTask extends Task |
| | | private static class WindowsServiceTask extends Task |
| | | { |
| | | private Set<String> backendSet; |
| | | private boolean enableService; |
| | |
| | | * |
| | | * Copyright 2006-2008 Sun Microsystems, Inc. |
| | | * Portions Copyright 2012-2016 ForgeRock AS. |
| | | * Portions Copyright 2026 3A Systems, LLC. |
| | | */ |
| | | package org.opends.quicksetup.util; |
| | | |
| | |
| | | } |
| | | |
| | | /** A file operation. */ |
| | | private abstract class FileOperation { |
| | | private abstract static class FileOperation { |
| | | private File objectFile; |
| | | |
| | | /** |
| | |
| | | * |
| | | * Copyright 2006-2008 Sun Microsystems, Inc. |
| | | * Portions Copyright 2014-2016 ForgeRock AS. |
| | | * Portions Copyright 2026 3A Systems, LLC. |
| | | */ |
| | | package org.opends.server.backends; |
| | | |
| | |
| | | * To avoid parsing and reparsing the contents of backup.info files, we |
| | | * cache the BackupDirectory for each directory using this class. |
| | | */ |
| | | private class CachedBackupDirectory |
| | | private static class CachedBackupDirectory |
| | | { |
| | | /** The path to the 'bak' directory. */ |
| | | private final String directoryPath; |
| | |
| | | * information: "Portions Copyright [year] [name of copyright owner]". |
| | | * |
| | | * Copyright 2015-2016 ForgeRock AS. |
| | | * Portions Copyright 2026 3A Systems, LLC. |
| | | */ |
| | | package org.opends.server.backends.jeb; |
| | | |
| | |
| | | } |
| | | |
| | | /** JE read-only implementation of {@link WriteableTransaction} interface. */ |
| | | private final class ReadOnlyTransactionImpl implements WriteableTransaction |
| | | private static final class ReadOnlyTransactionImpl implements WriteableTransaction |
| | | { |
| | | private final WriteableTransactionImpl delegate; |
| | | |
| | |
| | | } |
| | | |
| | | /** No operation storage transaction faking database files are present and empty. */ |
| | | private final class ReadOnlyEmptyTransactionImpl implements WriteableTransaction |
| | | private static final class ReadOnlyEmptyTransactionImpl implements WriteableTransaction |
| | | { |
| | | @Override |
| | | public void openTree(TreeName name, boolean createOnDemand) |
| | |
| | | * information: "Portions Copyright [year] [name of copyright owner]". |
| | | * |
| | | * Copyright 2014-2016 ForgeRock AS. |
| | | * Portions Copyright 2026 3A Systems, LLC. |
| | | */ |
| | | package org.opends.server.backends.pdb; |
| | | |
| | |
| | | } |
| | | |
| | | /** No operation storage faking database files are present and empty. */ |
| | | private final class ReadOnlyEmptyStorageImpl implements StorageImpl |
| | | private static final class ReadOnlyEmptyStorageImpl implements StorageImpl |
| | | { |
| | | @Override |
| | | public void close() throws IOException |
| | |
| | | * information: "Portions Copyright [year] [name of copyright owner]". |
| | | * |
| | | * Portions Copyright 2015-2016 ForgeRock AS. |
| | | * Portions Copyright 2026 3A Systems, LLC. |
| | | */ |
| | | package org.opends.server.backends.pluggable; |
| | | |
| | |
| | | } |
| | | |
| | | /** Statistics collector. */ |
| | | private class TreeStats |
| | | private static class TreeStats |
| | | { |
| | | private final long count; |
| | | private final long totalKeySize; |
| | |
| | | * |
| | | * Copyright 2010 Sun Microsystems, Inc. |
| | | * Portions Copyright 2014-2016 ForgeRock AS. |
| | | * Portions Copyright 2026 3A Systems, LLC. |
| | | */ |
| | | package org.opends.server.extensions; |
| | | |
| | |
| | | ServerShutdownListener |
| | | { |
| | | /** Helper class for each requestor for use with cn=monitor reporting and users of a specific mountpoint. */ |
| | | private class MonitoredDirectory extends MonitorProvider<MonitorProviderCfg> |
| | | private static class MonitoredDirectory extends MonitorProvider<MonitorProviderCfg> |
| | | { |
| | | private volatile File directory; |
| | | private volatile long lowThreshold; |
| | |
| | | * Helper class for building temporary list of handlers to notify on threshold hits. |
| | | * One object per directory per state will hold all the handlers matching directory and state. |
| | | */ |
| | | private class HandlerNotifier { |
| | | private static class HandlerNotifier { |
| | | private File directory; |
| | | private int state; |
| | | /** Printable list of handlers names, for reporting backend names in alert messages. */ |
| | |
| | | * The error handler simplifies the code of initializeEntryCache(), |
| | | * isConfigurationChangeAcceptable() and applyConfigurationChanges() methods. |
| | | */ |
| | | public class ConfigErrorHandler |
| | | public static class ConfigErrorHandler |
| | | { |
| | | /** Configuration phase. */ |
| | | private EntryCacheCommon.ConfigPhase _configPhase; |
| | |
| | | List<LocalizableMessage> errorMessages |
| | | ) |
| | | { |
| | | EntryCacheCommon ec = new EntryCacheCommon(); |
| | | return ec.new ConfigErrorHandler( |
| | | return new ConfigErrorHandler( |
| | | configPhase, unacceptableReasons, errorMessages); |
| | | } |
| | | |
| | |
| | | * information: "Portions Copyright [year] [name of copyright owner]". |
| | | * |
| | | * Portions Copyright 2011-2016 ForgeRock AS. |
| | | * Portions Copyright 2026 3A Systems, LLC. |
| | | */ |
| | | package org.opends.server.extensions; |
| | | |
| | |
| | | * A connection factory which caches its online/offline state in order to |
| | | * avoid unnecessary connection attempts when it is known to be offline. |
| | | */ |
| | | private final class MonitoredConnectionFactory implements ConnectionFactory |
| | | private static final class MonitoredConnectionFactory implements ConnectionFactory |
| | | { |
| | | private final ConnectionFactory factory; |
| | | |
| | |
| | | } |
| | | |
| | | /** Specialized {@link HttpApplication} using internal connections to this local LDAP server. */ |
| | | private final class AdminHttpApplication implements HttpApplication |
| | | private static final class AdminHttpApplication implements HttpApplication |
| | | { |
| | | private LDAPProfile ldapProfile = LDAPProfile.getInstance(); |
| | | |
| | |
| | | * - processSafeDataUpdateMsg |
| | | * This is a facility to pack many interesting returned object. |
| | | */ |
| | | private class PreparedAssuredInfo |
| | | private static class PreparedAssuredInfo |
| | | { |
| | | /** |
| | | * The list of servers identified as servers we are interested in |
| | |
| | | |
| | | /** Private exception class to handle error message printing. */ |
| | | @SuppressWarnings("serial") |
| | | private class ConfigureDSException extends Exception |
| | | private static class ConfigureDSException extends Exception |
| | | { |
| | | private final int returnedErrorCode; |
| | | private final LocalizableMessage errorMessage; |
| | |
| | | * |
| | | * Copyright 2006-2010 Sun Microsystems, Inc. |
| | | * Portions Copyright 2011-2016 ForgeRock AS. |
| | | * Portions Copyright 2026 3A Systems, LLC. |
| | | */ |
| | | package org.opends.server.tools; |
| | | |
| | |
| | | } |
| | | |
| | | /** Thread that mask user input. */ |
| | | private class ErasingThread extends Thread |
| | | private static class ErasingThread extends Thread |
| | | { |
| | | private boolean stop; |
| | | private String prompt; |