org.apache.ignite.internal.util.worker

Interface WorkProgressDispatcher

All Known Implementing Classes:

Checkpointer, CommunicationWorker, DmsDataWriterWorker, FileHandleManagerImpl.WALWriter, GridJobWorker, GridTaskWorker, GridWorker, SchemaIndexCachePartitionWorker, SchemaOperationWorker, ShmemAcceptWorker, ShmemWorker, StripedExecutor.Stripe

public interface WorkProgressDispatcher

Dispatcher of workers' progress which allows us to understand if worker freezes.

Method Summary

Modifier and Type	Method and Description
void	blockingSectionBegin() Protects the worker from timeout penalties if subsequent instructions in the calling thread does not update heartbeat timestamp timely, e.g. due to blocking operations, up to the nearest blockingSectionEnd() call.
void	blockingSectionEnd() Closes the protection section previously opened by blockingSectionBegin().
long	heartbeatTs() Last heatbeat timestamp.
void	updateHeartbeat() Notifying dispatcher that work is in progress and thread didn't freeze.

Method Detail

heartbeatTs

long heartbeatTs()

Last heatbeat timestamp.

updateHeartbeat

void updateHeartbeat()

Notifying dispatcher that work is in progress and thread didn't freeze.

blockingSectionBegin

void blockingSectionBegin()

Protects the worker from timeout penalties if subsequent instructions in the calling thread does not update heartbeat timestamp timely, e.g. due to blocking operations, up to the nearest blockingSectionEnd() call. Nested calls are not supported.

blockingSectionEnd

void blockingSectionEnd()

Closes the protection section previously opened by blockingSectionBegin().