Package org.xtreemfs.babudb.api.exception

Examples of org.xtreemfs.babudb.api.exception.BabuDBException


                diskLogger.get().append(entry);
            }
        } catch (InterruptedException ie) {
           
            if (entry != null) entry.free();
            throw new BabuDBException(ErrorCode.INTERRUPTED, "Operation " +
                        "could not have been stored persistent to disk and " +
                        "will therefore be discarded.", ie.getCause());
        }
    }
View Full Code Here


                        payload.shrink(txn.getSize());
                        break;
                    } catch (IOException ioe) {
                       
                        BufferPool.free(payload);
                        throw new BabuDBException(ErrorCode.IO_ERROR, ioe.getMessage(), ioe);
                    }
                } else {
                   
                    // no operation could have been executed so far
                    BufferPool.free(payload);
View Full Code Here

        int[] babu = new int[] { Integer.parseInt(b[0]), Integer.parseInt(b[1]),
                                 Integer.parseInt(b[2])};
       
        for (int i = 0; i < 3; i++) {
            if (babu[i] > to[i] || babu[i] < from[i]) {
                throw new BabuDBException(ErrorCode.BROKEN_PLUGIN, "This " +
                    "BabuDB ("+BabuDBFactory.BABUDB_VERSION+") " +
                          "is not compatible with this plugin (" +
                          getClass().getName() + "), which requires " +
                          "BabuDB to meet " + compatibleBabuDBVersion());
            }
View Full Code Here

                    BufferPool.allocate(transaction.getSize()));
            buffer.flip();
            makePersistent(transaction, buffer, requestFuture);
        } catch (IOException e) {
            if (buffer != null) BufferPool.free(buffer);
            throw new BabuDBException (ErrorCode.IO_ERROR, e.getMessage(), e);
        }
    }
View Full Code Here

            TransactionInternal txn = deserialize(serialized);
            serialized.flip();
            makePersistent(txn, serialized, requestFuture);
        } catch (IOException e) {
            if (serialized != null) BufferPool.free(serialized);
            throw new BabuDBException(ErrorCode.IO_ERROR, e.getMessage(), e);
        }
    }
View Full Code Here

TOP

Related Classes of org.xtreemfs.babudb.api.exception.BabuDBException

Copyright © 2018 www.massapicom. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.