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 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	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/19]

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

(

mu

)

ABSL_GUARDED_BY() [2/19]

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

(

mu

)

ABSL_GUARDED_BY() [3/19]

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

(

mu

)

ABSL_GUARDED_BY() [4/19]

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

(

mu

)

ABSL_GUARDED_BY() [5/19]

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

(

mu

)

ABSL_GUARDED_BY() [6/19]

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

(

mu

)

ABSL_GUARDED_BY() [7/19]

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

(

mu

)

ABSL_GUARDED_BY() [8/19]

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

(

mu

)

ABSL_GUARDED_BY() [9/19]

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

(

mu

)

ABSL_GUARDED_BY() [10/19]

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

(

mu

)

ABSL_GUARDED_BY() [11/19]

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

(

mu

)

ABSL_GUARDED_BY() [12/19]

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

(

mu

)

ABSL_GUARDED_BY() [13/19]

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

(

mu

)

ABSL_GUARDED_BY() [14/19]

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

(

mu

)

ABSL_GUARDED_BY() [15/19]

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

(

mu

)

ABSL_GUARDED_BY() [16/19]

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

(

mu

)

ABSL_GUARDED_BY() [17/19]

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

(

mu

)

ABSL_GUARDED_BY() [18/19]

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

(

mu

)

ABSL_GUARDED_BY() [19/19]

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

pure virtual

Member Data Documentation

cv

thread::CondVar a11::net::InProcessWireStream::State::cv

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

mu

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

mutable

options

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

peer

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

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

---

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

• cpp/a11/net/in_process_wire_stream.cc