Package com.orientechnologies.orient.core.storage.memory

Class ODirectMemoryStorage

java.lang.Object

com.orientechnologies.orient.core.storage.impl.local.OAbstractPaginatedStorage

com.orientechnologies.orient.core.storage.memory.ODirectMemoryStorage

All Implemented Interfaces:

OBackgroundExceptionListener, OCheckpointRequestListener, OFreezableStorageComponent, OPageIsBrokenListener, OIdentifiableStorage, OStorage, OStorageInfo, OBackupable

public class ODirectMemoryStorage
extends OAbstractPaginatedStorage

Since:

7/9/14

Author:

Andrey Lomakin (a.lomakin-at-orientdb.com)

Nested Class Summary

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

OStorage.LOCKING_STRATEGY, OStorage.STATUS

Field Summary

Fields inherited from class com.orientechnologies.orient.core.storage.impl.local.OAbstractPaginatedStorage

ALGORITHM_NAME, atomicOperationsManager, atomicOperationsTable, componentsFactory, configuration, context, DATABASE_INSTANCE_ID, ENCRYPTION_IV, error, fuzzyCheckpointExecutor, IV_EXT, IV_NAME, name, readCache, sbTreeCollectionManager, stateLock, status, storageThreadGroup, TRANSFORMATION, url, writeAheadLog, writeCache

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

CLUSTER_DEFAULT_NAME

Constructor Summary

Constructors

Constructor	Description
ODirectMemoryStorage(String name, String filePath, int id, OrientDBInternal context)

Method Summary

Modifier and Type	Method	Description
protected void	addFileToDirectory(String name, InputStream stream, File directory)
List<String>	backup(OutputStream out, Map<String,Object> options, Callable<Object> callable, OCommandOutputListener iListener, int compressionLevel, int bufferSize)	Executes a backup of the database.
protected Path	checkAndCleanPath(String zipPath)
protected void	checkBackupRunning()
protected OLogSequenceNumber	copyWALToIncrementalBackup(ZipOutputStream zipOutputStream, long startSegment)
protected OWriteAheadLog	createWalFromIBUFiles(File directory, OContextConfiguration contextConfiguration, Locale locale, byte[] iv)
protected File	createWalTempDirectory()
boolean	exists()
void	flushAllData()
protected byte[]	getIv()
String	getType()	Returns the storage's type.
String	getURL()
protected void	initIv()
protected void	initWalAndDiskCache(OContextConfiguration contextConfiguration)
boolean	isMemory()
protected boolean	isWriteAllowedDuringIncrementalBackup()
protected void	postCloseSteps(boolean onDelete, boolean internalError, long lastTxId)
protected void	readIv()
void	restore(InputStream in, Map<String,Object> options, Callable<Object> callable, OCommandOutputListener iListener)	Executes a restore of a database backup.
void	shutdown()	This method is called in Orient.shutdown() method.

Methods inherited from class com.orientechnologies.orient.core.storage.impl.local.OAbstractPaginatedStorage

acquireReadLock, acquireReadLock, acquireWriteLock, acquireWriteLock, addCluster, addCluster, addIndexEngine, browseCluster, callIndexEngine, ceilingPhysicalPositions, check, checkDatabaseInstanceId, checkErrorState, checkForRecordValidity, checkIfStorageDirty, checkName, checkOpennessAndMigration, cleanOutRecord, clearIndex, clearProperties, clearStorageDirty, close, closeClusters, closeIndexes, commit, commit, commitPreAllocated, count, count, countRecords, create, createRecord, createSBTree, delete, deleteIndexEngine, deleteRecord, deleteTreeRidBag, doCreate, doEncryptionDecryption, doShutdown, dropCluster, dropCluster, endBackup, endDDL, extractEngineAPIVersion, extractTransactionsFromWal, fireConfigurationUpdateNotifications, floorPhysicalPositions, freeze, fullIncrementalBackup, generateDatabaseInstanceId, getAtomicOperationsManager, getClusterDataRange, getClusterEncryption, getClusterIdByName, getClusterInstances, getClusterName, getClusterNameById, getClusterNames, getClusterNextPosition, getClusterRecordConflictStrategy, getClusterRecordsSizeById, getClusterRecordsSizeByName, getClusters, getClustersIds, getComponentsFactory, getConfiguration, getContext, getCreatedAtVersion, getDefaultClusterId, getId, getIdGen, getIndexDescStream, getIndexEngine, getIndexKeyStream, getIndexSize, getIndexStream, getIndexValue, getIndexValues, getLastClusterPosition, getLastMetadata, getLSN, getName, getOpenedAtVersion, getPhysicalClusterNameById, getReadCache, getRecordConflictStrategy, getRecordMetadata, getRecordScanned, getRecordStatus, getRecoverListener, getRidsGroupedByCluster, getSBtreeCollectionManager, getSize, getStatus, getUuid, getVersion, getVersionForKey, getWALInstance, getWriteCache, hasIndexRangeQuerySupport, higherPhysicalPositions, incrementalBackup, incrementalBackup, incrementalBackup, incrementalSync, initConfiguration, isAssigningClusterIds, isClosed, isClosedInternal, isDDLRunning, isDeleted, isDirty, isIcrementalBackupRunning, isInError, isSystemCluster, iterateIndexEntriesBetween, iterateIndexEntriesMajor, iterateIndexEntriesMinor, loadEncryption, loadIndexEngine, logAndPrepareForRethrow, logAndPrepareForRethrow, logAndPrepareForRethrow, logAndPrepareForRethrow, logAndPrepareForRethrow, lowerPhysicalPositions, makeFuzzyCheckpoint, makeStorageDirty, metadataOnly, moveToErrorStateIfNeeded, normalizeName, onException, open, openClusters, openIndexes, pageIsBroken, pauseConfigurationUpdateNotifications, postCreateSteps, postDeleteSteps, postProcessIncrementalRestore, preallocateRids, preCloseSteps, preCreateSteps, preprocessingIncrementalRestore, readDatabaseInstanceId, readRecord, readRecordIfVersionIsNotLatest, registerRecoverListener, release, releaseReadLock, releaseWriteLock, reload, removeIndexValuesContainer, removeProperty, requestCheckpoint, resolveObjectSerializer, restoreAtomicUnit, restoreFrom, restoreFromIncrementalBackup, restoreFromIncrementalBackup, restoreFullIncrementalBackup, setCharset, setClusterAttribute, setClusterSelection, setConflictStrategy, setDateFormat, setDateTimeFormat, setDefaultClusterId, setIndexMgrRecordId, setLocaleCountry, setLocaleLanguage, setMinimumClusters, setProperty, setRecordSerializer, setSchemaRecordId, setStorageConfigurationUpdateListener, setTimeZone, setValidation, startBackup, startDDL, supportIncremental, synch, toString, unregisterRecoverListener, updateRecord, wereDataRestoredAfterOpen, wereNonTxOperationsPerformedInPreviousOpen

