Class CheckpointTimeoutLock


  • public class CheckpointTimeoutLock
    extends Object
    Checkpoint lock for outer usage which should be used to protect data during writing to memory. It contains complex logic for the correct taking of inside checkpoint lock(timeout, force checkpoint, etc.).
    • Method Detail

      • checkpointReadLock

        public void checkpointReadLock()
        Gets the checkpoint read lock. While this lock is held, checkpoint thread will not acquireSnapshotWorker memory state.
        Throws:
        IgniteException - If failed.
      • checkpointReadUnlock

        public void checkpointReadUnlock()
        Releases the checkpoint read lock.
      • checkpointReadLockTimeout

        public long checkpointReadLockTimeout()
        Timeout for checkpoint read lock acquisition.
        Returns:
        Timeout for checkpoint read lock acquisition in milliseconds.
      • checkpointReadLockTimeout

        public void checkpointReadLockTimeout​(long val)
        Sets timeout for checkpoint read lock acquisition.
        Parameters:
        val - New timeout in milliseconds, non-positive value denotes infinite timeout.
      • checkpointLockIsHeldByThread

        public boolean checkpointLockIsHeldByThread()
        Returns:
        true if checkpoint lock is held by current thread
      • stop

        public void stop()
        Forbid to take this lock.
      • start

        public void start()
        Prepare the lock to further usage.