Examples of com.persistit.exception.PersistitInterruptedException

com.persistit.exception.PersistitInterruptedException
This is a wrapper for an {@link InterruptedException}. If a Persistit thread is interrupted when sleeping or waiting, it throws an instance of this Exception. This allows the caller of a Persistit method to catch {@link PersistitException}s without also needing to catch InterruptedExceptions.
Before throwing a PersistitInterruptedException Persistit reasserts the interrupted status of the current Thread so that a subsequent call to sleep or wait will once again be interrupted. @version 1.0

            flushTransactionBuffer(false);
            try {
                _transactionStatus = _persistit.getTransactionIndex().registerTransaction();
            } catch (final InterruptedException e) {
                _rollbackCompleted = true;
                throw new PersistitInterruptedException(e);
            }
            _rollbackPending = false;
            _rollbackCompleted = false;
            _startTimestamp = _transactionStatus.getTs();
            _commitTimestamp = 0;

View Full Code Here

            flushTransactionBuffer(false);
            try {
                _transactionStatus = _persistit.getTransactionIndex().registerCheckpointTransaction();
            } catch (final InterruptedException e) {
                _rollbackCompleted = true;
                throw new PersistitInterruptedException(e);
            }
            _rollbackPending = false;
            _rollbackCompleted = false;
            _startTimestamp = _transactionStatus.getTs();
            _commitTimestamp = 0;

View Full Code Here

                    if (_sync.tryAcquireSharedNanos(1, timeout * 1000000)) {
                        return true;
                    }
                }
            } catch (final InterruptedException e) {
                throw new PersistitInterruptedException(e);
            }
            return false;
        }
    }

View Full Code Here

                _currentCheckpoint = new Checkpoint(txn.getStartTimestamp(), System.currentTimeMillis());
                _outstandingCheckpoints.add(_currentCheckpoint);
                _persistit.getLogBase().checkpointProposed.log(_currentCheckpoint);
                return _currentCheckpoint;
            } catch (InterruptedException ie) {
                throw new PersistitInterruptedException(ie);
            } finally {
                txn.end();
            }
        } finally {
            _persistit.setSessionId(saveSessionId);

View Full Code Here

                } else if (item.getStartTimestamp() < _lastValidCheckpoint.getTimestamp()) {
                    _uncommittedTransactionCount++;
                    try {
                        _persistit.getTransactionIndex().injectAbortedTransaction(item.getStartTimestamp());
                    } catch (InterruptedException ie) {
                        throw new PersistitInterruptedException(ie);
                    }
                } else {
                    /*
                     * An uncommitted transaction that started after the last
                     * valid checkpoint is of no interest.

View Full Code Here

     */
    long getSnapshotValue(final long timestamp, final int step) throws PersistitInterruptedException {
        try {
            return _transactionIndex.getAccumulatorSnapshot(this, timestamp, step, _baseValue);
        } catch (InterruptedException ie) {
            throw new PersistitInterruptedException(ie);
        }
    }

View Full Code Here

                            // way, must abort.
                            _transaction.rollback();
                            throw new RollbackException();
                        }
                    } catch (InterruptedException ie) {
                        throw new PersistitInterruptedException(ie);
                    }
                } catch (RetryException re) {
                    if (buffer != null) {
                        buffer.releaseTouched();
                        buffer = null;

View Full Code Here

                    try {
                        if (delay > 0 && _lock.readLock().tryLock(delay, TimeUnit.NANOSECONDS)) {
                            _lock.readLock().unlock();
                        }
                    } catch (InterruptedException e) {
                        throw new PersistitInterruptedException(e);
                    }
                }
            }
            if (_lastExceptionTimestamp > timestamp) {
                final Exception e = _lastException;

View Full Code Here

                // Wait for UI to go down.
                while (_suspendShutdown.get()) {
                    try {
                        wait(SHORT_DELAY);
                    } catch (InterruptedException ie) {
                        throw new PersistitInterruptedException(ie);
                    }
                }
            }


            /*

View Full Code Here

        if (isClosed()) {
            checkFatal();
            throw new PersistitClosedException();
        }
        if (Thread.currentThread().isInterrupted()) {
            throw new PersistitInterruptedException(new InterruptedException());
        }
    }

View Full Code Here

0 1 2 3 4 5 6

TOP

Related Classes of com.persistit.exception.PersistitInterruptedException

com.persistit.Accumulator

com.persistit.CheckpointManager

com.persistit.Exchange

com.persistit.Exchange$MvvVisitor

com.persistit.JournalManager$JournalFlusher

com.persistit.MVV

com.persistit.Persistit

com.persistit.RecoveryManager

com.persistit.SharedResource

com.persistit.TimelyResource

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.