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

                        _foundVersion = version;
                    }
                    break;
                }
            } catch (InterruptedException ie) {
                throw new PersistitInterruptedException(ie);
            }
        }

View Full Code Here


    public static void sleep(final long millis) throws PersistitInterruptedException {
        try {
            Thread.sleep(millis);
        } catch (InterruptedException ie) {
            throw new PersistitInterruptedException(ie);
        }
    }

View Full Code Here

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

View Full Code Here

            flushTransactionBuffer(false);
            try {
                _transactionStatus = _persistit.getTransactionIndex().registerTransaction();
            } catch (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 (InterruptedException e) {
              _rollbackCompleted = true;
                throw new PersistitInterruptedException(e);
            }
            _rollbackPending = false;
            _rollbackCompleted = false;
            _startTimestamp = _transactionStatus.getTs();
            _commitTimestamp = 0;

View Full Code Here

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

View Full Code Here

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

View Full Code Here

                        _foundVersion = version;
                    }
                    break;
                }
            } catch (final InterruptedException ie) {
                throw new PersistitInterruptedException(ie);
            }
        }

View Full Code Here

                }
                Debug.$assert0.t(verify(bytes, offset, to - offset));
                return to - offset;
            }
        } catch (final InterruptedException ie) {
            throw new PersistitInterruptedException(ie);
        } finally {
            /*
             * Make sure all marks are removed even if this method exits via an
             * Exception.
             */

View Full Code Here

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

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.