Methods inherited from class java.lang.Object

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

Constructor Details

ODirectMemoryStorage

public ODirectMemoryStorage(String name,
 String filePath,
 int id,
 OrientDBInternal context)

Method Details

initWalAndDiskCache

protected void initWalAndDiskCache(OContextConfiguration contextConfiguration)

Specified by:

initWalAndDiskCache in class OAbstractPaginatedStorage

postCloseSteps

protected void postCloseSteps(boolean onDelete,
 boolean internalError,
 long lastTxId)

Specified by:

postCloseSteps in class OAbstractPaginatedStorage

exists

public boolean exists()

getType

public String getType()

Description copied from interface: OStorage

Returns the storage's type.

getURL

public String getURL()

Specified by:

getURL in interface OStorageInfo

Overrides:

getURL in class OAbstractPaginatedStorage

flushAllData

public void flushAllData()

Overrides:

flushAllData in class OAbstractPaginatedStorage

readIv

protected void readIv()

Specified by:

readIv in class OAbstractPaginatedStorage

getIv

protected byte[] getIv()

Specified by:

getIv in class OAbstractPaginatedStorage

initIv

protected void initIv()

Specified by:

initIv in class OAbstractPaginatedStorage

backup

public List<String> backup(OutputStream out,
 Map<String,Object> options,
 Callable<Object> callable,
 OCommandOutputListener iListener,
 int compressionLevel,
 int bufferSize)

Description copied from interface: OBackupable

Executes a backup of the database. During the backup the database will be frozen in read-only mode.

Parameters:

out - OutputStream used to write the backup content. Use a FileOutputStream to make the backup persistent on disk

options - Backup options as Map<String, Object> object

callable - Callback to execute when the database is locked

iListener - Listener called for backup messages

compressionLevel - ZIP Compression level between 1 (the minimum) and 9 (maximum). The bigger is the compression, the smaller will be the final backup content, but will consume more CPU and time to execute

bufferSize - Buffer size in bytes, the bigger is the buffer, the more efficient will be the compression

See Also:

• ODatabaseExport

restore

public void restore(InputStream in,
 Map<String,Object> options,
 Callable<Object> callable,
 OCommandOutputListener iListener)

Description copied from interface: OBackupable

Executes a restore of a database backup. During the restore the database will be frozen in read-only mode.

Parameters:

in - InputStream used to read the backup content. Use a FileInputStream to read a backup on a disk

options - Backup options as Map<String, Object> object

callable - Callback to execute when the database is locked

iListener - Listener called for backup messages

See Also:

• ODatabaseImport

copyWALToIncrementalBackup

protected OLogSequenceNumber copyWALToIncrementalBackup(ZipOutputStream zipOutputStream,
 long startSegment)

Specified by:

copyWALToIncrementalBackup in class OAbstractPaginatedStorage

isWriteAllowedDuringIncrementalBackup

protected boolean isWriteAllowedDuringIncrementalBackup()

Specified by:

isWriteAllowedDuringIncrementalBackup in class OAbstractPaginatedStorage

createWalTempDirectory

protected File createWalTempDirectory()

Specified by:

createWalTempDirectory in class OAbstractPaginatedStorage

addFileToDirectory

protected void addFileToDirectory(String name,
 InputStream stream,
 File directory)

Specified by:

addFileToDirectory in class OAbstractPaginatedStorage

createWalFromIBUFiles

protected OWriteAheadLog createWalFromIBUFiles(File directory,
 OContextConfiguration contextConfiguration,
 Locale locale,
 byte[] iv)

Specified by:

createWalFromIBUFiles in class OAbstractPaginatedStorage

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

Overrides:

shutdown in class OAbstractPaginatedStorage

checkBackupRunning

protected void checkBackupRunning()

Overrides:

checkBackupRunning in class OAbstractPaginatedStorage

checkAndCleanPath

protected Path checkAndCleanPath(String zipPath)

Specified by:

checkAndCleanPath in class OAbstractPaginatedStorage

isMemory

public boolean isMemory()

Specified by:

isMemory in interface OStorage

Overrides:

isMemory in class OAbstractPaginatedStorage