org.nuxeo.ecm.core.blob.binary

Class CachingBinaryManager

java.lang.Object

org.nuxeo.ecm.core.blob.binary.AbstractBinaryManager

org.nuxeo.ecm.core.blob.binary.CachingBinaryManager

All Implemented Interfaces:

BinaryManager

Direct Known Subclasses:

AbstractCloudBinaryManager, JCloudsBinaryManager, SQLBinaryManager

public abstract class CachingBinaryManager
extends AbstractBinaryManager

Abstract class for a BinaryManager that uses a cache for its files because fetching them is expensive.

Initialization of the BinaryManager must call initializeCache(java.io.File, long, org.nuxeo.ecm.core.blob.binary.FileStorage) from the initialize(java.lang.String, java.util.Map<java.lang.String, java.lang.String>) method.

Since:

5.7

Field Summary

Fields

Modifier and Type	Field and Description
protected File	cachedir
FileCache	fileCache
protected FileStorage	fileStorage
protected static String	LEN_DIGEST_SUFFIX

Fields inherited from class org.nuxeo.ecm.core.blob.binary.AbstractBinaryManager

blobProviderId, DEFAULT_DEPTH, DEFAULT_DIGEST, descriptor, DIGESTS_BY_LENGTH, garbageCollector, MAX_BUF_SIZE, MD5_DIGEST, MD5_DIGEST_LENGTH, MIN_BUF_SIZE, SHA1_DIGEST, SHA1_DIGEST_LENGTH, SHA256_DIGEST, SHA256_DIGEST_LENGTH

Fields inherited from interface org.nuxeo.ecm.core.blob.binary.BinaryManager

PROP_KEY, PROP_PATH

Constructor Summary

Constructors

Constructor and Description
CachingBinaryManager()

Method Summary

Modifier and Type	Method and Description
void	close() Closes the binary manager and releases all resources and temporary objects held by it.
protected Binary	getBinary(InputStream in) Creates a binary value from the given input stream.
Binary	getBinary(String digest) Returns a Binary corresponding to the given digest.
File	getFile(String digest) Gets a file from cache or storage.
Long	getLength(String digest) Gets a file length from cache or storage.
protected Long	getLengthFromCache(String digest)
void	initialize(String blobProviderId, Map<String,String> properties) Initializes the binary manager.
void	initializeCache(File dir, long maxSize, FileStorage fileStorage) Initialize the cache.
void	initializeCache(String cacheSizeStr, FileStorage fileStorage) Initialize the cache.
protected void	putLengthInCache(String digest, Long len)

Methods inherited from class org.nuxeo.ecm.core.blob.binary.AbstractBinaryManager

getBinary, getDefaultDigestAlgorithm, getDescriptor, getDigestAlgorithm, getGarbageCollector, removeBinaries, storeAndDigest, toHexString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

LEN_DIGEST_SUFFIX

protected static final String LEN_DIGEST_SUFFIX

See Also:

Constant Field Values

cachedir

protected File cachedir

fileCache

public FileCache fileCache

fileStorage

protected FileStorage fileStorage

Constructor Detail

CachingBinaryManager

public CachingBinaryManager()

Method Detail

initialize

public void initialize(String blobProviderId,
                       Map<String,String> properties)
                throws IOException

Description copied from interface: BinaryManager

Initializes the binary manager.

Specified by:

initialize in interface BinaryManager

Overrides:

initialize in class AbstractBinaryManager

Parameters:

blobProviderId - the blob provider id for this binary manager

properties - initialization properties

Throws:

IOException

initializeCache

public void initializeCache(File dir,
                            long maxSize,
                            FileStorage fileStorage)

Initialize the cache.

Parameters:

dir - the directory to use to store cached files

maxSize - the maximum size of the cache (in bytes)

fileStorage - the file storage mechanism to use to store and fetch files

Since:

5.9.2

initializeCache

public void initializeCache(String cacheSizeStr,
                            FileStorage fileStorage)
                     throws IOException

Initialize the cache.

Parameters:

cacheSizeStr - the maximum size of the cache (as a String)

fileStorage - the file storage mechanism to use to store and fetch files

Throws:

IOException

Since:

6.0

See Also:

initializeCache(File, long, FileStorage), SizeUtils.parseSizeInBytes(String)

close

public void close()

Description copied from interface: BinaryManager

Closes the binary manager and releases all resources and temporary objects held by it.

getBinary

protected Binary getBinary(InputStream in)
                    throws IOException

Description copied from class: AbstractBinaryManager

Creates a binary value from the given input stream.

Specified by:

getBinary in class AbstractBinaryManager

Throws:

IOException

getBinary

public Binary getBinary(String digest)

Description copied from interface: BinaryManager

Returns a Binary corresponding to the given digest.

A null is returned if the digest could not be found.

Specified by:

getBinary in interface BinaryManager

Specified by:

getBinary in class AbstractBinaryManager

Parameters:

digest - the digest, or null

Returns:

the corresponding binary

getFile

public File getFile(String digest)
             throws IOException

Gets a file from cache or storage.

Used by LazyBinary.

Throws:

IOException

getLength

public Long getLength(String digest)
               throws IOException

Gets a file length from cache or storage.

Use by LazyBinary.

Throws:

IOException

getLengthFromCache

protected Long getLengthFromCache(String digest)
                           throws IOException

Throws:

IOException

putLengthInCache

protected void putLengthInCache(String digest,
                                Long len)
                         throws IOException

Throws:

IOException