MCPcopy Index your code
hub / github.com/questdb/questdb / done

Method done

core/src/main/java/io/questdb/mp/Sequence.java:29–29  ·  view source on GitHub ↗
(long cursor)

Source from the content-addressed store, hash-verified

27public interface Sequence extends Barrier {
28
29 void done(long cursor);
30
31 /***
32 * Returns next position to publish to / fetch from

Callers 15

appendTaskToQueueMethod · 0.95
o3ScheduleMoveUncommitted0Method · 0.95
resetMethod · 0.95
dispatchConvertColumnPartitionTaskMethod · 0.95
purgeColumnVersionAsyncMethod · 0.95
buildTreeMapMethod · 0.95
processTasksMethod · 0.95
notifyWalTxnCommittedMethod · 0.95
queueColumnVersionPurgeMethod · 0.95
dispatchColumnTasksMethod · 0.95
o3ConsumePartitionUpdatesMethod · 0.95
processWalCommitBlock_sortWalSegmentTimestamps_dispatchColumnSortTasksMethod · 0.95

Implementers 1

AbstractSSequencecore/src/main/java/io/questdb/mp/Abstr

Calls

no outgoing calls

Tested by 15

appendTaskToQueueMethod · 0.76
o3ScheduleMoveUncommitted0Method · 0.76
resetMethod · 0.76
buildTreeMapMethod · 0.76
processTasksMethod · 0.76
onHeadersReadyMethod · 0.52
runMethod · 0.52
runMethod · 0.52
runMethod · 0.52
doTestMethod · 0.52
runMethod · 0.52
testConcurrentFanOutAsyncOffloadPatternMethod · 0.52