diff options
Diffstat (limited to 'java/src/Freeze/ObjectStore.java')
| -rw-r--r-- | java/src/Freeze/ObjectStore.java | 560 |
1 files changed, 280 insertions, 280 deletions
diff --git a/java/src/Freeze/ObjectStore.java b/java/src/Freeze/ObjectStore.java index aa1a75af487..4d39e2cb365 100644 --- a/java/src/Freeze/ObjectStore.java +++ b/java/src/Freeze/ObjectStore.java @@ -13,102 +13,102 @@ class ObjectStore implements IceUtil.Store { ObjectStore(String facet, boolean createDb, EvictorI evictor, - java.util.List indices, boolean populateEmptyIndices) + java.util.List indices, boolean populateEmptyIndices) { - _cache = new IceUtil.Cache(this); - - _facet = facet; - _evictor = evictor; - _indices = indices; - _communicator = evictor.communicator(); - - if(facet.equals("")) - { - _dbName = EvictorI.defaultDb; - } - else - { - _dbName = facet; - } + _cache = new IceUtil.Cache(this); + + _facet = facet; + _evictor = evictor; + _indices = indices; + _communicator = evictor.communicator(); + + if(facet.equals("")) + { + _dbName = EvictorI.defaultDb; + } + else + { + _dbName = facet; + } - Connection connection = Util.createConnection(_communicator, evictor.dbEnv().getEnvName()); + Connection connection = Util.createConnection(_communicator, evictor.dbEnv().getEnvName()); - try - { - Catalog catalog = new Catalog(connection, Util.catalogName(), true); - CatalogData catalogData = (CatalogData)catalog.get(evictor.filename()); - - if(catalogData != null && catalogData.evictor == false) - { - DatabaseException ex = new DatabaseException(); - ex.message = _evictor.errorPrefix() + evictor.filename() + " is not an evictor database"; - throw ex; - } - - com.sleepycat.db.Environment dbEnv = evictor.dbEnv().getEnv(); - - try - { - Transaction tx = connection.beginTransaction(); - com.sleepycat.db.Transaction txn = Util.getTxn(tx); + try + { + Catalog catalog = new Catalog(connection, Util.catalogName(), true); + CatalogData catalogData = (CatalogData)catalog.get(evictor.filename()); + + if(catalogData != null && catalogData.evictor == false) + { + DatabaseException ex = new DatabaseException(); + ex.message = _evictor.errorPrefix() + evictor.filename() + " is not an evictor database"; + throw ex; + } + + com.sleepycat.db.Environment dbEnv = evictor.dbEnv().getEnv(); + + try + { + Transaction tx = connection.beginTransaction(); + com.sleepycat.db.Transaction txn = Util.getTxn(tx); - // - // TODO: FREEZE_DB_MODE - // - com.sleepycat.db.DatabaseConfig config = new com.sleepycat.db.DatabaseConfig(); - config.setType(com.sleepycat.db.DatabaseType.BTREE); - config.setAllowCreate(createDb); - _db = dbEnv.openDatabase(txn, evictor.filename(), _dbName, config); + // + // TODO: FREEZE_DB_MODE + // + com.sleepycat.db.DatabaseConfig config = new com.sleepycat.db.DatabaseConfig(); + config.setType(com.sleepycat.db.DatabaseType.BTREE); + config.setAllowCreate(createDb); + _db = dbEnv.openDatabase(txn, evictor.filename(), _dbName, config); - java.util.Iterator p = _indices.iterator(); - while(p.hasNext()) - { - Index index = (Index) p.next(); - index.associate(this, txn, createDb, populateEmptyIndices); - } - - if(catalogData == null) - { - catalogData = new CatalogData(); - catalogData.evictor = true; - catalog.put(evictor.filename(), catalogData); - } + java.util.Iterator p = _indices.iterator(); + while(p.hasNext()) + { + Index index = (Index) p.next(); + index.associate(this, txn, createDb, populateEmptyIndices); + } + + if(catalogData == null) + { + catalogData = new CatalogData(); + catalogData.evictor = true; + catalog.put(evictor.filename(), catalogData); + } - tx.commit(); - } - catch(java.io.FileNotFoundException dx) - { - NotFoundException ex = new NotFoundException(); - ex.initCause(dx); - ex.message = _evictor.errorPrefix() + "Db.open: " + dx.getMessage(); - throw ex; - } - catch(com.sleepycat.db.DatabaseException dx) - { - DatabaseException ex = new DatabaseException(); - ex.initCause(dx); - ex.message = _evictor.errorPrefix() + "Db.open: " + dx.getMessage(); - throw ex; - } - finally - { - Transaction tx = connection.currentTransaction(); - if(tx != null) - { - try - { - tx.rollback(); - } - catch(DatabaseException de) - { - } - } - } - } - finally - { - connection.close(); - } + tx.commit(); + } + catch(java.io.FileNotFoundException dx) + { + NotFoundException ex = new NotFoundException(); + ex.initCause(dx); + ex.message = _evictor.errorPrefix() + "Db.open: " + dx.getMessage(); + throw ex; + } + catch(com.sleepycat.db.DatabaseException dx) + { + DatabaseException ex = new DatabaseException(); + ex.initCause(dx); + ex.message = _evictor.errorPrefix() + "Db.open: " + dx.getMessage(); + throw ex; + } + finally + { + Transaction tx = connection.currentTransaction(); + if(tx != null) + { + try + { + tx.rollback(); + } + catch(DatabaseException de) + { + } + } + } + } + finally + { + connection.close(); + } } protected void @@ -123,162 +123,162 @@ class ObjectStore implements IceUtil.Store void close() { - try - { - _db.close(); - - java.util.Iterator p = _indices.iterator(); - while(p.hasNext()) - { - Index index = (Index) p.next(); - index.close(); - } - _indices.clear(); - } - catch(com.sleepycat.db.DatabaseException dx) - { - DatabaseException ex = new DatabaseException(); - ex.initCause(dx); - ex.message = _evictor.errorPrefix() + "Db.close: " + dx.getMessage(); - throw ex; - } - _db = null; + try + { + _db.close(); + + java.util.Iterator p = _indices.iterator(); + while(p.hasNext()) + { + Index index = (Index) p.next(); + index.close(); + } + _indices.clear(); + } + catch(com.sleepycat.db.DatabaseException dx) + { + DatabaseException ex = new DatabaseException(); + ex.initCause(dx); + ex.message = _evictor.errorPrefix() + "Db.close: " + dx.getMessage(); + throw ex; + } + _db = null; } boolean dbHasObject(Ice.Identity ident) { - byte[] key = marshalKey(ident, _communicator); - com.sleepycat.db.DatabaseEntry dbKey = new com.sleepycat.db.DatabaseEntry(key); - - // - // Keep 0 length since we're not interested in the data - // - com.sleepycat.db.DatabaseEntry dbValue = new com.sleepycat.db.DatabaseEntry(); - dbValue.setPartial(true); - - for(;;) - { - try - { - com.sleepycat.db.OperationStatus err = _db.get(null, dbKey, dbValue, null); - - if(err == com.sleepycat.db.OperationStatus.SUCCESS) - { - return true; - } - else if(err == com.sleepycat.db.OperationStatus.NOTFOUND) - { - return false; - } - else - { - throw new DatabaseException(); - } - } - catch(com.sleepycat.db.DeadlockException dx) - { - if(_evictor.deadlockWarning()) - { - _communicator.getLogger().warning("Deadlock in Freeze.ObjectStore.dhHasObject while reading " + - "Db \"" + _evictor.filename() + "/" + _dbName + - "\"; retrying..."); - } + byte[] key = marshalKey(ident, _communicator); + com.sleepycat.db.DatabaseEntry dbKey = new com.sleepycat.db.DatabaseEntry(key); + + // + // Keep 0 length since we're not interested in the data + // + com.sleepycat.db.DatabaseEntry dbValue = new com.sleepycat.db.DatabaseEntry(); + dbValue.setPartial(true); + + for(;;) + { + try + { + com.sleepycat.db.OperationStatus err = _db.get(null, dbKey, dbValue, null); + + if(err == com.sleepycat.db.OperationStatus.SUCCESS) + { + return true; + } + else if(err == com.sleepycat.db.OperationStatus.NOTFOUND) + { + return false; + } + else + { + throw new DatabaseException(); + } + } + catch(com.sleepycat.db.DeadlockException dx) + { + if(_evictor.deadlockWarning()) + { + _communicator.getLogger().warning("Deadlock in Freeze.ObjectStore.dhHasObject while reading " + + "Db \"" + _evictor.filename() + "/" + _dbName + + "\"; retrying..."); + } - // - // Ignored, try again - // - } - catch(com.sleepycat.db.DatabaseException dx) - { - DatabaseException ex = new DatabaseException(); - ex.initCause(dx); - ex.message = _evictor.errorPrefix() + "Db.get: " + dx.getMessage(); - throw ex; - } - } + // + // Ignored, try again + // + } + catch(com.sleepycat.db.DatabaseException dx) + { + DatabaseException ex = new DatabaseException(); + ex.initCause(dx); + ex.message = _evictor.errorPrefix() + "Db.get: " + dx.getMessage(); + throw ex; + } + } } void save(byte[] key, byte[] value, byte status, com.sleepycat.db.Transaction tx) - throws com.sleepycat.db.DatabaseException + throws com.sleepycat.db.DatabaseException { - switch(status) - { - case EvictorElement.created: - case EvictorElement.modified: - { - com.sleepycat.db.DatabaseEntry dbKey = new com.sleepycat.db.DatabaseEntry(key); - com.sleepycat.db.DatabaseEntry dbValue = new com.sleepycat.db.DatabaseEntry(value); - com.sleepycat.db.OperationStatus err; - if(status == EvictorElement.created) - { - err = _db.putNoOverwrite(tx, dbKey, dbValue); - } - else - { - err = _db.put(tx, dbKey, dbValue); - } - if(err != com.sleepycat.db.OperationStatus.SUCCESS) - { - throw new DatabaseException(); - } - break; - } - case EvictorElement.destroyed: - { - com.sleepycat.db.DatabaseEntry dbKey = new com.sleepycat.db.DatabaseEntry(key); - com.sleepycat.db.OperationStatus err = _db.delete(tx, dbKey); - if(err != com.sleepycat.db.OperationStatus.SUCCESS) - { - throw new DatabaseException(); - } - break; - } - default: - { - assert false; - } - } + switch(status) + { + case EvictorElement.created: + case EvictorElement.modified: + { + com.sleepycat.db.DatabaseEntry dbKey = new com.sleepycat.db.DatabaseEntry(key); + com.sleepycat.db.DatabaseEntry dbValue = new com.sleepycat.db.DatabaseEntry(value); + com.sleepycat.db.OperationStatus err; + if(status == EvictorElement.created) + { + err = _db.putNoOverwrite(tx, dbKey, dbValue); + } + else + { + err = _db.put(tx, dbKey, dbValue); + } + if(err != com.sleepycat.db.OperationStatus.SUCCESS) + { + throw new DatabaseException(); + } + break; + } + case EvictorElement.destroyed: + { + com.sleepycat.db.DatabaseEntry dbKey = new com.sleepycat.db.DatabaseEntry(key); + com.sleepycat.db.OperationStatus err = _db.delete(tx, dbKey); + if(err != com.sleepycat.db.OperationStatus.SUCCESS) + { + throw new DatabaseException(); + } + break; + } + default: + { + assert false; + } + } } static byte[] marshalKey(Ice.Identity v, Ice.Communicator communicator) { IceInternal.BasicStream os = new IceInternal.BasicStream(Ice.Util.getInstance(communicator)); - v.__write(os); - java.nio.ByteBuffer buf = os.prepareWrite(); - byte[] r = new byte[buf.limit()]; - buf.get(r); - return r; + v.__write(os); + java.nio.ByteBuffer buf = os.prepareWrite(); + byte[] r = new byte[buf.limit()]; + buf.get(r); + return r; } static Ice.Identity unmarshalKey(byte[] b, Ice.Communicator communicator) { IceInternal.BasicStream is = new IceInternal.BasicStream(Ice.Util.getInstance(communicator)); - is.resize(b.length, true); - java.nio.ByteBuffer buf = is.prepareRead(); - buf.position(0); - buf.put(b); - buf.position(0); - Ice.Identity key = new Ice.Identity(); - key.__read(is); - return key; + is.resize(b.length, true); + java.nio.ByteBuffer buf = is.prepareRead(); + buf.position(0); + buf.put(b); + buf.position(0); + Ice.Identity key = new Ice.Identity(); + key.__read(is); + return key; } static byte[] marshalValue(ObjectRecord v, Ice.Communicator communicator) { IceInternal.BasicStream os = new IceInternal.BasicStream(Ice.Util.getInstance(communicator)); - os.startWriteEncaps(); - v.__write(os); - os.writePendingObjects(); - os.endWriteEncaps(); - java.nio.ByteBuffer buf = os.prepareWrite(); - byte[] r = new byte[buf.limit()]; - buf.get(r); - return r; + os.startWriteEncaps(); + v.__write(os); + os.writePendingObjects(); + os.endWriteEncaps(); + java.nio.ByteBuffer buf = os.prepareWrite(); + byte[] r = new byte[buf.limit()]; + buf.get(r); + return r; } static ObjectRecord @@ -286,109 +286,109 @@ class ObjectStore implements IceUtil.Store { IceInternal.BasicStream is = new IceInternal.BasicStream(Ice.Util.getInstance(communicator)); is.sliceObjects(false); - is.resize(b.length, true); - java.nio.ByteBuffer buf = is.prepareRead(); - buf.position(0); - buf.put(b); - buf.position(0); - ObjectRecord rec= new ObjectRecord(); - is.startReadEncaps(); - rec.__read(is); - is.readPendingObjects(); - is.endReadEncaps(); - return rec; + is.resize(b.length, true); + java.nio.ByteBuffer buf = is.prepareRead(); + buf.position(0); + buf.put(b); + buf.position(0); + ObjectRecord rec= new ObjectRecord(); + is.startReadEncaps(); + rec.__read(is); + is.readPendingObjects(); + is.endReadEncaps(); + return rec; } final IceUtil.Cache cache() { - return _cache; + return _cache; } final com.sleepycat.db.Database db() { - return _db; + return _db; } final Ice.Communicator communicator() { - return _communicator; + return _communicator; } final EvictorI evictor() { - return _evictor; + return _evictor; } final String facet() { - return _facet; + return _facet; } final String dbName() { - return _dbName; + return _dbName; } public Object load(Object identObj) { - Ice.Identity ident = (Ice.Identity) identObj; + Ice.Identity ident = (Ice.Identity) identObj; - byte[] key = marshalKey(ident, _communicator); + byte[] key = marshalKey(ident, _communicator); - com.sleepycat.db.DatabaseEntry dbKey = new com.sleepycat.db.DatabaseEntry(key); - com.sleepycat.db.DatabaseEntry dbValue = new com.sleepycat.db.DatabaseEntry(); + com.sleepycat.db.DatabaseEntry dbKey = new com.sleepycat.db.DatabaseEntry(key); + com.sleepycat.db.DatabaseEntry dbValue = new com.sleepycat.db.DatabaseEntry(); - for(;;) - { - try - { - com.sleepycat.db.OperationStatus rs = _db.get(null, dbKey, dbValue, null); - - if(rs == com.sleepycat.db.OperationStatus.NOTFOUND) - { - return null; - } - else if (rs != com.sleepycat.db.OperationStatus.SUCCESS) - { - assert false; - throw new DatabaseException(); - } - break; - } - catch(com.sleepycat.db.DeadlockException dx) - { - if(_evictor.deadlockWarning()) - { - _communicator.getLogger().warning("Deadlock in Freeze.ObjectStore.load while reading Db \"" + - _evictor.filename() + "/" + _dbName + "\"; retrying..."); - } + for(;;) + { + try + { + com.sleepycat.db.OperationStatus rs = _db.get(null, dbKey, dbValue, null); + + if(rs == com.sleepycat.db.OperationStatus.NOTFOUND) + { + return null; + } + else if (rs != com.sleepycat.db.OperationStatus.SUCCESS) + { + assert false; + throw new DatabaseException(); + } + break; + } + catch(com.sleepycat.db.DeadlockException dx) + { + if(_evictor.deadlockWarning()) + { + _communicator.getLogger().warning("Deadlock in Freeze.ObjectStore.load while reading Db \"" + + _evictor.filename() + "/" + _dbName + "\"; retrying..."); + } - // - // Ignored, try again - // - } - catch(com.sleepycat.db.DatabaseException dx) - { - DatabaseException ex = new DatabaseException(); - ex.initCause(dx); - ex.message = _evictor.errorPrefix() + "Db.get: " + dx.getMessage(); - throw ex; - } - } - - EvictorElement result = new EvictorElement(ident, this); - result.rec = unmarshalValue(dbValue.getData(), _communicator); - - _evictor.initialize(ident, _facet, result.rec.servant); - return result; + // + // Ignored, try again + // + } + catch(com.sleepycat.db.DatabaseException dx) + { + DatabaseException ex = new DatabaseException(); + ex.initCause(dx); + ex.message = _evictor.errorPrefix() + "Db.get: " + dx.getMessage(); + throw ex; + } + } + + EvictorElement result = new EvictorElement(ident, this); + result.rec = unmarshalValue(dbValue.getData(), _communicator); + + _evictor.initialize(ident, _facet, result.rec.servant); + return result; } private final IceUtil.Cache _cache; |