Interface WorkProgressDispatcher
-
- All Known Implementing Classes:
Checkpointer,CommunicationWorker,DmsDataWriterWorker,FileHandleManagerImpl.WALWriter,GridJobWorker,GridTaskWorker,GridWorker,SchemaIndexCachePartitionWorker,SchemaOperationWorker,StripedExecutor.Stripe
public interface WorkProgressDispatcherDispatcher of workers' progress which allows us to understand if worker freezes.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description voidblockingSectionBegin()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 nearestblockingSectionEnd()call.voidblockingSectionEnd()Closes the protection section previously opened byblockingSectionBegin().longheartbeatTs()Last heatbeat timestamp.voidupdateHeartbeat()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 nearestblockingSectionEnd()call. Nested calls are not supported.
-
blockingSectionEnd
void blockingSectionEnd()
Closes the protection section previously opened byblockingSectionBegin().
-
-