MCPcopy Create free account
hub / github.com/questdb/questdb / drain

Method drain

core/src/main/java/io/questdb/mp/Job.java:34–34  ·  view source on GitHub ↗
(int workerId)

Source from the content-addressed store, hash-verified

32 RunStatus TERMINATING_STATUS = () -> true;
33
34 default void drain(int workerId) {
35 while (true) {
36 if (!run(workerId)) {
37 return;

Callers 15

drainCopyImportJobQueueMethod · 0.65
drainPurgeJobMethod · 0.65
drainWalQueueMethod · 0.65
testLocalCopyFromCancellationMethod · 0.65
testUpdateCommandRunningInWALCantBeCancelledMethod · 0.65
testUpdateCommandRunningInWALDoesntTimeOutMethod · 0.65
testSuspendResumeWalPurgeJobMethod · 0.65
runPartitionPurgeJobsMethod · 0.65
testParallelCopyCancelChecksImportIdMethod · 0.65
testParallelCopyCancelRejectsSecondReqMethod · 0.65
testSerialCopyCancelChecksImportIdMethod · 0.65
testCopyMethod · 0.65

Implementers 8

LineTcpLegacyWriterJobcore/src/main/java/io/questdb/cutlass/
AbstractQueueConsumerJobcore/src/main/java/io/questdb/mp/Abstr
SynchronizedJobcore/src/main/java/io/questdb/mp/Synch
AsyncMunmapJobcore/src/main/java/io/questdb/std/Asyn
PageFrameReduceJobcore/src/main/java/io/questdb/cairo/sq
UnorderedPageFrameReduceJobcore/src/main/java/io/questdb/cairo/sq
ViewCompilerJobcore/src/main/java/io/questdb/cairo/vi
MatViewRefreshJobcore/src/main/java/io/questdb/cairo/mv

Calls

no outgoing calls

Tested by 15

drainCopyImportJobQueueMethod · 0.52
drainPurgeJobMethod · 0.52
drainWalQueueMethod · 0.52
testLocalCopyFromCancellationMethod · 0.52
testUpdateCommandRunningInWALCantBeCancelledMethod · 0.52
testUpdateCommandRunningInWALDoesntTimeOutMethod · 0.52
testSuspendResumeWalPurgeJobMethod · 0.52
runPartitionPurgeJobsMethod · 0.52
testParallelCopyCancelChecksImportIdMethod · 0.52
testParallelCopyCancelRejectsSecondReqMethod · 0.52
testSerialCopyCancelChecksImportIdMethod · 0.52
testCopyMethod · 0.52