|
A11 (C++ runtime)
Native C++ implementation of the A11 action and streaming runtime
|
Public Member Functions | |
| std::deque< std::optional< ReceivedSessionMessage > > queue | ABSL_GUARDED_BY (mu) |
| std::optional< absl::Status > error | ABSL_GUARDED_BY (mu) |
| absl::flat_hash_set< net::WireStream * > ended_streams | ABSL_GUARDED_BY (mu) |
| bool session_half_closed | ABSL_GUARDED_BY (mu) |
| bool eof_started | ABSL_GUARDED_BY (mu) |
| bool eof_delivered | ABSL_GUARDED_BY (mu) |
| std::shared_ptr< thread::PermanentEvent > changed | ABSL_GUARDED_BY (mu) |
Public Attributes | |
| thread::Mutex | mu |
| std::deque< std::optional< ReceivedSessionMessage > > queue a11::service::SessionWithRecv::ReceiveState::ABSL_GUARDED_BY | ( | mu | ) |
| std::optional< absl::Status > error a11::service::SessionWithRecv::ReceiveState::ABSL_GUARDED_BY | ( | mu | ) |
| absl::flat_hash_set< net::WireStream * > ended_streams a11::service::SessionWithRecv::ReceiveState::ABSL_GUARDED_BY | ( | mu | ) |
| bool session_half_closed a11::service::SessionWithRecv::ReceiveState::ABSL_GUARDED_BY | ( | mu | ) |
| bool eof_started a11::service::SessionWithRecv::ReceiveState::ABSL_GUARDED_BY | ( | mu | ) |
| bool eof_delivered a11::service::SessionWithRecv::ReceiveState::ABSL_GUARDED_BY | ( | mu | ) |
| std::shared_ptr< thread::PermanentEvent > changed a11::service::SessionWithRecv::ReceiveState::ABSL_GUARDED_BY | ( | mu | ) |
| thread::Mutex a11::service::SessionWithRecv::ReceiveState::mu |