Uses of Class
org.apache.ignite.internal.IgniteInterruptedCheckedException

Packages that use IgniteInterruptedCheckedException

Package	Description
org.apache.ignite.internal.pagemem.wal
org.apache.ignite.internal.processors.cache	This package contain cache-related processors & persistence implementation.
org.apache.ignite.internal.processors.cache.distributed.dht.preloader
org.apache.ignite.internal.processors.cache.distributed.dht.topology
org.apache.ignite.internal.processors.cache.persistence.wal
org.apache.ignite.internal.processors.cache.persistence.wal.aware
org.apache.ignite.internal.processors.query.schema
org.apache.ignite.internal.util	System-wide utility routine and helper classes.
org.apache.ignite.internal.util.worker	Common utility classes for threads.

Uses of IgniteInterruptedCheckedException in org.apache.ignite.internal.pagemem.wal

Methods in org.apache.ignite.internal.pagemem.wal that throw IgniteInterruptedCheckedException

Modifier and Type	Method	Description
void	IgniteWriteAheadLogManager.awaitCompacted(long idx)	Blocks current thread while segment with the idx not compressed.

Uses of IgniteInterruptedCheckedException in org.apache.ignite.internal.processors.cache

Methods in org.apache.ignite.internal.processors.cache that throw IgniteInterruptedCheckedException

Modifier and Type	Method	Description
boolean	GridCachePartitionExchangeManager.mergeExchanges(GridDhtPartitionsExchangeFuture curFut, GridDhtPartitionsFullMessage msg)

Uses of IgniteInterruptedCheckedException in org.apache.ignite.internal.processors.cache.distributed.dht.preloader

Methods in org.apache.ignite.internal.processors.cache.distributed.dht.preloader that throw IgniteInterruptedCheckedException

Modifier and Type	Method	Description
void	GridDhtPartitionsExchangeFuture.init(boolean newCrd)	Starts activity.

Uses of IgniteInterruptedCheckedException in org.apache.ignite.internal.processors.cache.distributed.dht.topology

Methods in org.apache.ignite.internal.processors.cache.distributed.dht.topology that throw IgniteInterruptedCheckedException

Modifier and Type	Method	Description
boolean	GridDhtPartitionTopology.initPartitionsWhenAffinityReady(AffinityTopologyVersion affVer, GridDhtPartitionsExchangeFuture exchFut)
boolean	GridDhtPartitionTopologyImpl.initPartitionsWhenAffinityReady(AffinityTopologyVersion affVer, GridDhtPartitionsExchangeFuture exchFut)
void	GridClientPartitionTopology.updateTopologyVersion(GridDhtTopologyFuture exchFut, DiscoCache discoCache, long updSeq, boolean stopping)	Updates topology version.
void	GridDhtPartitionTopology.updateTopologyVersion(GridDhtTopologyFuture exchFut, DiscoCache discoCache, long updateSeq, boolean stopping)	Updates topology version.
void	GridDhtPartitionTopologyImpl.updateTopologyVersion(GridDhtTopologyFuture exchFut, @NotNull DiscoCache discoCache, long updSeq, boolean stopping)	Updates topology version.

Uses of IgniteInterruptedCheckedException in org.apache.ignite.internal.processors.cache.persistence.wal

Methods in org.apache.ignite.internal.processors.cache.persistence.wal that throw IgniteInterruptedCheckedException

Modifier and Type	Method	Description
void	FileWriteAheadLogManager.awaitCompacted(long idx)	Blocks current thread while segment with the idx not compressed.

Uses of IgniteInterruptedCheckedException in org.apache.ignite.internal.processors.cache.persistence.wal.aware

Methods in org.apache.ignite.internal.processors.cache.persistence.wal.aware that throw IgniteInterruptedCheckedException

