| Modifier and Type | Method and Description |
|---|---|
IgniteInClosure<IgniteConfiguration> |
IgniteConfiguration.getWarmupClosure()
Gets grid warmup closure.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteConfiguration |
IgniteConfiguration.setWarmupClosure(IgniteInClosure<IgniteConfiguration> warmupClos)
Sets warmup closure to execute before grid startup.
|
| Modifier and Type | Method and Description |
|---|---|
void |
IgniteInternalFuture.listen(IgniteInClosure<? super IgniteInternalFuture<R>> lsnr)
Registers listener closure to be asynchronously notified whenever future completes.
|
void |
IgniteDiagnosticPrepareContext.send(GridKernalContext ctx,
IgniteInClosure<IgniteInternalFuture<String>> lsnr) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridIoManager.sendOrderedMessage(ClusterNode node,
Object topic,
Message msg,
byte plc,
long timeout,
boolean skipOnTimeout,
IgniteInClosure<IgniteException> ackC) |
void |
GridIoManager.sendToGridTopic(ClusterNode node,
GridTopic topic,
Message msg,
byte plc,
IgniteInClosure<IgniteException> ackC) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDiscoveryManager.addLocalNodeInitializedEventListener(IgniteInClosure<ClusterNode> lsnr)
Adds a listener for local node initialized event.
|
| Modifier and Type | Interface and Description |
|---|---|
static interface |
GridCacheUtils.BackupPostProcessingClosure |
| Modifier and Type | Class and Description |
|---|---|
class |
CacheObjectsReleaseFuture<T,R> |
protected static class |
GridCacheAdapter.UpdateGetTimeStatClosure<T> |
protected static class |
GridCacheAdapter.UpdatePutAndGetTimeStatClosure<T> |
protected static class |
GridCacheAdapter.UpdatePutTimeStatClosure<T> |
protected static class |
GridCacheAdapter.UpdateRemoveTimeStatClosure<T> |
protected static class |
GridCacheAdapter.UpdateTimeStatClosure<T> |
class |
GridCacheCompoundFuture<T,R> |
class |
GridCacheCompoundIdentityFuture<T> |
| Modifier and Type | Method and Description |
|---|---|
static IgniteInClosure<IgniteInternalFuture<?>> |
GridCacheUtils.errorLogger(IgniteLogger log,
Class<? extends Exception>... excl) |
| Modifier and Type | Class and Description |
|---|---|
class |
GridCacheTxRecoveryFuture
Future verifying that all remote transactions related to transaction were prepared or committed.
|
| Modifier and Type | Class and Description |
|---|---|
class |
CacheDistributedGetFutureAdapter<K,V> |
class |
GridDhtGetFuture<K,V> |
class |
GridDhtLockFuture
Cache lock future.
|
class |
GridDhtTxFinishFuture<K,V> |
class |
GridDhtTxPrepareFuture |
class |
GridPartitionedGetFuture<K,V>
Colocated get future.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridDhtColocatedLockFuture
Colocated cache lock future.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridDhtForceKeysFuture<K,V>
Force keys request future.
|
class |
InitNewCoordinatorFuture |
| Modifier and Type | Class and Description |
|---|---|
class |
GridNearGetFuture<K,V> |
class |
GridNearLockFuture
Cache lock future.
|
class |
GridNearOptimisticSerializableTxPrepareFuture |
class |
GridNearOptimisticTxPrepareFuture |
class |
GridNearOptimisticTxPrepareFutureAdapter |
class |
GridNearPessimisticTxPrepareFuture |
class |
GridNearTxFinishFuture<K,V> |
class |
GridNearTxPrepareFutureAdapter
Common code for tx prepare in optimistic and pessimistic modes.
|
| Modifier and Type | Method and Description |
|---|---|
long |
BPlusTree.destroy(IgniteInClosure<L> c)
Destroys tree.
|
| Modifier and Type | Method and Description |
|---|---|
void |
BPlusIO.visit(long pageAddr,
IgniteInClosure<L> c) |
| Modifier and Type | Method and Description |
|---|---|
void |
FileWriteAheadLogManager.setCreateWalFileListener(IgniteInClosure<FileIO> createWalFileListener)
Setup listener for WAL segment write File IO creation.
|
| Modifier and Type | Method and Description |
|---|---|
void |
AbstractDataLeafIO.visit(long pageAddr,
IgniteInClosure<CacheSearchRow> c) |
void |
AbstractDataInnerIO.visit(long pageAddr,
IgniteInClosure<CacheSearchRow> c) |
| Modifier and Type | Method and Description |
|---|---|
void |
PlatformCompute.ComputeConvertingFuture.listen(IgniteInClosure lsnr)
Registers listener closure to be asynchronously notified whenever future completes.
|
| Modifier and Type | Method and Description |
|---|---|
protected int |
PlatformDotNetCacheStore.doInvoke(IgniteInClosure<BinaryRawWriterEx> task,
IgniteInClosure<BinaryRawReaderEx> readClo)
Perform actual invoke.
|
protected int |
PlatformDotNetCacheStore.doInvoke(IgniteInClosure<BinaryRawWriterEx> task,
IgniteInClosure<BinaryRawReaderEx> readClo)
Perform actual invoke.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridServiceDeploymentCompoundFuture
Service deployment compound future.
|
| Modifier and Type | Method and Description |
|---|---|
static GridJavaProcess |
GridJavaProcess.exec(Class cls,
String params,
IgniteLogger log,
IgniteInClosure<String> printC,
GridAbsClosure procKilledC)
Executes main() method of the given class in a separate system process.
|
static GridJavaProcess |
GridJavaProcess.exec(Class cls,
String params,
IgniteLogger log,
IgniteInClosure<String> printC,
GridAbsClosure procKilledC,
Collection<String> jvmArgs,
String cp)
Executes main() method of the given class in a separate system process.
|
static GridJavaProcess |
GridJavaProcess.exec(String clsName,
String params,
IgniteLogger log,
IgniteInClosure<String> printC,
GridAbsClosure procKilledC,
String javaHome,
Collection<String> jvmArgs,
String cp)
Executes main() method of the given class in a separate system process.
|
void |
GridCircularBuffer.forEach(IgniteInClosure<T> c)
Executes given closure for every item in circular buffer.
|
| Modifier and Type | Class and Description |
|---|---|
class |
AsyncFutureListener<V>
Wraps listener and executes it in specified executor.
|
class |
GridCompoundFuture<T,R>
Future composed of multiple inner futures.
|
class |
GridCompoundIdentityFuture<T>
Compound future with reducer which accepts and produces results of the same type.
|
| Modifier and Type | Method and Description |
|---|---|
void |
IgniteFutureImpl.listen(IgniteInClosure<? super IgniteFuture<V>> lsnr)
Registers listener closure to be asynchronously notified whenever future completes.
|
void |
GridFutureAdapter.listen(IgniteInClosure<? super IgniteInternalFuture<R>> lsnr)
Registers listener closure to be asynchronously notified whenever future completes.
|
void |
GridFinishedFuture.listen(IgniteInClosure<? super IgniteInternalFuture<T>> lsnr)
Registers listener closure to be asynchronously notified whenever future completes.
|
void |
IgniteFutureImpl.listenAsync(IgniteInClosure<? super IgniteFuture<V>> lsnr,
Executor exec)
Registers listener closure to be asynchronously notified whenever future completes.
|
| Constructor and Description |
|---|
AsyncFutureListener(IgniteInClosure<? super IgniteFuture<V>> lsnr,
Executor exec) |
| Modifier and Type | Class and Description |
|---|---|
class |
IgniteInClosureX<T>
Convenient in-closure subclass that allows for thrown grid exception.
|
| Modifier and Type | Method and Description |
|---|---|
static <X> void |
GridFunc.forEach(Iterable<? extends X> c,
IgniteInClosure<? super X> f,
IgnitePredicate<? super X>... p)
Deprecated.
|
static <X> void |
GridFunc.forEach(X[] c,
IgniteInClosure<? super X> f,
IgnitePredicate<? super X>... p)
Deprecated.
|
| Modifier and Type | Field and Description |
|---|---|
protected IgniteInClosure<IgniteException> |
GridNioFutureImpl.ackC |
| Modifier and Type | Method and Description |
|---|---|
IgniteInClosure<IgniteException> |
SessionWriteRequest.ackClosure() |
IgniteInClosure<IgniteException> |
GridNioFuture.ackClosure() |
IgniteInClosure<IgniteException> |
GridNioFutureImpl.ackClosure() |
IgniteInClosure<IgniteException> |
GridNioFinishedFuture.ackClosure() |
| Modifier and Type | Method and Description |
|---|---|
GridNioFuture<GridNioSession> |
GridNioServer.createSession(SocketChannel ch,
Map<Integer,Object> meta,
boolean async,
IgniteInClosure<? super IgniteInternalFuture<GridNioSession>> lsnr)
Establishes a session.
|
GridNioFuture<?> |
GridConnectionBytesVerifyFilter.onSessionWrite(GridNioSession ses,
Object msg,
boolean fut,
IgniteInClosure<IgniteException> ackC)
Invoked when a write request is performed on a session.
|
GridNioFuture<?> |
GridNioAsyncNotifyFilter.onSessionWrite(GridNioSession ses,
Object msg,
boolean fut,
IgniteInClosure<IgniteException> ackC)
Invoked when a write request is performed on a session.
|
GridNioFuture<?> |
GridNioFilter.onSessionWrite(GridNioSession ses,
Object msg,
boolean fut,
IgniteInClosure<IgniteException> ackC)
Invoked when a write request is performed on a session.
|
GridNioFuture<?> |
GridNioCodecFilter.onSessionWrite(GridNioSession ses,
Object msg,
boolean fut,
IgniteInClosure<IgniteException> ackC)
Invoked when a write request is performed on a session.
|
GridNioFuture<?> |
GridNioFilterChain.onSessionWrite(GridNioSession ses,
Object msg,
boolean fut,
IgniteInClosure<IgniteException> ackC)
Starts chain notification from tail to head.
|
GridNioFuture<?> |
GridNioFilter.proceedSessionWrite(GridNioSession ses,
Object msg,
boolean fut,
IgniteInClosure<IgniteException> ackC)
Forwards write request to the next logical filter in filter chain.
|
GridNioFuture<?> |
GridNioFilterAdapter.proceedSessionWrite(GridNioSession ses,
Object msg,
boolean fut,
IgniteInClosure<IgniteException> ackC)
Forwards write request to the next logical filter in filter chain.
|
boolean |
GridShmemCommunicationClient.sendMessage(UUID nodeId,
Message msg,
IgniteInClosure<IgniteException> c) |
boolean |
GridCommunicationClient.sendMessage(UUID nodeId,
Message msg,
IgniteInClosure<IgniteException> c) |
boolean |
GridTcpNioCommunicationClient.sendMessage(UUID nodeId,
Message msg,
IgniteInClosure<IgniteException> c) |
void |
GridNioSessionImpl.sendNoFuture(Object msg,
IgniteInClosure<IgniteException> ackC) |
void |
GridNioSession.sendNoFuture(Object msg,
IgniteInClosure<IgniteException> ackC) |
void |
GridNioServer.sendSystem(GridNioSession ses,
Message msg,
IgniteInClosure<? super IgniteInternalFuture<?>> lsnr)
Adds message at the front of the queue without acquiring back pressure semaphore.
|
boolean |
GridNioRecoveryDescriptor.tryReserve(long id,
IgniteInClosure<Boolean> c) |
| Constructor and Description |
|---|
GridNioFutureImpl(IgniteInClosure<IgniteException> ackC) |
| Modifier and Type | Method and Description |
|---|---|
GridNioFuture<?> |
GridNioSslFilter.onSessionWrite(GridNioSession ses,
Object msg,
boolean fut,
IgniteInClosure<IgniteException> ackC)
Invoked when a write request is performed on a session.
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
CI1<T>
Defines
alias for IgniteInClosure by extending it. |
| Modifier and Type | Class and Description |
|---|---|
class |
CIX1<T>
Defines
alias for IgniteInClosureX by extending it. |
| Modifier and Type | Method and Description |
|---|---|
void |
IgniteFuture.listen(IgniteInClosure<? super IgniteFuture<V>> lsnr)
Registers listener closure to be asynchronously notified whenever future completes.
|
void |
IgniteFuture.listenAsync(IgniteInClosure<? super IgniteFuture<V>> lsnr,
Executor exec)
Registers listener closure to be asynchronously notified whenever future completes.
|
| Modifier and Type | Method and Description |
|---|---|
void |
TcpCommunicationSpi.sendMessage(ClusterNode node,
Message msg,
IgniteInClosure<IgniteException> ackC)
Sends given message to destination node.
|
| Modifier and Type | Field and Description |
|---|---|
protected CopyOnWriteArrayList<IgniteInClosure<Socket>> |
TcpDiscoverySpi.incomeConnLsnrs |
protected CopyOnWriteArrayList<IgniteInClosure<TcpDiscoveryAbstractMessage>> |
TcpDiscoverySpi.sndMsgLsnrs |
| Modifier and Type | Method and Description |
|---|---|
void |
TcpDiscoverySpi.addIncomeConnectionListener(IgniteInClosure<Socket> lsnr)
FOR TEST ONLY!!!
|
void |
TcpDiscoverySpi.addSendMessageListener(IgniteInClosure<TcpDiscoveryAbstractMessage> lsnr)
FOR TEST ONLY!!!
|
void |
TcpDiscoverySpi.removeIncomeConnectionListener(IgniteInClosure<Socket> lsnr)
FOR TEST ONLY!!!
|
void |
TcpDiscoverySpi.removeSendMessageListener(IgniteInClosure<TcpDiscoveryAbstractMessage> lsnr)
FOR TEST ONLY!!!
|
| Modifier and Type | Class and Description |
|---|---|
class |
BasicWarmupClosure
Basic warm-up closure which warm-ups cache operations.
|
Follow @ApacheIgnite
Ignite Fabric : ver. 2.4.0 Release Date : March 5 2018