com.orientechnologies.orient.core.storage

Class OStorageAbstract

java.lang.Object

com.orientechnologies.orient.core.storage.OStorageAbstract

All Implemented Interfaces:

OSharedContainer, OStorage, OStorageInfo, 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.STATUS

Field Summary

Fields

Modifier and Type	Field and Description
protected OCurrentStorageComponentsFactory	componentsFactory
protected OStorageConfiguration	configuration
protected Throwable	error
protected ReentrantReadWriteLock	errorLock
protected boolean	inError
protected String	mode
protected String	name
protected OSharedContainerImpl	sharedContainer This field is used in EE version, do not make it private
protected ReentrantReadWriteLock	stateLock
protected OStorage.STATUS	status
static ThreadGroup	storageThreadGroup
protected String	url

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)

Method Summary

Modifier and Type	Method and Description
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	existsResource(String iName)
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, delete, deleteRecord, dropCluster, exists, floorPhysicalPositions, fullIncrementalBackup, getClusterDataRange, getClusterEncryption, getClusterIdByName, getClusterInstances, getClusterName, getClusterNameById, getClusterNames, getClusterNextPosition, getClusterRecordConflictStrategy, getClusterRecordsSizeById, getClusterRecordsSizeByName, getCreatedAtVersion, getLastClusterPosition, getPhysicalClusterNameById, getRecordConflictStrategy, getRecordMetadata, getRecordStatus, getSBtreeCollectionManager, getSize, getType, higherPhysicalPositions, incrementalBackup, isRemote, isSystemCluster, lowerPhysicalPositions, open, readRecord, readRecordIfVersionIsNotLatest, reload, removeProperty, restoreFromIncrementalBackup, restoreFullIncrementalBackup, setCharset, setClusterAttribute, setClusterAttribute, setClusterSelection, setConflictStrategy, setDateFormat, setDateTimeFormat, setDefaultClusterId, setIndexMgrRecordId, setLocaleCountry, setLocaleLanguage, setMinimumClusters, setProperty, setRecordSerializer, setSchemaRecordId, setTimeZone, setValidation, supportIncremental, synch

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

backup, restore

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

getClusters, getDefaultClusterId

Field Detail

storageThreadGroup

public static final ThreadGroup storageThreadGroup

url

protected final String url

mode

protected final String mode

stateLock

protected final ReentrantReadWriteLock stateLock

errorLock

protected final ReentrantReadWriteLock errorLock

configuration

protected volatile OStorageConfiguration configuration

componentsFactory

protected volatile OCurrentStorageComponentsFactory componentsFactory

name

protected String name

status

protected volatile OStorage.STATUS status

error

protected Throwable error

inError

protected volatile boolean inError

sharedContainer

protected final OSharedContainerImpl sharedContainer

This field is used in EE version, do not make it private

Constructor Detail

OStorageAbstract

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

Method Detail

normalizeName

protected String normalizeName(String name)

getUnderlying

public OStorage getUnderlying()

Specified by:

getUnderlying in interface OStorage

getConfiguration

public OStorageConfiguration getConfiguration()

Specified by:

getConfiguration in interface OStorageInfo

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 OStorageInfo

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)

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

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

isDistributed

public boolean isDistributed()

Specified by:

isDistributed in interface OStorage

isAssigningClusterIds

public boolean isAssigningClusterIds()

Specified by:

isAssigningClusterIds in interface OStorage

Specified by:

isAssigningClusterIds in interface OStorageInfo

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