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

Class OSBTreeCollectionManagerShared

java.lang.Object

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

All Implemented Interfaces:

OOrientShutdownListener, OOrientStartupListener, OSBTreeCollectionManager

public final class OSBTreeCollectionManagerShared
extends Object
implements OSBTreeCollectionManager, OOrientStartupListener, OOrientShutdownListener

Author:

Artem Orobets (enisher-at-gmail.com)

Field Summary

Fields

Modifier and Type	Field	Description
static final String	FILE_EXTENSION
static final String	FILE_NAME_PREFIX

Constructor Summary

Constructors

Constructor	Description
OSBTreeCollectionManagerShared(OAbstractPaginatedStorage storage)

Method Summary

Modifier and Type	Method	Description
Map<UUID,OBonsaiCollectionPointer>	changedIds()
void	clearChangedIds()
void	clearPendingCollections()
void	close()
OSBTreeBonsai<OIdentifiable,Integer>	createAndLoadTree(OAtomicOperation atomicOperation, int clusterId)
void	createComponent(OAtomicOperation operation, int clusterId)
OBonsaiCollectionPointer	createSBTree(int clusterId, OAtomicOperation atomicOperation, UUID ownerUUID)
boolean	delete(OAtomicOperation atomicOperation, OBonsaiCollectionPointer collectionPointer)
void	delete(OBonsaiCollectionPointer collectionPointer)
void	deleteComponentByClusterId(OAtomicOperation atomicOperation, int clusterId)
static String	generateLockName(int clusterId)	Generates a lock name for the given cluster ID.
boolean	isComponentPresent(OAtomicOperation operation, int clusterId)
UUID	listenForChanges(ORidBag collection)	Change UUID to null to prevent its serialization to disk.
void	load()
OSBTreeBonsai<OIdentifiable,Integer>	loadSBTree(OBonsaiCollectionPointer collectionPointer)
void	migrate()
void	onShutdown()
void	onStartup()
void	releaseSBTree(OBonsaiCollectionPointer collectionPointer)
void	updateCollectionPointer(UUID uuid, OBonsaiCollectionPointer pointer)

Methods inherited from class java.lang.Object

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

Field Details

FILE_EXTENSION

public static final String FILE_EXTENSION

See Also:

• Constant Field Values

FILE_NAME_PREFIX

public static final String FILE_NAME_PREFIX

See Also:

• Constant Field Values

Constructor Details

OSBTreeCollectionManagerShared

public OSBTreeCollectionManagerShared(OAbstractPaginatedStorage storage)

Method Details

load

public void load()

migrate

public void migrate()
             throws IOException

Throws:

IOException

createAndLoadTree

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

Specified by:

createAndLoadTree in interface OSBTreeCollectionManager

isComponentPresent

public boolean isComponentPresent(OAtomicOperation operation,
 int clusterId)

createComponent

public void createComponent(OAtomicOperation operation,
 int clusterId)

deleteComponentByClusterId

public void deleteComponentByClusterId(OAtomicOperation atomicOperation,
 int clusterId)

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

createSBTree

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

Specified by:

createSBTree in interface OSBTreeCollectionManager

listenForChanges

public UUID listenForChanges(ORidBag collection)

Change UUID to null to prevent its serialization to disk.

Specified by:

listenForChanges in interface OSBTreeCollectionManager

updateCollectionPointer

public void updateCollectionPointer(UUID uuid,
 OBonsaiCollectionPointer pointer)

Specified by:

updateCollectionPointer in interface OSBTreeCollectionManager

clearPendingCollections

public void clearPendingCollections()

Specified by:

clearPendingCollections in interface OSBTreeCollectionManager

changedIds

public Map<UUID,OBonsaiCollectionPointer> changedIds()

Specified by:

changedIds in interface OSBTreeCollectionManager

clearChangedIds

public void clearChangedIds()

Specified by:

clearChangedIds in interface OSBTreeCollectionManager

onShutdown

public void onShutdown()

Specified by:

onShutdown in interface OOrientShutdownListener

onStartup

public void onStartup()

Specified by:

onStartup in interface OOrientStartupListener

close

public void close()

delete

public boolean delete(OAtomicOperation atomicOperation,
 OBonsaiCollectionPointer collectionPointer)

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.