org.apache.ignite.internal.processors.cache.persistence.checkpoint

Class PartitionDestroyQueue

java.lang.Object

org.apache.ignite.internal.processors.cache.persistence.checkpoint.PartitionDestroyQueue

public class PartitionDestroyQueue
extends Object

Partition destroy queue.

Constructor Summary

Constructors

Constructor and Description
PartitionDestroyQueue()

Method Summary

Modifier and Type	Method and Description
void	addDestroyRequest(@Nullable CacheGroupContext grpCtx, int grpId, int partId)
PartitionDestroyRequest	cancelDestroy(int grpId, int partId)
ConcurrentMap<T2<Integer,Integer>,PartitionDestroyRequest>	pendingReqs()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PartitionDestroyQueue

public PartitionDestroyQueue()

Method Detail

addDestroyRequest

public void addDestroyRequest(@Nullable
                              @Nullable CacheGroupContext grpCtx,
                              int grpId,
                              int partId)

Parameters:

grpCtx - Group context.

partId - Partition ID to destroy.

cancelDestroy

public PartitionDestroyRequest cancelDestroy(int grpId,
                                             int partId)

Parameters:

grpId - Group ID.

partId - Partition ID.

Returns:

Destroy request to wait for if destroy has begun.

pendingReqs

public ConcurrentMap<T2<Integer,Integer>,PartitionDestroyRequest> pendingReqs()

Returns:

Pending reqs.