Package org.opends.server.extensions
Class SoftReferenceEntryCache
- java.lang.Object
-
- org.opends.server.api.MonitorProvider
-
- org.opends.server.api.EntryCache<SoftReferenceEntryCacheCfg>
-
- org.opends.server.extensions.SoftReferenceEntryCache
-
- All Implemented Interfaces:
Runnable,MeterBinder,ConfigurationChangeListener<SoftReferenceEntryCacheCfg>
public final class SoftReferenceEntryCache extends EntryCache<SoftReferenceEntryCacheCfg> implements ConfigurationChangeListener<SoftReferenceEntryCacheCfg>, Runnable
This class defines a Directory Server entry cache that uses soft references to manage objects in a way that will allow them to be freed if the JVM is running low on memory.
-
-
Field Summary
-
Fields inherited from class org.opends.server.api.MonitorProvider
registry
-
-
Constructor Summary
Constructors Constructor Description SoftReferenceEntryCache()Creates a new instance of this soft reference entry cache.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description ConfigChangeResultapplyConfigurationChange(SoftReferenceEntryCacheCfg configuration)Applies the configuration changes to this change listener.voidclear()Removes all entries from the cache.voidclearBackend(String backendID)Removes all entries from the cache that are associated with the provided backend.booleancontainsEntry(Dn entryDN)Indicates whether the entry cache currently contains the entry with the specified DN.voidfinalizeEntryCache()Performs any necessary cleanup work (e.g., flushing all cached entries and releasing any other held resources) that should be performed when the server is to be shut down or the entry cache destroyed or replaced.SizedEntrygetEntry(Dn entryDN)Retrieves the entry with its size, with the specified DN from the cache.longgetEntryCount()Retrieves the current number of entries stored within the cache.DngetEntryDN(String backendID, long entryID)Retrieves the entry DN for the entry with the specified ID on the specific backend from the cache.voidhandleLowMemory()Attempts to react to a scenario in which it is determined that the system is running low on available memory.voidinitializeEntryCache(ServerContext serverContext, SoftReferenceEntryCacheCfg configuration)Initializes this entry cache implementation so that it will be available for storing and retrieving entries.booleanisConfigurationAcceptable(SoftReferenceEntryCacheCfg configuration, List<LocalizableMessage> unacceptableReasons)Indicates whether the provided configuration is acceptable for this entry cache.booleanisConfigurationChangeAcceptable(SoftReferenceEntryCacheCfg configuration, List<LocalizableMessage> unacceptableReasons)Indicates whether the proposed change to the configuration is acceptable to this change listener.voidputEntry(SizedEntry entry, String backendID, long entryID)Stores the provided entry in the cache.booleanputEntryIfAbsent(SizedEntry entry, String backendID, long entryID)Stores the provided entry in the cache only if it does not conflict with an entry that already exists.voidremoveEntry(Dn entryDN)Removes the specified entry from the cache.voidrun()Operate in a loop, receiving notification of soft references that have been freed and removing the corresponding entries from the cache.StringtoVerboseString()Return a verbose string representation of the current cache maps.-
Methods inherited from class org.opends.server.api.EntryCache
addMonitorObjectClassNames, bindTo, computeMonitorInstanceDn, filtersAllowCaching, getEntry, getServerContext, newMeterRegistryHolder, recordMiss, recordTry, setIncludeExcludeFilters
-
Methods inherited from class org.opends.server.api.MonitorProvider
configurationDnToMonitorDn, deregisterAll, getMonitorEntry, getMonitorInstanceDn, toString
-
-
-
-
Method Detail
-
initializeEntryCache
public void initializeEntryCache(ServerContext serverContext, SoftReferenceEntryCacheCfg configuration) throws ConfigException, InitializationException
Description copied from class:EntryCacheInitializes this entry cache implementation so that it will be available for storing and retrieving entries.- Overrides:
initializeEntryCachein classEntryCache<SoftReferenceEntryCacheCfg>- Parameters:
serverContext- The server context.configuration- The configuration to use to initialize the entry cache.- Throws:
ConfigException- If there is a problem with the provided configuration entry that would prevent this entry cache from being used.InitializationException- If a problem occurs during the initialization process that is not related to the configuration.
-
finalizeEntryCache
public void finalizeEntryCache()
Description copied from class:EntryCachePerforms any necessary cleanup work (e.g., flushing all cached entries and releasing any other held resources) that should be performed when the server is to be shut down or the entry cache destroyed or replaced.- Specified by:
finalizeEntryCachein classEntryCache<SoftReferenceEntryCacheCfg>
-
containsEntry
public boolean containsEntry(Dn entryDN)
Description copied from class:EntryCacheIndicates whether the entry cache currently contains the entry with the specified DN. This method may be called without holding any locks if a point-in-time check is all that is required. Note that this method is called from @see #getEntry(DN entryDN, LockType lockType, List lockList)- Specified by:
containsEntryin classEntryCache<SoftReferenceEntryCacheCfg>- Parameters:
entryDN- The DN for which to make the determination.- Returns:
trueif the entry cache currently contains the entry with the specified DN, orfalseif not.
-
getEntry
public SizedEntry getEntry(Dn entryDN)
Description copied from class:EntryCacheRetrieves the entry with its size, with the specified DN from the cache.- Specified by:
getEntryin classEntryCache<SoftReferenceEntryCacheCfg>- Parameters:
entryDN- The DN of the entry to retrieve.- Returns:
- The requested entry with its size if it is present in the cache, or
nullif it is not present.
-
getEntryDN
public Dn getEntryDN(String backendID, long entryID)
Description copied from class:EntryCacheRetrieves the entry DN for the entry with the specified ID on the specific backend from the cache. The caller should have already acquired a read or write lock for the entry if such protection is needed. Note that this method is called from @see #getEntry(Backend backend, long entryID, LockType lockType, List lockList)- Specified by:
getEntryDNin classEntryCache<SoftReferenceEntryCacheCfg>- Parameters:
backendID- ID of the backend associated with the entry for which to retrieve the entry DN.entryID- The entry ID within the provided backend for which to retrieve the entry DN.- Returns:
- The entry DN for the requested entry, or
nullif it is not present in the cache.
-
putEntry
public void putEntry(SizedEntry entry, String backendID, long entryID)
Description copied from class:EntryCacheStores the provided entry in the cache. Note that the mechanism that it uses to achieve this is implementation-dependent, and it is acceptable for the entry to not actually be stored in any cache.- Specified by:
putEntryin classEntryCache<SoftReferenceEntryCacheCfg>- Parameters:
entry- The entry to store in the cache.backendID- ID of the backend with which the entry is associated.entryID- The entry ID within the provided backend that uniquely identifies the specified entry.
-
putEntryIfAbsent
public boolean putEntryIfAbsent(SizedEntry entry, String backendID, long entryID)
Description copied from class:EntryCacheStores the provided entry in the cache only if it does not conflict with an entry that already exists. Note that the mechanism that it uses to achieve this is implementation-dependent, and it is acceptable for the entry to not actually be stored in any cache. However, this method must not overwrite an existing version of the entry.- Specified by:
putEntryIfAbsentin classEntryCache<SoftReferenceEntryCacheCfg>- Parameters:
entry- The entry to store in the cache.backendID- ID of the backend with which the entry is associated.entryID- The entry ID within the provided backend that uniquely identifies the specified entry.- Returns:
falseif an existing entry or some other problem prevented the method from completing successfully, ortrueif there was no conflict and the entry was either stored or the cache determined that this entry should never be cached for some reason.
-
removeEntry
public void removeEntry(Dn entryDN)
Description copied from class:EntryCacheRemoves the specified entry from the cache.- Specified by:
removeEntryin classEntryCache<SoftReferenceEntryCacheCfg>- Parameters:
entryDN- The DN of the entry to remove from the cache.
-
clear
public void clear()
Description copied from class:EntryCacheRemoves all entries from the cache. The cache should still be available for future use.- Specified by:
clearin classEntryCache<SoftReferenceEntryCacheCfg>
-
clearBackend
public void clearBackend(String backendID)
Description copied from class:EntryCacheRemoves all entries from the cache that are associated with the provided backend.- Specified by:
clearBackendin classEntryCache<SoftReferenceEntryCacheCfg>- Parameters:
backendID- ID of the backend for which to flush the associated entries.
-
handleLowMemory
public void handleLowMemory()
Description copied from class:EntryCacheAttempts to react to a scenario in which it is determined that the system is running low on available memory. In this case, the entry cache should attempt to free some memory if possible to try to avoid out of memory errors.- Specified by:
handleLowMemoryin classEntryCache<SoftReferenceEntryCacheCfg>
-
isConfigurationAcceptable
public boolean isConfigurationAcceptable(SoftReferenceEntryCacheCfg configuration, List<LocalizableMessage> unacceptableReasons)
Description copied from class:EntryCacheIndicates whether the provided configuration is acceptable for this entry cache. It should be possible to call this method on an uninitialized entry cache instance in order to determine whether the entry cache would be able to use the provided configuration.- Overrides:
isConfigurationAcceptablein classEntryCache<SoftReferenceEntryCacheCfg>- Parameters:
configuration- The entry cache configuration for which to make the determination.unacceptableReasons- A list that may be used to hold the reasons that the provided configuration is not acceptable.- Returns:
trueif the provided configuration is acceptable for this entry cache, orfalseif not.
-
isConfigurationChangeAcceptable
public boolean isConfigurationChangeAcceptable(SoftReferenceEntryCacheCfg configuration, List<LocalizableMessage> unacceptableReasons)
Description copied from interface:ConfigurationChangeListenerIndicates whether the proposed change to the configuration is acceptable to this change listener.- Specified by:
isConfigurationChangeAcceptablein interfaceConfigurationChangeListener<SoftReferenceEntryCacheCfg>- Parameters:
configuration- The new configuration containing the changes.unacceptableReasons- A list that can be used to hold messages about why the provided configuration is not acceptable.- Returns:
- Returns
trueif the proposed change is acceptable, orfalseif it is not.
-
applyConfigurationChange
public ConfigChangeResult applyConfigurationChange(SoftReferenceEntryCacheCfg configuration)
Description copied from interface:ConfigurationChangeListenerApplies the configuration changes to this change listener.- Specified by:
applyConfigurationChangein interfaceConfigurationChangeListener<SoftReferenceEntryCacheCfg>- Parameters:
configuration- The new configuration containing the changes.- Returns:
- Returns information about the result of changing the configuration.
-
run
public void run()
Operate in a loop, receiving notification of soft references that have been freed and removing the corresponding entries from the cache.
-
getEntryCount
public long getEntryCount()
Description copied from class:EntryCacheRetrieves the current number of entries stored within the cache.- Specified by:
getEntryCountin classEntryCache<SoftReferenceEntryCacheCfg>- Returns:
- The current number of entries stored within the cache.
-
toVerboseString
public String toVerboseString()
Description copied from class:EntryCacheReturn a verbose string representation of the current cache maps. This is useful primary for debugging and diagnostic purposes such as in the entry cache unit tests.This method is invoked by unit tests for debugging.
- Specified by:
toVerboseStringin classEntryCache<SoftReferenceEntryCacheCfg>- Returns:
- String verbose string representation of the current cache maps in the following format: dn:id:backend one
cache entry map representation per line or
nullif all maps are empty.
-
-