jetbrains.exodus.env

Class EnvironmentImpl

java.lang.Object

jetbrains.exodus.env.EnvironmentImpl

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, jetbrains.exodus.backup.Backupable, jetbrains.exodus.env.Environment

Direct Known Subclasses:

ContextualEnvironmentImpl

public class EnvironmentImpl
extends java.lang.Object
implements jetbrains.exodus.env.Environment

Field Summary

Fields

Modifier and Type	Field and Description
static int	META_TREE_ID

Method Summary

Modifier and Type	Method and Description
@NotNull jetbrains.exodus.env.Transaction	beginExclusiveTransaction()
@NotNull jetbrains.exodus.env.Transaction	beginExclusiveTransaction(java.lang.Runnable beginHook)
@NotNull ReadWriteTransaction	beginGCTransaction()
@NotNull jetbrains.exodus.env.Transaction	beginReadonlyTransaction()
@NotNull TransactionBase	beginReadonlyTransaction(java.lang.Runnable beginHook)
@NotNull TransactionBase	beginTransaction()
@NotNull TransactionBase	beginTransaction(java.lang.Runnable beginHook)
protected @NotNull TransactionBase	beginTransaction(java.lang.Runnable beginHook, boolean exclusive, boolean cloneMeta)
ReadonlyTransaction	beginTransactionAt(long highAddress)
void	clear()
void	close()
<T> T	computeInExclusiveTransaction(@NotNull jetbrains.exodus.env.TransactionalComputable<T> computable)
<T> T	computeInReadonlyTransaction(@NotNull jetbrains.exodus.env.TransactionalComputable<T> computable)
<T> T	computeInTransaction(@NotNull jetbrains.exodus.env.TransactionalComputable<T> computable)
protected StoreImpl	createStore(@NotNull java.lang.String name, @NotNull TreeMetaInfo metaInfo)
protected StoreImpl	createTemporaryEmptyStore(java.lang.String name)
void	executeBeforeGc(java.lang.Runnable action)
void	executeInExclusiveTransaction(@NotNull jetbrains.exodus.env.TransactionalExecutable executable)
void	executeInReadonlyTransaction(@NotNull jetbrains.exodus.env.TransactionalExecutable executable)
void	executeInTransaction(@NotNull jetbrains.exodus.env.TransactionalExecutable executable)
void	executeTransactionSafeTask(@NotNull java.lang.Runnable task)
protected void	finishTransaction(@NotNull TransactionBase txn)
void	flushAndSync() Flushes Log's data writer exclusively in commit lock.
void	gc()
long	getAllStoreCount()
@NotNull java.util.List<java.lang.String>	getAllStoreNames(@NotNull jetbrains.exodus.env.Transaction txn)
@NotNull jetbrains.exodus.backup.BackupStrategy	getBackupStrategy()
BTreeBalancePolicy	getBTreeBalancePolicy()
long	getCipherBasicIV()
@Nullable byte[]	getCipherKey()
@Nullable jetbrains.exodus.crypto.StreamCipherProvider	getCipherProvider()
long	getCreated()
@NotNull jetbrains.exodus.env.EnvironmentConfig	getEnvironmentConfig()
jetbrains.exodus.gc.GarbageCollector	getGC()
@NotNull java.lang.String	getLocation()
@NotNull jetbrains.exodus.log.Log	getLog()
MetaTree	getMetaTree()
@NotNull EnvironmentStatistics	getStatistics()
float	getStoreGetCacheHitRate()
int	getStuckTransactionCount()
@Nullable jetbrains.exodus.debug.TxnProfiler	getTxnProfiler()
boolean	isOpen()
@NotNull jetbrains.exodus.env.BitmapImpl	openBitmap(@NotNull java.lang.String name, @NotNull jetbrains.exodus.env.StoreConfig config, @NotNull jetbrains.exodus.env.Transaction transaction)
@NotNull StoreImpl	openStore(@NotNull java.lang.String name, @NotNull jetbrains.exodus.env.StoreConfig config, @NotNull jetbrains.exodus.env.Transaction transaction)
@Nullable StoreImpl	openStore(@NotNull java.lang.String name, @NotNull jetbrains.exodus.env.StoreConfig config, @NotNull jetbrains.exodus.env.Transaction transaction, boolean creationRequired)
void	removeFiles(long[] files, @NotNull jetbrains.exodus.io.RemoveBlockType rbt)
void	removeStore(@NotNull java.lang.String storeName, @NotNull jetbrains.exodus.env.Transaction txn)
void	resumeGC()
boolean	storeExists(@NotNull java.lang.String storeName, @NotNull jetbrains.exodus.env.Transaction txn)
void	suspendGC()
void	truncateStore(@NotNull java.lang.String storeName, @NotNull jetbrains.exodus.env.Transaction txn)

