org.apache.ignite.internal.processors.cache

Class ExchangeContext

java.lang.Object

org.apache.ignite.internal.processors.cache.ExchangeContext

public class ExchangeContext
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static String	IGNITE_EXCHANGE_COMPATIBILITY_VER_1 Enables exchange compatibility with protocol version 1.

Constructor Summary

Constructors

Constructor and Description
ExchangeContext(GridCacheSharedContext<?,?> cctx, boolean crd, GridDhtPartitionsExchangeFuture fut)

Method Summary

Modifier and Type	Method and Description
ExchangeDiscoveryEvents	events()
boolean	exchangeFreeSwitch()
boolean	fetchAffinityOnJoin()
@Nullable Set<Integer>	groupsAffinityRequestOnJoin()
boolean	mergeExchanges()
boolean	remapStaleCacheRequests()
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

IGNITE_EXCHANGE_COMPATIBILITY_VER_1

@SystemProperty(value="Enables the compatibility mode for the exchange protocol of version 1")
public static final String IGNITE_EXCHANGE_COMPATIBILITY_VER_1

Enables exchange compatibility with protocol version 1.

See Also:

Constant Field Values

Constructor Detail

ExchangeContext

public ExchangeContext(GridCacheSharedContext<?,?> cctx,
                       boolean crd,
                       GridDhtPartitionsExchangeFuture fut)

Parameters:

cctx - Context.

crd - Coordinator flag.

fut - Exchange future.

Method Detail

events

public ExchangeDiscoveryEvents events()

Returns:

Discovery events.

fetchAffinityOnJoin

public boolean fetchAffinityOnJoin()

Returns:

True if on local join need fetch affinity per-group (old protocol), otherwise affinity is sent in GridDhtPartitionsFullMessage.

exchangeFreeSwitch

public boolean exchangeFreeSwitch()

Returns:

True if it's safe to perform PME-free switch.

groupsAffinityRequestOnJoin

@Nullable
public @Nullable Set<Integer> groupsAffinityRequestOnJoin()

Returns:

Groups to request affinity for.

mergeExchanges

public boolean mergeExchanges()

Returns:

True if exchanges merge is allowed during current exchange.

remapStaleCacheRequests

public boolean remapStaleCacheRequests()

Returns:

Whether cache requests that were mapped to an outdated topology version should be forcibly remapped to the up-to-date one.

toString

public String toString()

Overrides:

toString in class Object