a11::net::InProcessWireStream::State Struct Reference

Classes
struct	Outbound

Public Member Functions
	State (WireStreamOptions stream_options, std::string stream_id)
std::deque< Outbound > outbound	ABSL_GUARDED_BY (mu)
std::deque< std::string > incoming	ABSL_GUARDED_BY (mu)
size_t incoming_bytes	ABSL_GUARDED_BY (mu)=0
bool sending	ABSL_GUARDED_BY (mu)
bool started	ABSL_GUARDED_BY (mu)
bool transport_finished	ABSL_GUARDED_BY (mu)
End local_end	ABSL_GUARDED_BY (mu)
End local_end_sent	ABSL_GUARDED_BY (mu)
bool half_close_requested	ABSL_GUARDED_BY (mu)
bool remote_half_closed	ABSL_GUARDED_BY (mu)
bool remote_aborted	ABSL_GUARDED_BY (mu)
bool implementation_aborted	ABSL_GUARDED_BY (mu)
absl::Status status	ABSL_GUARDED_BY (mu)
std::optional< data::ByteMap > trailers	ABSL_GUARDED_BY (mu)
OnMessage on_message	ABSL_GUARDED_BY (mu)
OnDone on_done	ABSL_GUARDED_BY (mu)
bool done_called	ABSL_GUARDED_BY (mu)
absl::Time deadline	ABSL_GUARDED_BY (mu)
absl::Time last_activity	ABSL_GUARDED_BY (mu)
obs::Span span	ABSL_GUARDED_BY (mu)

Public Attributes
const WireStreamOptions	options
const std::string	id
std::weak_ptr< State >	peer
thread::Mutex	mu
thread::CondVar	outbound_cv
thread::CondVar	incoming_cv
thread::CondVar	room_cv
thread::CondVar	timing_cv
const std::shared_ptr< a11::Promise< a11::Unit > >	terminal_promise
const a11::Task	terminal_future
const std::shared_ptr< a11::Promise< a11::Unit > >	done_promise
const a11::Task	done_future

Constructor & Destructor Documentation

State()

a11::net::InProcessWireStream::State::State ( WireStreamOptions  stream_options, std::string  stream_id  )

inline

Member Function Documentation

ABSL_GUARDED_BY() [1/20]

std::deque< Outbound > outbound a11::net::InProcessWireStream::State::ABSL_GUARDED_BY

(

mu

)

ABSL_GUARDED_BY() [2/20]

std::deque< std::string > incoming a11::net::InProcessWireStream::State::ABSL_GUARDED_BY

(

mu

)

ABSL_GUARDED_BY() [3/20]

bool sending a11::net::InProcessWireStream::State::ABSL_GUARDED_BY

(

mu

)

ABSL_GUARDED_BY() [4/20]

bool started a11::net::InProcessWireStream::State::ABSL_GUARDED_BY

(

mu

)

ABSL_GUARDED_BY() [5/20]

bool transport_finished a11::net::InProcessWireStream::State::ABSL_GUARDED_BY

(

mu

)

ABSL_GUARDED_BY() [6/20]

End local_end a11::net::InProcessWireStream::State::ABSL_GUARDED_BY

(

mu

)

ABSL_GUARDED_BY() [7/20]

End local_end_sent a11::net::InProcessWireStream::State::ABSL_GUARDED_BY

(

mu

)

ABSL_GUARDED_BY() [8/20]

bool half_close_requested a11::net::InProcessWireStream::State::ABSL_GUARDED_BY

(

mu

)

ABSL_GUARDED_BY() [9/20]

bool remote_half_closed a11::net::InProcessWireStream::State::ABSL_GUARDED_BY

(

mu

)

ABSL_GUARDED_BY() [10/20]

bool remote_aborted a11::net::InProcessWireStream::State::ABSL_GUARDED_BY

(

mu

)

ABSL_GUARDED_BY() [11/20]

bool implementation_aborted a11::net::InProcessWireStream::State::ABSL_GUARDED_BY

(

mu

)

ABSL_GUARDED_BY() [12/20]

absl::Status status a11::net::InProcessWireStream::State::ABSL_GUARDED_BY

(

mu

)

ABSL_GUARDED_BY() [13/20]

std::optional< data::ByteMap > trailers a11::net::InProcessWireStream::State::ABSL_GUARDED_BY

(

mu

)

ABSL_GUARDED_BY() [14/20]

OnMessage on_message a11::net::InProcessWireStream::State::ABSL_GUARDED_BY

(

mu

)

ABSL_GUARDED_BY() [15/20]

OnDone on_done a11::net::InProcessWireStream::State::ABSL_GUARDED_BY

(

mu

)

ABSL_GUARDED_BY() [16/20]

bool done_called a11::net::InProcessWireStream::State::ABSL_GUARDED_BY

(

mu

)

ABSL_GUARDED_BY() [17/20]

absl::Time deadline a11::net::InProcessWireStream::State::ABSL_GUARDED_BY

(

mu

)

ABSL_GUARDED_BY() [18/20]

absl::Time last_activity a11::net::InProcessWireStream::State::ABSL_GUARDED_BY

(

mu

)

ABSL_GUARDED_BY() [19/20]

obs::Span span a11::net::InProcessWireStream::State::ABSL_GUARDED_BY

(

mu

)

ABSL_GUARDED_BY() [20/20]

size_t incoming_bytes a11::net::InProcessWireStream::State::ABSL_GUARDED_BY ( mu  )

pure virtual

Member Data Documentation

done_future

const a11::Task a11::net::InProcessWireStream::State::done_future

done_promise

const std::shared_ptr<a11::Promise<a11::Unit> > a11::net::InProcessWireStream::State::done_promise

id

const std::string a11::net::InProcessWireStream::State::id

incoming_cv

thread::CondVar a11::net::InProcessWireStream::State::incoming_cv

mu

thread::Mutex a11::net::InProcessWireStream::State::mu

mutable

options

const WireStreamOptions a11::net::InProcessWireStream::State::options

outbound_cv

thread::CondVar a11::net::InProcessWireStream::State::outbound_cv

peer

std::weak_ptr<State> a11::net::InProcessWireStream::State::peer

room_cv

thread::CondVar a11::net::InProcessWireStream::State::room_cv

terminal_future

const a11::Task a11::net::InProcessWireStream::State::terminal_future

terminal_promise

const std::shared_ptr<a11::Promise<a11::Unit> > a11::net::InProcessWireStream::State::terminal_promise

timing_cv

thread::CondVar a11::net::InProcessWireStream::State::timing_cv

---

The documentation for this struct was generated from the following file:

• cpp/a11/net/in_process_wire_stream.cc