Methods inherited from class java.lang.Object

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

Field Detail

META_TREE_ID

public static final int META_TREE_ID

See Also:

Constant Field Values

Method Detail

getCreated

public long getCreated()

Specified by:

getCreated in interface jetbrains.exodus.env.Environment

getLocation

@NotNull
public @NotNull java.lang.String getLocation()

Specified by:

getLocation in interface jetbrains.exodus.env.Environment

openBitmap

@NotNull
public @NotNull jetbrains.exodus.env.BitmapImpl openBitmap(@NotNull
                                                                    @NotNull java.lang.String name,
                                                                    @NotNull
                                                                    @NotNull jetbrains.exodus.env.StoreConfig config,
                                                                    @NotNull
                                                                    @NotNull jetbrains.exodus.env.Transaction transaction)

Specified by:

openBitmap in interface jetbrains.exodus.env.Environment

getEnvironmentConfig

@NotNull
public @NotNull jetbrains.exodus.env.EnvironmentConfig getEnvironmentConfig()

Specified by:

getEnvironmentConfig in interface jetbrains.exodus.env.Environment

getStatistics

@NotNull
public @NotNull EnvironmentStatistics getStatistics()

Specified by:

getStatistics in interface jetbrains.exodus.env.Environment

getGC

public jetbrains.exodus.gc.GarbageCollector getGC()

getTxnProfiler

@Nullable
public @Nullable jetbrains.exodus.debug.TxnProfiler getTxnProfiler()

openStore

@NotNull
public @NotNull StoreImpl openStore(@NotNull
                                             @NotNull java.lang.String name,
                                             @NotNull
                                             @NotNull jetbrains.exodus.env.StoreConfig config,
                                             @NotNull
                                             @NotNull jetbrains.exodus.env.Transaction transaction)

Specified by:

openStore in interface jetbrains.exodus.env.Environment

openStore

@Nullable
public @Nullable StoreImpl openStore(@NotNull
                                               @NotNull java.lang.String name,
                                               @NotNull
                                               @NotNull jetbrains.exodus.env.StoreConfig config,
                                               @NotNull
                                               @NotNull jetbrains.exodus.env.Transaction transaction,
                                               boolean creationRequired)

Specified by:

openStore in interface jetbrains.exodus.env.Environment

beginTransaction

@NotNull
public @NotNull TransactionBase beginTransaction()

Specified by:

beginTransaction in interface jetbrains.exodus.env.Environment

beginTransaction

@NotNull
public @NotNull TransactionBase beginTransaction(java.lang.Runnable beginHook)

Specified by:

beginTransaction in interface jetbrains.exodus.env.Environment

beginExclusiveTransaction

@NotNull
public @NotNull jetbrains.exodus.env.Transaction beginExclusiveTransaction()

Specified by:

beginExclusiveTransaction in interface jetbrains.exodus.env.Environment

beginExclusiveTransaction

@NotNull
public @NotNull jetbrains.exodus.env.Transaction beginExclusiveTransaction(java.lang.Runnable beginHook)

Specified by:

beginExclusiveTransaction in interface jetbrains.exodus.env.Environment

beginReadonlyTransaction

@NotNull
public @NotNull jetbrains.exodus.env.Transaction beginReadonlyTransaction()

Specified by:

beginReadonlyTransaction in interface jetbrains.exodus.env.Environment

beginReadonlyTransaction

@NotNull
public @NotNull TransactionBase beginReadonlyTransaction(java.lang.Runnable beginHook)

Specified by:

beginReadonlyTransaction in interface jetbrains.exodus.env.Environment

beginGCTransaction

@NotNull
public @NotNull ReadWriteTransaction beginGCTransaction()

beginTransactionAt

public ReadonlyTransaction beginTransactionAt(long highAddress)

executeInTransaction

public void executeInTransaction(@NotNull
                                 @NotNull jetbrains.exodus.env.TransactionalExecutable executable)

Specified by:

executeInTransaction in interface jetbrains.exodus.env.Environment

executeInExclusiveTransaction

public void executeInExclusiveTransaction(@NotNull
                                          @NotNull jetbrains.exodus.env.TransactionalExecutable executable)

Specified by:

executeInExclusiveTransaction in interface jetbrains.exodus.env.Environment

executeInReadonlyTransaction

public void executeInReadonlyTransaction(@NotNull
                                         @NotNull jetbrains.exodus.env.TransactionalExecutable executable)

Specified by:

executeInReadonlyTransaction in interface jetbrains.exodus.env.Environment

computeInTransaction

public <T> T computeInTransaction(@NotNull
                                  @NotNull jetbrains.exodus.env.TransactionalComputable<T> computable)

