org.apache.ignite.internal.processors.cache.distributed.dht.preloader.latch

Class ExchangeLatchManager

java.lang.Object

org.apache.ignite.internal.processors.cache.distributed.dht.preloader.latch.ExchangeLatchManager

public class ExchangeLatchManager
extends Object

Class is responsible to create and manage instances of distributed latches Latch.

Constructor Summary

Constructors

Constructor and Description
ExchangeLatchManager(GridKernalContext ctx) Constructor.

Method Summary

Modifier and Type	Method and Description
Latch	getOrCreate(String id, AffinityTopologyVersion topVer) Creates new latch with specified id and topVer or returns existing latch.
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

ExchangeLatchManager

public ExchangeLatchManager(GridKernalContext ctx)

Constructor.

Parameters:

ctx - Kernal context.

Method Detail

getOrCreate

public Latch getOrCreate(String id,
                         AffinityTopologyVersion topVer)

Creates new latch with specified id and topVer or returns existing latch. Participants of latch are calculated from given topVer as alive server nodes. If local node is coordinator ServerLatch instance will be created, otherwise ClientLatch instance.

Parameters:

id - Latch id.

topVer - Latch topology version.

Returns:

Latch instance.

toString

public String toString()

Overrides:

toString in class Object