| Constructor and Description |
|---|
GridAffinityAssignmentCache(GridCacheContext ctx,
String cacheName,
GridCacheAffinityFunction aff,
GridCacheAffinityKeyMapper affMapper,
int backups)
Constructs affinity cached calculations.
|
| Modifier and Type | Field and Description |
|---|---|
protected GridCacheContext<K,V> |
GridCacheMapEntry.cctx
Cache registry.
|
protected GridCacheContext<K,V> |
GridCacheTxAdapter.cctx
Cache registry.
|
protected GridCacheContext<K,V> |
GridCacheManagerAdapter.cctx
Context.
|
protected GridCacheContext<K,V> |
GridCachePreloaderAdapter.cctx
Cache context.
|
protected GridCacheContext<K,V> |
GridCacheConcurrentMap.ctx
Cache context.
|
protected GridCacheContext<K,V> |
GridCacheClearAllRunnable.ctx
Cache context.
|
protected GridCacheContext<K,V> |
GridCacheEntryImpl.ctx
Cache context.
|
protected GridCacheContext<K,V> |
GridCacheAdapter.ctx
Cache configuration.
|
| Modifier and Type | Method and Description |
|---|---|
GridCacheContext<K,V> |
GridCacheMapEntry.context() |
GridCacheContext<K,V> |
GridCacheAdapter.context() |
GridCacheContext<K,V> |
GridCacheEntryEx.context() |
protected GridCacheContext<K,V> |
GridCacheManagerAdapter.context() |
| Modifier and Type | Method and Description |
|---|---|
static boolean |
GridCacheUtils.affinityNode(GridCacheContext ctx,
GridNode s)
Checks if given node has specified cache started and the local DHT storage is enabled.
|
static Collection<GridNode> |
GridCacheUtils.affinityNodes(GridCacheContext ctx)
Gets all nodes on which cache with the same name is started and the local DHT storage is enabled.
|
static Collection<GridNode> |
GridCacheUtils.affinityNodes(GridCacheContext ctx,
long topOrder)
Gets DHT affinity nodes.
|
static Collection<GridNode> |
GridCacheUtils.aliveNodes(GridCacheContext ctx,
long topOrder)
Gets alive nodes.
|
static Collection<GridNode> |
GridCacheUtils.aliveRemoteNodes(GridCacheContext ctx,
long topOrder)
Gets alive nodes.
|
static Collection<GridNode> |
GridCacheUtils.allNodes(GridCacheContext ctx)
Gets all nodes on which cache with the same name is started.
|
static Collection<GridNode> |
GridCacheUtils.allNodes(GridCacheContext ctx,
long topOrder)
Gets all nodes on which cache with the same name is started.
|
static <K,V> GridClosure<K,GridCacheEntry<K,V>> |
GridCacheUtils.cacheKey2Entry(GridCacheContext<K,V> ctx)
Gets closure which returns
GridCacheEntry given cache key. |
static boolean |
GridCacheUtils.cacheNode(GridCacheContext ctx,
GridNode node)
Checks if given node contains configured cache with the name
as described by given cache context.
|
static boolean |
GridCacheUtils.cacheNode(GridCacheContext ctx,
GridNodeShadow s)
Checks if given node has specified cache started.
|
static void |
GridCacheUtils.checkStore(GridCacheContext<?,?> ctx)
Checks that cache store is present.
|
GridCacheTxEntry<K,V> |
GridCacheTxEntry.cleanCopy(GridCacheContext<K,V> ctx) |
GridCacheMapEntry<K,V> |
GridCacheMapEntryFactory.create(GridCacheContext<K,V> ctx,
long topVer,
K key,
int hash,
V val,
GridCacheMapEntry<K,V> next,
long ttl,
int hdrId) |
void |
GridCacheMessage.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheContext) method. |
void |
GridCacheDgcResponse.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheContext) method. |
void |
GridCacheDgcRequest.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheContext) method. |
void |
GridCacheEvictionRequest.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheContext) method. |
void |
GridCacheEvictionResponse.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheContext) method. |
static boolean |
GridCacheUtils.isNearEnabled(GridCacheContext ctx)
Checks if near cache is enabled for cache context.
|
static <K,V> GridPredicate<K> |
GridCacheUtils.keyHasMeta(GridCacheContext<K,V> ctx,
String meta) |
static <K> Map<GridNode,Collection<K>> |
GridCacheUtils.mapKeysToNodes(GridCacheContext<K,?> ctx,
Collection<? extends K> keys) |
void |
GridCacheTxEntry.marshal(GridCacheContext<K,V> ctx) |
void |
GridCacheEntryInfo.marshal(GridCacheContext<K,V> ctx) |
static byte[] |
GridCacheUtils.marshal(GridCacheContext ctx,
Object obj) |
protected LinkedHashMap<byte[],Boolean> |
GridCacheMessage.marshalBooleanLinkedMap(LinkedHashMap<?,Boolean> map,
GridCacheContext<K,V> ctx) |
protected List<byte[]> |
GridCacheMessage.marshalCollection(Collection<?> col,
GridCacheContext<K,V> ctx) |
protected <T> byte[][] |
GridCacheMessage.marshalFilter(GridPredicate<GridCacheEntry<K,V>>[] filter,
GridCacheContext<K,V> ctx) |
protected void |
GridCacheMessage.marshalInfo(GridCacheEntryInfo<K,V> info,
GridCacheContext<K,V> ctx) |
protected void |
GridCacheMessage.marshalInfos(Iterable<? extends GridCacheEntryInfo<K,V>> infos,
GridCacheContext<K,V> ctx) |
protected void |
GridCacheMessage.marshalTx(Iterable<GridCacheTxEntry<K,V>> txEntries,
GridCacheContext<K,V> ctx) |
protected List<GridCacheValueBytes> |
GridCacheMessage.marshalValuesCollection(Collection<?> col,
GridCacheContext<K,V> ctx) |
static GridNode |
GridCacheUtils.oldest(GridCacheContext cctx)
Gets oldest alive node for specified topology version.
|
static GridNode |
GridCacheUtils.oldest(GridCacheContext cctx,
long topOrder)
Gets oldest alive node for specified topology version.
|
static <T> T |
GridCacheUtils.outTx(Callable<T> cmd,
GridCacheContext ctx)
Method executes any Callable out of scope of transaction.
|
protected void |
GridCacheMessage.prepareFilter(GridPredicate<GridCacheEntry<K,V>>[] filters,
GridCacheContext<K,V> ctx) |
void |
GridCacheMessage.prepareMarshal(GridCacheContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridCacheDgcResponse.prepareMarshal(GridCacheContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridCacheDgcRequest.prepareMarshal(GridCacheContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridCacheEvictionRequest.prepareMarshal(GridCacheContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridCacheEvictionResponse.prepareMarshal(GridCacheContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
protected void |
GridCacheMessage.prepareObject(Object o,
GridCacheContext<K,V> ctx) |
protected void |
GridCacheMessage.prepareObjects(Iterable<?> col,
GridCacheContext<K,V> ctx) |
static GridNode |
GridCacheUtils.primaryNode(GridCacheContext ctx,
Object key)
Gets primary node on which given key is cached.
|
static Collection<GridNode> |
GridCacheUtils.remoteNodes(GridCacheContext ctx)
Gets remote nodes on which cache with the same name is started.
|
static Collection<GridNode> |
GridCacheUtils.remoteNodes(GridCacheContext ctx,
long topOrder)
Gets remote nodes on which cache with the same name is started.
|
static void |
GridCacheUtils.resetTxContext(GridCacheContext ctx) |
void |
GridCacheManager.start(GridCacheContext<K,V> cctx)
Starts manager.
|
void |
GridCacheManagerAdapter.start(GridCacheContext<K,V> cctx)
Starts manager.
|
static <K,V> UUID |
GridCacheUtils.subjectId(GridCacheTxEx<K,V> tx,
GridCacheContext<K,V> ctx)
Gets subject ID by transaction.
|
static String |
GridCacheUtils.swapSpaceName(GridCacheContext<?,?> ctx) |
static GridCacheTx |
GridCacheUtils.txStartInternal(GridCacheContext ctx,
GridCacheProjection prj,
GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation) |
void |
GridCacheTxEntry.unmarshal(GridCacheContext<K,V> ctx,
ClassLoader clsLdr)
Unmarshalls entry.
|
void |
GridCacheEntryInfo.unmarshal(GridCacheContext<K,V> ctx,
ClassLoader clsLdr)
Unmarshalls entry.
|
protected <K1> LinkedHashMap<K1,Boolean> |
GridCacheMessage.unmarshalBooleanLinkedMap(Map<byte[],Boolean> byteMap,
GridCacheContext<K,V> ctx,
ClassLoader ldr) |
protected <T> List<T> |
GridCacheMessage.unmarshalCollection(Collection<byte[]> byteCol,
GridCacheContext<K,V> ctx,
ClassLoader ldr) |
protected <T> GridPredicate<GridCacheEntry<K,V>>[] |
GridCacheMessage.unmarshalFilter(byte[][] byteCol,
GridCacheContext<K,V> ctx,
ClassLoader ldr) |
protected void |
GridCacheMessage.unmarshalInfo(GridCacheEntryInfo<K,V> info,
GridCacheContext<K,V> ctx,
ClassLoader ldr) |
protected void |
GridCacheMessage.unmarshalInfos(Iterable<? extends GridCacheEntryInfo<K,V>> infos,
GridCacheContext<K,V> ctx,
ClassLoader ldr) |
protected void |
GridCacheMessage.unmarshalTx(Iterable<GridCacheTxEntry<K,V>> txEntries,
GridCacheContext<K,V> ctx,
ClassLoader ldr) |
void |
GridCacheEntryInfo.unmarshalValue(GridCacheContext<K,V> ctx,
ClassLoader ldr) |
protected <T> List<T> |
GridCacheMessage.unmarshalValueBytesCollection(Collection<GridCacheValueBytes> byteCol,
GridCacheContext<K,V> ctx,
ClassLoader ldr) |
static void |
GridCacheUtils.unwindEvicts(GridCacheContext ctx) |
| Constructor and Description |
|---|
GridCacheAdapter(GridCacheContext<K,V> ctx,
GridCacheConcurrentMap<K,V> map) |
GridCacheAdapter(GridCacheContext<K,V> ctx,
int startSize) |
GridCacheConcurrentMap(GridCacheContext<K,V> ctx,
int initCap)
Creates a new, empty map with the specified initial capacity,
and with default load factor (0.75) and concurrencyLevel (16).
|
GridCacheConcurrentMap(GridCacheContext<K,V> ctx,
int initCap,
float loadFactor)
Creates a new, empty map with the specified initial capacity
and load factor and with the default concurrencyLevel (16).
|
GridCacheConcurrentMap(GridCacheContext<K,V> ctx,
int initCap,
float loadFactor,
int concurrencyLevel)
Creates a new, empty map with the specified initial
capacity, load factor and concurrency level.
|
GridCacheEntryImpl(GridCacheProjectionImpl<K,V> prj,
GridCacheContext<K,V> ctx,
K key,
GridCacheEntryEx<K,V> cached) |
GridCacheEntrySet(GridCacheContext<K,V> ctx,
Collection<? extends GridCacheEntry<K,V>> c,
GridPredicate<GridCacheEntry<K,V>>... filter) |
GridCacheGateway(GridCacheContext<K,V> ctx) |
GridCacheKeySet(GridCacheContext<K,V> ctx,
Collection<? extends GridCacheEntry<K,V>> c,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridCacheMapEntry(GridCacheContext<K,V> cctx,
K key,
int hash,
V val,
GridCacheMapEntry<K,V> next,
long ttl,
int hdrId) |
GridCacheMultiTxFuture(GridCacheContext<K,V> cctx) |
GridCacheMvcc(GridCacheContext<K,?> cctx) |
GridCachePreloaderAdapter(GridCacheContext<K,V> cctx) |
GridCacheProjectionImpl(GridCacheProjection<K,V> parent,
GridCacheContext<K,V> cctx,
GridBiPredicate<K,V> kvFilter,
GridPredicate<? super GridCacheEntry<K,V>> entryFilter,
Set<GridCacheFlag> flags,
UUID subjId) |
GridCacheProxyImpl(GridCacheContext<K,V> ctx,
GridCacheProjectionEx<K,V> delegate,
GridCacheProjectionImpl<K,V> prj) |
GridCacheTxAdapter(GridCacheContext<K,V> cctx,
GridCacheVersion xidVer,
boolean implicit,
boolean implicitSingle,
boolean loc,
GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
long timeout,
boolean invalidate,
boolean swapOrOffheapEnabled,
boolean storeEnabled,
int txSize,
Object grpLockKey,
UUID subjId) |
GridCacheTxAdapter(GridCacheContext<K,V> cctx,
UUID nodeId,
GridCacheVersion xidVer,
GridCacheVersion startVer,
long threadId,
GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
long timeout,
boolean invalidate,
boolean swapOrOffheapEnabled,
boolean storeEnabled,
int txSize,
Object grpLockKey,
UUID subjId) |
GridCacheTxEntry(GridCacheContext<K,V> ctx,
GridCacheTxEx<K,V> tx,
GridCacheOperation op,
V val,
GridClosure<V,V> transformClos,
long ttl,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>[] filters,
GridCacheVersion drVer)
This constructor is meant for local transactions.
|
GridCacheTxEntry(GridCacheContext<K,V> ctx,
GridCacheTxEx<K,V> tx,
GridCacheOperation op,
V val,
long ttl,
long drExpireTime,
GridCacheEntryEx<K,V> entry,
GridCacheVersion drVer)
This constructor is meant for remote transactions.
|
GridCacheTxLocalAdapter(GridCacheContext<K,V> cctx,
GridCacheVersion xidVer,
boolean implicit,
boolean implicitSingle,
GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
long timeout,
boolean invalidate,
boolean swapEnabled,
boolean storeEnabled,
int txSize,
Object grpLockKey,
boolean partLock,
UUID subjId) |
GridCacheValueCollection(GridCacheContext<K,V> ctx,
Collection<? extends GridCacheEntry<K,V>> c,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
| Constructor and Description |
|---|
GridCacheAffinityImpl(GridCacheContext<K,V> cctx) |
GridCacheAffinityProxy(GridCacheContext<K,V> cctx,
GridCacheAffinity<K> delegate) |
| Modifier and Type | Field and Description |
|---|---|
protected GridCacheContext<?,?> |
GridCacheQueueAdapter.cctx
Cache context.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridSetQueryPredicate.init(GridCacheContext ctx) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDistributedUnlockRequest.addKey(K key,
byte[] bytes,
GridCacheContext<K,V> ctx) |
void |
GridDistributedLockRequest.addKeyBytes(K key,
byte[] keyBytes,
GridCacheTxEntry<K,V> writeEntry,
boolean retVal,
Collection<GridCacheMvccCandidate<K>> cands,
GridCacheVersion drVer,
GridCacheContext<K,V> ctx)
Adds a key.
|
void |
GridDistributedLockResponse.addValueBytes(V val,
byte[] valBytes,
GridCacheContext<K,V> ctx) |
void |
GridDistributedTxPrepareResponse.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheContext) method. |
void |
GridDistributedTxPrepareRequest.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheContext) method. |
void |
GridDistributedTxFinishRequest.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheContext) method. |
void |
GridDistributedLockRequest.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheContext) method. |
void |
GridDistributedBaseMessage.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheContext) method. |
void |
GridDistributedUnlockRequest.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheContext) method. |
void |
GridDistributedLockResponse.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheContext) method. |
void |
GridCachePessimisticCheckCommittedTxResponse.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheContext) method. |
void |
GridDistributedTxPrepareResponse.prepareMarshal(GridCacheContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDistributedTxPrepareRequest.prepareMarshal(GridCacheContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDistributedTxFinishRequest.prepareMarshal(GridCacheContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDistributedLockRequest.prepareMarshal(GridCacheContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDistributedBaseMessage.prepareMarshal(GridCacheContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDistributedUnlockRequest.prepareMarshal(GridCacheContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDistributedLockResponse.prepareMarshal(GridCacheContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridCachePessimisticCheckCommittedTxResponse.prepareMarshal(GridCacheContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridDhtLockRequest.addDhtKey(K key,
byte[] keyBytes,
GridCacheTxEntry<K,V> writeEntry,
GridCacheVersion drVer,
boolean invalidateEntry,
GridCacheContext<K,V> ctx)
Adds a DHT key.
|
void |
GridDhtUnlockRequest.addNearKey(K key,
byte[] keyBytes,
GridCacheContext<K,V> ctx)
Adds a Near key.
|
void |
GridDhtLockRequest.addNearKey(K key,
byte[] keyBytes,
GridCacheContext<K,V> ctx)
Adds a Near key.
|
protected void |
GridDhtTransactionalCacheAdapter.finish(GridCacheContext<K,V> ctx,
UUID nodeId,
GridCacheTxRemoteEx<K,V> tx,
GridDhtTxFinishRequest<K,V> req,
Collection<GridCacheTxEntry<K,V>> writes) |
void |
GridDhtTxPrepareResponse.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheContext) method. |
void |
GridDhtUnlockRequest.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheContext) method. |
void |
GridDhtAffinityAssignmentResponse.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheContext) method. |
void |
GridDhtLockRequest.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheContext) method. |
void |
GridDhtTxPrepareRequest.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheContext) method. |
void |
GridDhtTxFinishRequest.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheContext) method. |
void |
GridDhtLockResponse.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheContext) method. |
void |
GridDhtTxPrepareResponse.prepareMarshal(GridCacheContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDhtAffinityAssignmentResponse.prepareMarshal(GridCacheContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDhtLockRequest.prepareMarshal(GridCacheContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDhtTxPrepareRequest.prepareMarshal(GridCacheContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDhtTxFinishRequest.prepareMarshal(GridCacheContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDhtLockResponse.prepareMarshal(GridCacheContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
| Constructor and Description |
|---|
GridDhtAssignmentFetchFuture(GridCacheContext<K,V> ctx,
long topVer,
Collection<GridNode> availableNodes) |
GridDhtCache(GridCacheContext<K,V> ctx) |
GridDhtCache(GridCacheContext<K,V> ctx,
GridCacheConcurrentMap<K,V> map) |
GridDhtCacheAdapter(GridCacheContext<K,V> ctx) |
GridDhtCacheAdapter(GridCacheContext<K,V> ctx,
GridCacheConcurrentMap<K,V> map)
Constructor used for near-only cache.
|
GridDhtCacheEntry(GridCacheContext<K,V> ctx,
long topVer,
K key,
int hash,
V val,
GridCacheMapEntry<K,V> next,
long ttl,
int hdrId) |
GridDhtCacheEntryImpl(GridCacheProjectionImpl<K,V> nearPrj,
GridCacheContext<K,V> ctx,
K key,
GridCacheEntryEx<K,V> cached) |
GridDhtGetFuture(GridCacheContext<K,V> cctx,
long msgId,
UUID reader,
LinkedHashMap<? extends K,Boolean> keys,
boolean reload,
GridCacheTxLocalEx<K,V> tx,
long topVer,
GridPredicate<GridCacheEntry<K,V>>[] filters,
UUID subjId) |
GridDhtLockFuture(GridCacheContext<K,V> cctx,
UUID nearNodeId,
GridCacheVersion nearLockVer,
long topVer,
int cnt,
boolean read,
long timeout,
GridDhtTxLocalAdapter<K,V> tx,
long threadId,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridDhtTransactionalCacheAdapter(GridCacheContext<K,V> ctx) |
GridDhtTransactionalCacheAdapter(GridCacheContext<K,V> ctx,
GridCacheConcurrentMap<K,V> map)
Constructor used for near-only cache.
|
GridDhtTxFinishFuture(GridCacheContext<K,V> cctx,
GridDhtTxLocalAdapter<K,V> tx,
boolean commit) |
GridDhtTxLocalAdapter(GridCacheVersion xidVer,
boolean implicit,
boolean implicitSingle,
GridCacheContext<K,V> cctx,
GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
long timeout,
boolean invalidate,
boolean syncCommit,
boolean syncRollback,
boolean explicitLock,
boolean swapEnabled,
boolean storeEnabled,
int txSize,
Object grpLockKey,
boolean partLock,
UUID subjId) |
GridDhtTxPrepareFuture(GridCacheContext<K,V> cctx,
GridDhtTxLocalAdapter<K,V> tx,
GridUuid nearMiniId,
Map<K,GridCacheVersion> dhtVerMap,
boolean last,
Collection<UUID> lastBackups) |
GridDhtTxRemote(UUID nearNodeId,
GridUuid rmtFutId,
UUID nodeId,
GridCacheVersion nearXidVer,
long rmtThreadId,
long topVer,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
boolean invalidate,
long timeout,
GridCacheContext<K,V> ctx,
int txSize,
Object grpLockKey,
UUID subjId)
This constructor is meant for pessimistic transactions.
|
GridDhtTxRemote(UUID nearNodeId,
GridUuid rmtFutId,
UUID nodeId,
long rmtThreadId,
long topVer,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
boolean invalidate,
long timeout,
GridCacheContext<K,V> ctx,
int txSize,
Object grpLockKey,
GridCacheVersion nearXidVer,
Map<UUID,Collection<UUID>> txNodes,
UUID subjId)
This constructor is meant for optimistic transactions.
|
GridNoStorageCacheMap(GridCacheContext<K,V> ctx) |
GridPartitionedGetFuture(GridCacheContext<K,V> cctx,
Collection<? extends K> keys,
boolean reload,
boolean forcePrimary,
GridPredicate<GridCacheEntry<K,V>>[] filters,
UUID subjId) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDhtAtomicUpdateResponse.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheContext) method. |
void |
GridDhtAtomicUpdateRequest.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheContext) method. |
void |
GridNearAtomicUpdateResponse.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheContext) method. |
void |
GridNearAtomicUpdateRequest.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheContext) method. |
void |
GridDhtAtomicUpdateResponse.prepareMarshal(GridCacheContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDhtAtomicUpdateRequest.prepareMarshal(GridCacheContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridNearAtomicUpdateResponse.prepareMarshal(GridCacheContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridNearAtomicUpdateRequest.prepareMarshal(GridCacheContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
| Constructor and Description |
|---|
GridDhtColocatedCache(GridCacheContext<K,V> ctx) |
GridDhtColocatedCache(GridCacheContext<K,V> ctx,
GridCacheConcurrentMap<K,V> map)
Creates colocated cache with specified map.
|
GridDhtColocatedCacheEntry(GridCacheContext<K,V> ctx,
long topVer,
K key,
int hash,
V val,
GridCacheMapEntry<K,V> next,
long ttl,
int hdrId) |
GridDhtColocatedLockFuture(GridCacheContext<K,V> cctx,
Collection<? extends K> keys,
GridDhtColocatedTxLocal<K,V> tx,
boolean read,
boolean retval,
long timeout,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridDhtColocatedTxFinishFuture(GridCacheContext<K,V> cctx,
GridDhtColocatedTxLocal<K,V> tx) |
GridDhtColocatedTxLocal(boolean implicit,
boolean implicitSingle,
GridCacheContext<K,V> cctx,
GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
long timeout,
boolean invalidate,
boolean syncCommit,
boolean syncRollback,
boolean swapEnabled,
boolean storeEnabled,
int txSize,
Object grpLockKey,
boolean partLock,
UUID subjId) |
GridDhtColocatedTxPrepareFuture(GridCacheContext<K,V> cctx,
GridDhtColocatedTxLocal<K,V> tx) |
GridDhtDetachedCacheEntry(GridCacheContext<K,V> ctx,
K key,
int hash,
V val,
GridCacheMapEntry<K,V> next,
long ttl,
int hdrId) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDhtPartitionSupplyMessage.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheContext) method. |
void |
GridDhtPartitionsSingleMessage.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheContext) method. |
void |
GridDhtPartitionDemandMessage.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheContext) method. |
void |
GridDhtForceKeysResponse.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheContext) method. |
void |
GridDhtPartitionsFullMessage.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheContext) method. |
void |
GridDhtForceKeysRequest.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheContext) method. |
void |
GridDhtPartitionSupplyMessage.prepareMarshal(GridCacheContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDhtPartitionsSingleMessage.prepareMarshal(GridCacheContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDhtPartitionDemandMessage.prepareMarshal(GridCacheContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDhtForceKeysResponse.prepareMarshal(GridCacheContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDhtPartitionsFullMessage.prepareMarshal(GridCacheContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridDhtForceKeysRequest.prepareMarshal(GridCacheContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
| Constructor and Description |
|---|
GridDhtForceKeysFuture(GridCacheContext<K,V> cctx,
long topVer,
Collection<? extends K> keys,
GridDhtPreloader<K,V> preloader) |
GridDhtPartitionDemandPool(GridCacheContext<K,V> cctx,
ReadWriteLock busyLock) |
GridDhtPartitionsExchangeFuture(GridCacheContext<K,V> cctx,
boolean reassign,
GridDiscoveryEvent discoEvt,
GridDhtPartitionExchangeId exchId)
Dummy future created to trigger reassignments if partition
topology changed while preloading.
|
GridDhtPartitionsExchangeFuture(GridCacheContext<K,V> cctx,
GridDiscoveryEvent discoEvt,
GridDhtPartitionExchangeId exchId)
Force preload future created to trigger reassignments if partition
topology changed while preloading.
|
GridDhtPreloader(GridCacheContext<K,V> cctx) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridNearLockRequest.addKeyBytes(K key,
byte[] keyBytes,
boolean retVal,
GridCacheVersion dhtVer,
GridCacheTxEntry<K,V> writeEntry,
GridCacheVersion drVer,
GridCacheContext<K,V> ctx)
Adds a key.
|
void |
GridNearLockResponse.addValueBytes(V val,
byte[] valBytes,
boolean filterPassed,
GridCacheVersion dhtVer,
GridCacheVersion mappedVer,
GridCacheContext<K,V> ctx) |
void |
GridNearLockRequest.filter(GridPredicate<GridCacheEntry<K,V>>[] filter,
GridCacheContext<K,V> ctx) |
void |
GridNearGetResponse.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheContext) method. |
void |
GridNearTxPrepareResponse.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheContext) method. |
void |
GridNearGetRequest.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr) |
void |
GridNearTxFinishResponse.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheContext) method. |
void |
GridNearLockRequest.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheContext) method. |
void |
GridNearGetResponse.prepareMarshal(GridCacheContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridNearTxPrepareResponse.prepareMarshal(GridCacheContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridNearGetRequest.prepareMarshal(GridCacheContext<K,V> ctx) |
void |
GridNearTxFinishResponse.prepareMarshal(GridCacheContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridNearLockRequest.prepareMarshal(GridCacheContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
| Constructor and Description |
|---|
GridNearAtomicCache(GridCacheContext<K,V> ctx) |
GridNearCacheAdapter(GridCacheContext<K,V> ctx) |
GridNearCacheEntry(GridCacheContext<K,V> ctx,
K key,
int hash,
V val,
GridCacheMapEntry<K,V> next,
long ttl,
int hdrId) |
GridNearGetFuture(GridCacheContext<K,V> cctx,
Collection<? extends K> keys,
boolean reload,
boolean forcePrimary,
GridCacheTxLocalEx<K,V> tx,
GridPredicate<GridCacheEntry<K,V>>[] filters,
UUID subjId) |
GridNearLockFuture(GridCacheContext<K,V> cctx,
Collection<? extends K> keys,
org.gridgain.grid.kernal.processors.cache.distributed.near.GridNearTxLocal<K,V> tx,
boolean read,
boolean retval,
long timeout,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridNearTransactionalCache(GridCacheContext<K,V> ctx) |
GridNearTxFinishFuture(GridCacheContext<K,V> cctx,
org.gridgain.grid.kernal.processors.cache.distributed.near.GridNearTxLocal<K,V> tx,
boolean commit) |
GridNearTxPrepareFuture(GridCacheContext<K,V> cctx,
org.gridgain.grid.kernal.processors.cache.distributed.near.GridNearTxLocal<K,V> tx) |
GridNearTxRemote(ClassLoader ldr,
UUID nodeId,
UUID nearNodeId,
long rmtThreadId,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
boolean invalidate,
long timeout,
Collection<GridCacheTxEntry<K,V>> writeEntries,
GridCacheContext<K,V> ctx,
int txSize,
Object grpLockKey,
UUID subjId)
This constructor is meant for optimistic transactions.
|
GridNearTxRemote(UUID nodeId,
UUID nearNodeId,
GridCacheVersion nearXidVer,
long rmtThreadId,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
boolean invalidate,
long timeout,
K key,
byte[] keyBytes,
V val,
byte[] valBytes,
GridCacheVersion drVer,
GridCacheContext<K,V> ctx,
int txSize,
Object grpLockKey,
UUID subjId)
This constructor is meant for pessimistic transactions.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridOsCacheDrManager.start(GridCacheContext<K,V> cctx)
Starts manager.
|
| Constructor and Description |
|---|
GridLocalCache(GridCacheContext<K,V> ctx) |
GridLocalCacheEntry(GridCacheContext<K,V> ctx,
K key,
int hash,
V val,
GridCacheMapEntry<K,V> next,
long ttl,
int hdrId) |
| Constructor and Description |
|---|
GridLocalAtomicCache(GridCacheContext<K,V> ctx) |
| Modifier and Type | Field and Description |
|---|---|
protected GridCacheContext<K,V> |
GridCacheQueryFutureAdapter.cctx
Cache context.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridCacheQueryResponse.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheContext) method. |
void |
GridCacheQueryRequest.finishUnmarshal(GridCacheContext<K,V> ctx,
ClassLoader ldr)
This method is called after the message is deserialized and is responsible for
unmarshalling state marshalled in
GridCacheMessage.prepareMarshal(GridCacheContext) method. |
void |
GridCacheQueryResponse.prepareMarshal(GridCacheContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
void |
GridCacheQueryRequest.prepareMarshal(GridCacheContext<K,V> ctx)
This method is called before the whole message is serialized
and is responsible for pre-marshalling state.
|
Copyright © 2014. All rights reserved.