Modifier and Type	Method	Description
long	SegmentAware.awaitAvailableTruncateArchive()	Waiting for segment truncation to be available.
void	SegmentAware.awaitExceedMaxArchiveSize(long max)	Waiting for exceeding the maximum WAL archive size.
void	SegmentAware.awaitSegment(long absSegIdx)	Waiting until current WAL index will be greater or equal than given one.
void	SegmentAware.awaitSegmentArchived(long awaitIdx)	Method will wait archivation of particular WAL segment index.
void	SegmentAware.awaitSegmentCompressed(long awaitIdx)	Method will wait activation of particular WAL segment index.
void	SegmentAware.markAsMovedToArchive(long toArchive)	Mark segment as moved to archive under lock.
long	SegmentAware.nextAbsoluteSegmentIndex()	Calculate next segment index or wait if needed.
long	SegmentAware.waitNextSegmentForArchivation()	Waiting until archivation of next segment will be allowed.
long	SegmentAware.waitNextSegmentToCompress()	Pessimistically tries to reserve segment for compression in order to avoid concurrent truncation.

Uses of IgniteInterruptedCheckedException in org.apache.ignite.internal.processors.query.schema

Methods in org.apache.ignite.internal.processors.query.schema that throw IgniteInterruptedCheckedException

Modifier and Type	Method	Description
protected void	SchemaIndexCachePartitionWorker.body()	The implementation should provide the execution body for this runnable.
protected void	SchemaOperationWorker.body()	The implementation should provide the execution body for this runnable.

Uses of IgniteInterruptedCheckedException in org.apache.ignite.internal.util

Methods in org.apache.ignite.internal.util that throw IgniteInterruptedCheckedException

Modifier and Type	Method	Description
void	BasicRateLimiter.acquire(long permits)	Acquires the given number of permits from this RateLimiter, blocking until the request can be granted.
static void	IgniteUtils.acquire(Semaphore sem)	Acquires a permit from provided semaphore.
boolean	GridAtomicInitializer.await()	Await for completion.
static void	IgniteUtils.await(CountDownLatch latch)	Awaits for the latch.
static boolean	IgniteUtils.await(CountDownLatch latch, long timeout, TimeUnit unit)	Awaits for the latch.
static void	IgniteUtils.await(Condition cond)	Awaits for condition.
static boolean	IgniteUtils.await(Condition cond, long time, TimeUnit unit)	Awaits for condition.
static <T,R> Collection<R>	IgniteUtils.doInParallel(int parallelismLvl, ExecutorService executorSvc, Collection<T> srcDatas, IgniteThrowableFunction<T,R> operation)	Execute operation on data in parallel.
static <T,R> Collection<R>	IgniteUtils.doInParallel(ExecutorService executorSvc, Collection<T> srcDatas, IgniteThrowableFunction<T,R> operation)	Execute operation on data in parallel.
static <T,R> Collection<R>	IgniteUtils.doInParallelUninterruptibly(int parallelismLvl, ExecutorService executorSvc, Collection<T> srcDatas, IgniteThrowableFunction<T,R> operation)	Execute operation on data in parallel uninterruptibly.
static void	IgniteUtils.join(@Nullable Thread t)	Joins thread.
static void	IgniteUtils.join(GridWorker w)	Joins worker.
static void	IgniteUtils.sleep(long ms)	Sleeps for given number of milliseconds.
static boolean	IgniteUtils.tryAcquire(Semaphore sem, long timeout, TimeUnit unit)	Tries to acquire a permit from provided semaphore during timeout.
static void	IgniteUtils.wait(Object mux)	Converts InterruptedException to IgniteCheckedException.
static void	IgniteUtils.writeLock(ReadWriteLock lock)

Uses of IgniteInterruptedCheckedException in org.apache.ignite.internal.util.worker

Methods in org.apache.ignite.internal.util.worker that throw IgniteInterruptedCheckedException

Modifier and Type	Method	Description
protected abstract void	GridWorker.body()	The implementation should provide the execution body for this runnable.