| ABSL_GUARDED_BY(mu) | a11::stores::ChunkStoreReader::State | |
| ABSL_GUARDED_BY(mu)=0 | a11::stores::ChunkStoreReader::State | pure 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)=0 | a11::stores::ChunkStoreReader::State | pure virtual |
| ABSL_GUARDED_BY(mu) | a11::stores::ChunkStoreReader::State | |
| ABSL_GUARDED_BY(mu) | a11::stores::ChunkStoreReader::State | |
| ABSL_GUARDED_BY(mu)=0 | a11::stores::ChunkStoreReader::State | pure virtual |
| ABSL_GUARDED_BY(mu)=0 | a11::stores::ChunkStoreReader::State | pure 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::State | inline |
| Cancel() | a11::stores::ChunkStoreReader::State | inline |
| ClearDone(std::uint64_t generation, const absl::StatusOr< data::NodeFragment > &result) | a11::stores::ChunkStoreReader::State | inline |
| CollectAvailableLocked(std::vector< Completion > *completions) ABSL_EXCLUSIVE_LOCKS_REQUIRED(mu) | a11::stores::ChunkStoreReader::State | inline |
| Complete(std::vector< Completion > completions) | a11::stores::ChunkStoreReader::State | inlinestatic |
| CompletionKind enum name | a11::stores::ChunkStoreReader::State | |
| done | a11::stores::ChunkStoreReader::State | |
| done_promise | a11::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::State | inline |
| Drive() | a11::stores::ChunkStoreReader::State | inline |
| DriveOnce() | a11::stores::ChunkStoreReader::State | inline |
| FetchArrived(std::uint64_t arrived_position, std::uint64_t generation, absl::StatusOr< data::NodeFragment > result, bool inline_drive=false) | a11::stores::ChunkStoreReader::State | inline |
| FinishFragmentLocked(data::NodeFragment fragment, std::vector< Completion > *completions) ABSL_EXCLUSIVE_LOCKS_REQUIRED(mu) | a11::stores::ChunkStoreReader::State | inline |
| HasReadCapacityLocked(size_t about_to_issue=0) const ABSL_EXCLUSIVE_LOCKS_REQUIRED(mu) | a11::stores::ChunkStoreReader::State | inline |
| InstallClear(const a11::Future< data::NodeFragment > &pending, std::uint64_t generation) | a11::stores::ChunkStoreReader::State | inline |
| InstallFetch(const a11::Future< data::NodeFragment > &pending, std::uint64_t position_wanted, std::uint64_t generation) | a11::stores::ChunkStoreReader::State | inline |
| kMaxFetchesInFlight | a11::stores::ChunkStoreReader::State | static |
| MaybeCompleteDone() | a11::stores::ChunkStoreReader::State | inline |
| mu | a11::stores::ChunkStoreReader::State | mutable |
| Next(absl::Duration timeout) | a11::stores::ChunkStoreReader::State | inline |
| NextResult typedef | a11::stores::ChunkStoreReader::State | |
| Operation enum name | a11::stores::ChunkStoreReader::State | |
| options | a11::stores::ChunkStoreReader::State | |
| PopPendingReadLocked() ABSL_EXCLUSIVE_LOCKS_REQUIRED(mu) | a11::stores::ChunkStoreReader::State | inline |
| pump | a11::stores::ChunkStoreReader::State | |
| Scheduler() | a11::stores::ChunkStoreReader::State | inlinestatic |
| State(std::shared_ptr< ChunkStore > chunk_store, ChunkStoreReaderOptions reader_options) | a11::stores::ChunkStoreReader::State | inline |
| store | a11::stores::ChunkStoreReader::State | |
| TakeBuffered(size_t limit) | a11::stores::ChunkStoreReader::State | inline |
| Wake() | a11::stores::ChunkStoreReader::State | inline |