Specified by:

computeInTransaction in interface jetbrains.exodus.env.Environment

computeInExclusiveTransaction

public <T> T computeInExclusiveTransaction(@NotNull
                                           @NotNull jetbrains.exodus.env.TransactionalComputable<T> computable)

Specified by:

computeInExclusiveTransaction in interface jetbrains.exodus.env.Environment

computeInReadonlyTransaction

public <T> T computeInReadonlyTransaction(@NotNull
                                          @NotNull jetbrains.exodus.env.TransactionalComputable<T> computable)

Specified by:

computeInReadonlyTransaction in interface jetbrains.exodus.env.Environment

executeTransactionSafeTask

public void executeTransactionSafeTask(@NotNull
                                       @NotNull java.lang.Runnable task)

Specified by:

executeTransactionSafeTask in interface jetbrains.exodus.env.Environment

getStuckTransactionCount

public int getStuckTransactionCount()

getCipherProvider

@Nullable
public @Nullable jetbrains.exodus.crypto.StreamCipherProvider getCipherProvider()

Specified by:

getCipherProvider in interface jetbrains.exodus.env.Environment

getCipherKey

@Nullable
public @Nullable byte[] getCipherKey()

Specified by:

getCipherKey in interface jetbrains.exodus.env.Environment

getCipherBasicIV

public long getCipherBasicIV()

Specified by:

getCipherBasicIV in interface jetbrains.exodus.env.Environment

clear

public void clear()

Specified by:

clear in interface jetbrains.exodus.env.Environment

close

public void close()

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface jetbrains.exodus.env.Environment

isOpen

public boolean isOpen()

Specified by:

isOpen in interface jetbrains.exodus.env.Environment

getBackupStrategy

@NotNull
public @NotNull jetbrains.exodus.backup.BackupStrategy getBackupStrategy()

Specified by:

getBackupStrategy in interface jetbrains.exodus.backup.Backupable

truncateStore

public void truncateStore(@NotNull
                          @NotNull java.lang.String storeName,
                          @NotNull
                          @NotNull jetbrains.exodus.env.Transaction txn)

Specified by:

truncateStore in interface jetbrains.exodus.env.Environment

removeStore

public void removeStore(@NotNull
                        @NotNull java.lang.String storeName,
                        @NotNull
                        @NotNull jetbrains.exodus.env.Transaction txn)

Specified by:

removeStore in interface jetbrains.exodus.env.Environment

getAllStoreCount

public long getAllStoreCount()

getAllStoreNames

@NotNull
public @NotNull java.util.List<java.lang.String> getAllStoreNames(@NotNull
                                                                           @NotNull jetbrains.exodus.env.Transaction txn)

Specified by:

getAllStoreNames in interface jetbrains.exodus.env.Environment

storeExists

public boolean storeExists(@NotNull
                           @NotNull java.lang.String storeName,
                           @NotNull
                           @NotNull jetbrains.exodus.env.Transaction txn)

Specified by:

storeExists in interface jetbrains.exodus.env.Environment

getLog

@NotNull
public @NotNull jetbrains.exodus.log.Log getLog()

gc

public void gc()

Specified by:

gc in interface jetbrains.exodus.env.Environment

suspendGC

public void suspendGC()

Specified by:

suspendGC in interface jetbrains.exodus.env.Environment

resumeGC

public void resumeGC()

Specified by:

resumeGC in interface jetbrains.exodus.env.Environment

executeBeforeGc

public void executeBeforeGc(java.lang.Runnable action)

Specified by:

executeBeforeGc in interface jetbrains.exodus.env.Environment

getBTreeBalancePolicy

public BTreeBalancePolicy getBTreeBalancePolicy()

flushAndSync

public void flushAndSync()

Flushes Log's data writer exclusively in commit lock. This guarantees that the data writer is in committed state. Also performs syncing cached by OS data to storage device.

removeFiles

public void removeFiles(long[] files,
                        @NotNull
                        @NotNull jetbrains.exodus.io.RemoveBlockType rbt)

getStoreGetCacheHitRate

public float getStoreGetCacheHitRate()

createStore

protected StoreImpl createStore(@NotNull
                                @NotNull java.lang.String name,
                                @NotNull
                                @NotNull TreeMetaInfo metaInfo)

finishTransaction

protected void finishTransaction(@NotNull
                                 @NotNull TransactionBase txn)

beginTransaction

@NotNull
protected @NotNull TransactionBase beginTransaction(java.lang.Runnable beginHook,
                                                             boolean exclusive,
                                                             boolean cloneMeta)

getMetaTree

public MetaTree getMetaTree()

createTemporaryEmptyStore

protected StoreImpl createTemporaryEmptyStore(java.lang.String name)