A11 (C++ runtime)
Native C++ implementation of the A11 streaming action runtime
Loading...
Searching...
No Matches
a11::stores::ChunkStoreReader::State Member List

This is the complete list of members for a11::stores::ChunkStoreReader::State, including all inherited members.

ABSL_GUARDED_BY(mu)a11::stores::ChunkStoreReader::State
ABSL_GUARDED_BY(mu)=0a11::stores::ChunkStoreReader::Statepure virtual
ABSL_GUARDED_BY(mu)a11::stores::ChunkStoreReader::State
ABSL_GUARDED_BY(mu)a11::stores::ChunkStoreReader::State
ABSL_GUARDED_BY(mu)a11::stores::ChunkStoreReader::State
ABSL_GUARDED_BY(mu)a11::stores::ChunkStoreReader::State
ABSL_GUARDED_BY(mu)a11::stores::ChunkStoreReader::State
ABSL_GUARDED_BY(mu)a11::stores::ChunkStoreReader::State
ABSL_GUARDED_BY(mu)=0a11::stores::ChunkStoreReader::Statepure virtual
ABSL_GUARDED_BY(mu)a11::stores::ChunkStoreReader::State
ABSL_GUARDED_BY(mu)a11::stores::ChunkStoreReader::State
ABSL_GUARDED_BY(mu)=0a11::stores::ChunkStoreReader::Statepure virtual
ABSL_GUARDED_BY(mu)=0a11::stores::ChunkStoreReader::Statepure virtual
ABSL_GUARDED_BY(mu)a11::stores::ChunkStoreReader::State
ABSL_GUARDED_BY(mu)a11::stores::ChunkStoreReader::State
ABSL_GUARDED_BY(mu)a11::stores::ChunkStoreReader::State
ActivePendingReadCountLocked() const ABSL_EXCLUSIVE_LOCKS_REQUIRED(mu)a11::stores::ChunkStoreReader::Stateinline
Cancel()a11::stores::ChunkStoreReader::Stateinline
ClearDone(std::uint64_t generation, const absl::StatusOr< data::NodeFragment > &result)a11::stores::ChunkStoreReader::Stateinline
CollectAvailableLocked(std::vector< Completion > *completions) ABSL_EXCLUSIVE_LOCKS_REQUIRED(mu)a11::stores::ChunkStoreReader::Stateinline
Complete(std::vector< Completion > completions)a11::stores::ChunkStoreReader::Stateinlinestatic
CompletionKind enum namea11::stores::ChunkStoreReader::State
donea11::stores::ChunkStoreReader::State
done_promisea11::stores::ChunkStoreReader::State
DrainArrivedLocked(std::vector< Completion > *completions, bool *start_clear, std::uint32_t *clear_seq, std::uint64_t *clear_generation) ABSL_EXCLUSIVE_LOCKS_REQUIRED(mu)a11::stores::ChunkStoreReader::Stateinline
Drive()a11::stores::ChunkStoreReader::Stateinline
DriveOnce()a11::stores::ChunkStoreReader::Stateinline
FetchArrived(std::uint64_t arrived_position, std::uint64_t generation, absl::StatusOr< data::NodeFragment > result, bool inline_drive=false)a11::stores::ChunkStoreReader::Stateinline
FinishFragmentLocked(data::NodeFragment fragment, std::vector< Completion > *completions) ABSL_EXCLUSIVE_LOCKS_REQUIRED(mu)a11::stores::ChunkStoreReader::Stateinline
HasReadCapacityLocked(size_t about_to_issue=0) const ABSL_EXCLUSIVE_LOCKS_REQUIRED(mu)a11::stores::ChunkStoreReader::Stateinline
InstallClear(const a11::Future< data::NodeFragment > &pending, std::uint64_t generation)a11::stores::ChunkStoreReader::Stateinline
InstallFetch(const a11::Future< data::NodeFragment > &pending, std::uint64_t position_wanted, std::uint64_t generation)a11::stores::ChunkStoreReader::Stateinline
kMaxFetchesInFlighta11::stores::ChunkStoreReader::Statestatic
MaybeCompleteDone()a11::stores::ChunkStoreReader::Stateinline
mua11::stores::ChunkStoreReader::Statemutable
Next(absl::Duration timeout)a11::stores::ChunkStoreReader::Stateinline
NextResult typedefa11::stores::ChunkStoreReader::State
Operation enum namea11::stores::ChunkStoreReader::State
optionsa11::stores::ChunkStoreReader::State
PopPendingReadLocked() ABSL_EXCLUSIVE_LOCKS_REQUIRED(mu)a11::stores::ChunkStoreReader::Stateinline
pumpa11::stores::ChunkStoreReader::State
Scheduler()a11::stores::ChunkStoreReader::Stateinlinestatic
State(std::shared_ptr< ChunkStore > chunk_store, ChunkStoreReaderOptions reader_options)a11::stores::ChunkStoreReader::Stateinline
storea11::stores::ChunkStoreReader::State
TakeBuffered(size_t limit)a11::stores::ChunkStoreReader::Stateinline
Wake()a11::stores::ChunkStoreReader::Stateinline