com.orientechnologies.orient.core.storage

Class OStorageAbstract

java.lang.Object

com.orientechnologies.orient.core.storage.OStorageAbstract

All Implemented Interfaces:

OSharedContainer, OStorage, OBackupable

Direct Known Subclasses:

OAbstractPaginatedStorage, OStorageRemote

public abstract class OStorageAbstract
extends Object
implements OStorage, OSharedContainer

Nested Class Summary

Nested classes/interfaces inherited from interface com.orientechnologies.orient.core.storage.OStorage

OStorage.LOCKING_STRATEGY, OStorage.SIZE, OStorage.STATUS

Field Summary

Fields

Modifier and Type	Field and Description
protected OCurrentStorageComponentsFactory	componentsFactory
protected OStorageConfiguration	configuration
protected String	mode
protected String	name
protected OSharedContainerImpl	sharedContainer
protected OReadWriteLock	stateLock
protected OStorage.STATUS	status
static ThreadGroup	storageThreadGroup
protected String	url
protected AtomicLong	version

Fields inherited from interface com.orientechnologies.orient.core.storage.OStorage

CLUSTER_DEFAULT_NAME

Constructor Summary

Constructors

Constructor and Description
OStorageAbstract(String name, String iURL, String mode, OReadWriteLock stateLock)

Method Summary

Modifier and Type	Method and Description
<V> V	callInLock(Callable<V> iCallable, boolean iExclusiveLock)
void	checkForClusterPermissions(String iClusterName)
boolean	checkForRecordValidity(OPhysicalPosition ppos)
void	close()
void	close(boolean iForce, boolean onDelete)
long	countRecords() Returns the total number of records.
boolean	dropCluster(String iClusterName, boolean iTruncate)
boolean	existsResource(String iName)
abstract OCluster	getClusterByName(String iClusterName)
OCurrentStorageComponentsFactory	getComponentsFactory()
OStorageConfiguration	getConfiguration()
String	getName()
<T> T	getResource(String iName, Callable<T> iCallback)
OStorage.STATUS	getStatus() Returns the current storage's status
OStorage	getUnderlying()
String	getURL()
long	getVersion() Returns current storage's version as serial.
boolean	isAssigningClusterIds()
boolean	isClosed()
boolean	isDistributed()
protected String	normalizeName(String name)
<T> T	removeResource(String iName)
void	shutdown() This method is called in Orient.shutdown() method.
String	toString()

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.orientechnologies.orient.core.storage.OStorage

addCluster, addCluster, ceilingPhysicalPositions, cleanOutRecord, clearProperties, command, commit, count, count, count, count, create, createRecord, delete, deleteRecord, dropCluster, exists, floorPhysicalPositions, getClusterById, getClusterDataRange, getClusterIdByName, getClusterInstances, getClusterNames, getClusters, getConflictStrategy, getDefaultClusterId, getPhysicalClusterNameById, getRecordMetadata, getSBtreeCollectionManager, getSize, getType, hideRecord, higherPhysicalPositions, incrementalBackup, isRemote, lowerPhysicalPositions, open, readRecord, readRecordIfVersionIsNotLatest, recyclePosition, reload, removeProperty, restoreFromIncrementalBackup, rollback, setCharset, setClusterSelection, setConflictStrategy, setDateFormat, setDateTimeFormat, setDefaultClusterId, setIndexMgrRecordId, setLocaleCountry, setLocaleLanguage, setMinimumClusters, setProperty, setRecordSerializer, setSchemaRecordId, setTimeZone, setValidation, synch, updateConfiguration, updateRecord

Methods inherited from interface com.orientechnologies.orient.core.util.OBackupable

backup, restore

Field Detail

storageThreadGroup

public static final ThreadGroup storageThreadGroup

url

protected final String url

mode

protected final String mode

stateLock

protected final OReadWriteLock stateLock

configuration

protected volatile OStorageConfiguration configuration

componentsFactory

protected volatile OCurrentStorageComponentsFactory componentsFactory

name

protected String name

version

protected AtomicLong version

status

protected volatile OStorage.STATUS status

sharedContainer

protected final OSharedContainerImpl sharedContainer

Constructor Detail

OStorageAbstract

public OStorageAbstract(String name,
                        String iURL,
                        String mode,
                        OReadWriteLock stateLock)

Method Detail

normalizeName

protected String normalizeName(String name)

getClusterByName

public abstract OCluster getClusterByName(String iClusterName)

Specified by:

getClusterByName in interface OStorage

getUnderlying

public OStorage getUnderlying()

Specified by:

getUnderlying in interface OStorage

getConfiguration

public OStorageConfiguration getConfiguration()

Specified by:

getConfiguration in interface OStorage

isClosed

public boolean isClosed()

Specified by:

isClosed in interface OStorage

checkForRecordValidity

public boolean checkForRecordValidity(OPhysicalPosition ppos)

Specified by:

checkForRecordValidity in interface OStorage

getName

public String getName()

Specified by:

getName in interface OStorage

getURL

public String getURL()

Specified by:

getURL in interface OStorage

close

public void close()

Specified by:

close in interface OStorage

close

public void close(boolean iForce,
                  boolean onDelete)

Specified by:

close in interface OStorage

existsResource

public boolean existsResource(String iName)

Specified by:

existsResource in interface OSharedContainer

removeResource

public <T> T removeResource(String iName)

Specified by:

removeResource in interface OSharedContainer

getResource

public <T> T getResource(String iName,
                         Callable<T> iCallback)

Specified by:

getResource in interface OSharedContainer

getVersion

public long getVersion()

Returns current storage's version as serial.

Specified by:

getVersion in interface OStorage

dropCluster

public boolean dropCluster(String iClusterName,
                           boolean iTruncate)

Specified by:

dropCluster in interface OStorage

countRecords

public long countRecords()

Description copied from interface: OStorage

Returns the total number of records.

Specified by:

countRecords in interface OStorage

callInLock

public <V> V callInLock(Callable<V> iCallable,
                        boolean iExclusiveLock)

Specified by:

callInLock in interface OStorage

toString

public String toString()

Overrides:

toString in class Object

getStatus

public OStorage.STATUS getStatus()

Description copied from interface: OStorage

Returns the current storage's status

Specified by:

getStatus in interface OStorage

checkForClusterPermissions

public void checkForClusterPermissions(String iClusterName)

Specified by:

checkForClusterPermissions in interface OStorage

isDistributed

public boolean isDistributed()

Specified by:

isDistributed in interface OStorage

isAssigningClusterIds

public boolean isAssigningClusterIds()

Specified by:

isAssigningClusterIds in interface OStorage

getComponentsFactory

public OCurrentStorageComponentsFactory getComponentsFactory()

Specified by:

getComponentsFactory in interface OStorage

shutdown

public void shutdown()

Description copied from interface: OStorage

This method is called in Orient.shutdown() method. For most of the storages it means that storage will be merely closed, but sometimes additional operations are need to be taken in account.

Specified by:

shutdown in interface OStorage