com.orientechnologies.orient.core.storage.ridbag.sbtree

Class OSBTreeCollectionManagerAbstract

java.lang.Object

com.orientechnologies.orient.core.storage.ridbag.sbtree.OSBTreeCollectionManagerAbstract

All Implemented Interfaces:

OCloseable, OOrientShutdownListener, OOrientStartupListener, OSBTreeCollectionManager

Direct Known Subclasses:

OSBTreeCollectionManagerRemote, OSBTreeCollectionManagerShared

public abstract class OSBTreeCollectionManagerAbstract
extends Object
implements OCloseable, OSBTreeCollectionManager, OOrientStartupListener, OOrientShutdownListener

Author:

Artem Orobets (enisher-at-gmail.com)

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	OSBTreeCollectionManagerAbstract.CacheKey
protected static class	OSBTreeCollectionManagerAbstract.SBTreeBonsaiContainer

Field Summary

Fields

Modifier and Type	Field and Description
static String	DEFAULT_EXTENSION
static String	FILE_NAME_PREFIX
protected com.googlecode.concurrentlinkedhashmap.ConcurrentLinkedHashMap<OSBTreeCollectionManagerAbstract.CacheKey,OSBTreeCollectionManagerAbstract.SBTreeBonsaiContainer>	treeCache

Constructor Summary

Constructors

Constructor and Description
OSBTreeCollectionManagerAbstract(OStorage storage)

Method Summary

Modifier and Type	Method and Description
void	clear()
void	close() Closes resources inside of call of OStorage#close().
OSBTreeBonsai<OIdentifiable,Integer>	createAndLoadTree(OAtomicOperation atomicOperation, int clusterId)
OBonsaiCollectionPointer	createSBTree(OAtomicOperation atomicOperation, int clusterId, UUID ownerUUID)
protected abstract OSBTreeBonsai<OIdentifiable,Integer>	createTree(OAtomicOperation atomicOperation, int clusterId)
void	delete(OBonsaiCollectionPointer collectionPointer)
static String	generateLockName(int clusterId) Generates a lock name for the given cluster ID.
OSBTreeBonsai<OIdentifiable,Integer>	loadSBTree(OBonsaiCollectionPointer collectionPointer)
protected abstract OSBTreeBonsai<OIdentifiable,Integer>	loadTree(OBonsaiCollectionPointer collectionPointer)
void	onShutdown()
void	onStartup()
void	releaseSBTree(OBonsaiCollectionPointer collectionPointer)
protected Object	treesSubsetLock(OSBTreeCollectionManagerAbstract.CacheKey cacheKey)

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.orientechnologies.orient.core.storage.ridbag.sbtree.OSBTreeCollectionManager

changedIds, clearChangedIds, clearPendingCollections, listenForChanges, updateCollectionPointer

Field Detail

FILE_NAME_PREFIX

public static final String FILE_NAME_PREFIX

See Also:

Constant Field Values

DEFAULT_EXTENSION

public static final String DEFAULT_EXTENSION

See Also:

Constant Field Values

treeCache

protected final com.googlecode.concurrentlinkedhashmap.ConcurrentLinkedHashMap<OSBTreeCollectionManagerAbstract.CacheKey,OSBTreeCollectionManagerAbstract.SBTreeBonsaiContainer> treeCache

Constructor Detail

OSBTreeCollectionManagerAbstract

public OSBTreeCollectionManagerAbstract(OStorage storage)

Method Detail

generateLockName

public static String generateLockName(int clusterId)

Generates a lock name for the given cluster ID.

Parameters:

clusterId - the cluster ID to generate the lock name for.

Returns:

the generated lock name.

onStartup

public void onStartup()

Specified by:

onStartup in interface OOrientStartupListener

onShutdown

public void onShutdown()

Specified by:

onShutdown in interface OOrientShutdownListener

createAndLoadTree

public OSBTreeBonsai<OIdentifiable,Integer> createAndLoadTree(OAtomicOperation atomicOperation,
                                                              int clusterId)
                                                       throws IOException

Specified by:

createAndLoadTree in interface OSBTreeCollectionManager

Throws:

IOException

createSBTree

public OBonsaiCollectionPointer createSBTree(OAtomicOperation atomicOperation,
                                             int clusterId,
                                             UUID ownerUUID)
                                      throws IOException

Specified by:

createSBTree in interface OSBTreeCollectionManager

Throws:

IOException

loadSBTree

public OSBTreeBonsai<OIdentifiable,Integer> loadSBTree(OBonsaiCollectionPointer collectionPointer)

Specified by:

loadSBTree in interface OSBTreeCollectionManager

releaseSBTree

public void releaseSBTree(OBonsaiCollectionPointer collectionPointer)

Specified by:

releaseSBTree in interface OSBTreeCollectionManager

delete

public void delete(OBonsaiCollectionPointer collectionPointer)

Specified by:

delete in interface OSBTreeCollectionManager

close

public void close()

Description copied from interface: OCloseable

Closes resources inside of call of OStorage#close(). So do not use locks when you call this method or you may have deadlock during storage close. This method is completely house keeping method and plays role of Object#finalize() in case of you need to clean up resources after storage is closed.

Specified by:

close in interface OCloseable

clear

public void clear()

createTree

protected abstract OSBTreeBonsai<OIdentifiable,Integer> createTree(OAtomicOperation atomicOperation,
                                                                   int clusterId)
                                                            throws IOException

Throws:

IOException

loadTree

protected abstract OSBTreeBonsai<OIdentifiable,Integer> loadTree(OBonsaiCollectionPointer collectionPointer)

treesSubsetLock

protected Object treesSubsetLock(OSBTreeCollectionManagerAbstract.CacheKey cacheKey)