|
ozone core API | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.ozoneDB.core.ServerComponent
org.ozoneDB.core.storage.gammaStore.GammaStore
Field Summary | |
private Cache |
containerCache
|
private java.util.Map |
containerNames
|
static PropertyInfo |
DIRECTORY
|
static java.lang.String |
GAMMASTORE_BASE
|
private GarbageCollector |
garbageCollector
The garbage collector. |
private IndexManager |
indexManager
|
private static java.util.logging.Logger |
log
|
static java.lang.String |
OZONE_BASE
|
private static java.lang.String |
PROP_CONTAINERCACHE
|
private static java.lang.String |
PROP_NUMCONFIGS
|
private static java.lang.String |
PROP_STORAGEFACTORY
|
private static java.lang.String |
PROP_STREAMFACTORY
|
private java.util.Properties |
properties
|
private StorageFactory[] |
storageFactories
|
private StreamFactory[] |
streamFactories
|
private StorageFactory |
txStorageFactory
|
static PropertyInfo |
TXSTORAGEFACTORY
|
Fields inherited from class org.ozoneDB.core.ServerComponent |
env |
Constructor Summary | |
GammaStore(Env env)
|
|
GammaStore(java.util.Properties properties)
ozoneDB.gammaStore.numConfigs=1 ozoneDB.gammaStore.0.clusterFactory=org.ozoneDB.core.gammaStore.RandomAccessFileCluster.Factory ozoneDB.gammaStore.0.maxClusterSize=65536 ozoneDB.gammaStore.0.streamFactory=org.ozoneDB.core.gammaStore.GZIPStreamFactory ozoneDB.gammaStore.containerCache=org.ozoneDB.core.gammaStore.SoftReferenceCache While not yet supported there is a possiblility to have multiple configurations. |
Method Summary | |
private void |
abortObjectId(ObjectID objectId)
|
void |
abortTransaction(Transaction ta)
|
DxBag |
clusterOfID(ObjectID id)
Force the Store to make a guess which objects are used together with the container with the specified id. |
void |
commitTransaction(Transaction ta)
|
ObjectContainer |
containerForID(Transaction ta,
ObjectID id)
|
ObjectContainer |
containerForName(Transaction ta,
java.lang.String name)
|
Transaction |
createTransaction(Env env,
User user)
Factory method for creating a new Transaction . |
Cache |
getContainerCache()
|
private java.util.Map |
getContainerNames()
|
private GarbageCollector |
getGarbageCollector()
|
private StorageFactory |
getTxStorageFactory()
|
void |
init(Env env)
Aid constructor, because a store is instantiated with 'newInstance', where we've got no arguments. |
void |
nameContainer(Transaction ta,
ObjectContainer container,
java.lang.String name)
|
ObjectContainer |
newContainerAndLock(Transaction ta,
org.ozoneDB.OzoneCompatible target,
ObjectID objectId,
Permissions permissions,
int lockLevel)
Creates a new object container and initializes it with the specified target object. |
java.lang.Object |
newTransactionData()
|
DxIterator |
objectIDIterator()
|
DxSet |
objectNames(Transaction ta)
|
void |
prepareCommitTransaction(Transaction ta)
Prepare the specified transaction for commit. |
void |
reportNamedObjectsToGarbageCollector()
Tells this StoreManager to report every named object to the garbage collector. |
void |
save()
Save the internal state in the state to the server state properties. |
void |
setContainerCache(Cache containerCache)
|
private void |
setGarbageCollector(GarbageCollector garbageCollector)
|
void |
shutdown()
|
void |
startup()
Start up and load the internal state from the server state properties. |
void |
updateLockLevel(Transaction ta,
ObjectContainer container)
Update lock level of the given container according to the leve of the containers lock object. |
Methods inherited from class org.ozoneDB.core.ServerComponent |
clearChanged, hasChanged, setChanged |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
private static final java.util.logging.Logger log
public static final java.lang.String OZONE_BASE
public static final java.lang.String GAMMASTORE_BASE
public static final PropertyInfo DIRECTORY
public static final PropertyInfo TXSTORAGEFACTORY
private static final java.lang.String PROP_STORAGEFACTORY
private static final java.lang.String PROP_NUMCONFIGS
private static final java.lang.String PROP_STREAMFACTORY
private static final java.lang.String PROP_CONTAINERCACHE
private StorageFactory[] storageFactories
private StreamFactory[] streamFactories
private Cache containerCache
private IndexManager indexManager
private java.util.Properties properties
private java.util.Map containerNames
private GarbageCollector garbageCollector
private StorageFactory txStorageFactory
Constructor Detail |
public GammaStore(java.util.Properties properties)
public GammaStore(Env env)
Method Detail |
public Cache getContainerCache()
public void setContainerCache(Cache containerCache)
private void abortObjectId(ObjectID objectId)
public void abortTransaction(Transaction ta) throws java.io.IOException, java.lang.ClassNotFoundException
abortTransaction
in interface StoreManager
ta
- ID of the comitting transaction.
java.io.IOException
java.lang.ClassNotFoundException
public DxBag clusterOfID(ObjectID id) throws java.lang.Exception
clusterOfID
in interface StoreManager
id
- The ObjectID if the container.
java.lang.Exception
public void commitTransaction(Transaction ta) throws java.io.IOException, java.lang.ClassNotFoundException
commitTransaction
in interface StoreManager
java.io.IOException
java.lang.ClassNotFoundException
public ObjectContainer containerForID(Transaction ta, ObjectID id) throws org.ozoneDB.ObjectNotFoundException, java.io.IOException, java.lang.ClassNotFoundException
containerForID
in interface StoreManager
org.ozoneDB.ObjectNotFoundException
java.io.IOException
java.lang.ClassNotFoundException
public ObjectContainer containerForName(Transaction ta, java.lang.String name) throws java.lang.Exception
containerForName
in interface StoreManager
name
- The object name to search for.ta
-
java.lang.Exception
public void init(Env env)
init
in interface StoreManager
public void nameContainer(Transaction ta, ObjectContainer container, java.lang.String name) throws org.ozoneDB.PermissionDeniedException
nameContainer
in interface StoreManager
ta
- container
- name
-
org.ozoneDB.PermissionDeniedException
public ObjectContainer newContainerAndLock(Transaction ta, org.ozoneDB.OzoneCompatible target, ObjectID objectId, Permissions permissions, int lockLevel) throws java.lang.Exception
newContainerAndLock
in interface StoreManager
ta
- target
- objectId
- permissions
- lockLevel
-
java.lang.Exception
public java.lang.Object newTransactionData()
public DxIterator objectIDIterator()
objectIDIterator
in interface StoreManager
public DxSet objectNames(Transaction ta)
objectNames
in interface StoreManager
ta
- the running transaction
public void prepareCommitTransaction(Transaction ta) throws java.io.IOException, java.lang.ClassNotFoundException
The TransactionManager
let this method run exclusivly. However,
prepareCommitTransaction(org.ozoneDB.core.Transaction)
and commitTransaction(org.ozoneDB.core.Transaction)
are not
an atomar operation.
prepareCommitTransaction
in interface StoreManager
ta
- Transaction that will be commited.
java.io.IOException
java.lang.ClassNotFoundException
public void reportNamedObjectsToGarbageCollector()
reportNamedObjectsToGarbageCollector
in interface StoreManager
public void shutdown() throws java.lang.Exception
shutdown
in interface StoreManager
shutdown
in class ServerComponent
java.lang.Exception
public void startup() throws java.lang.Exception
ServerComponent
startup
in interface StoreManager
startup
in class ServerComponent
java.lang.Exception
public void updateLockLevel(Transaction ta, ObjectContainer container) throws java.io.IOException
updateLockLevel
in interface StoreManager
java.io.IOException
public Transaction createTransaction(Env env, User user)
StoreManager
Transaction
.
createTransaction
in interface StoreManager
private StorageFactory getTxStorageFactory()
private java.util.Map getContainerNames()
private GarbageCollector getGarbageCollector()
private void setGarbageCollector(GarbageCollector garbageCollector)
public void save() throws java.lang.Exception
ServerComponent
save
in class ServerComponent
java.lang.Exception
|
ozone core API | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |