a11::net::ChannelWireStream::State Struct Reference

Classes
struct	Outbound

Public Member Functions
	State (std::shared_ptr< internal::BinaryChannel > value_channel, std::string value_id, ChannelEndpointRole value_role, OpenOperation operation, WireStreamOptions value_options, ChannelFramingOptions value_framing)
	~State ()
absl::Time deadline	ABSL_GUARDED_BY (mu)
absl::Time last_activity	ABSL_GUARDED_BY (mu)
OnMessage on_message	ABSL_GUARDED_BY (mu)
OnDone on_done	ABSL_GUARDED_BY (mu)
bool started	ABSL_GUARDED_BY (mu)
bool open	ABSL_GUARDED_BY (mu)
bool channel_closed	ABSL_GUARDED_BY (mu)
bool finished	ABSL_GUARDED_BY (mu)
bool done_called	ABSL_GUARDED_BY (mu)
End local_end	ABSL_GUARDED_BY (mu)
End local_end_sent	ABSL_GUARDED_BY (mu)
bool remote_half_closed	ABSL_GUARDED_BY (mu)
bool remote_aborted	ABSL_GUARDED_BY (mu)
absl::Status status	ABSL_GUARDED_BY (mu)
std::optional< data::ByteMap > trailers	ABSL_GUARDED_BY (mu)
std::deque< Outbound > outgoing	ABSL_GUARDED_BY (mu)
std::deque< std::string > incoming	ABSL_GUARDED_BY (mu)
size_t incoming_bytes	ABSL_GUARDED_BY (mu)=0
std::uint64_t next_outgoing_message_id	ABSL_GUARDED_BY (mu)
std::shared_ptr< thread::PermanentEvent > changed	ABSL_GUARDED_BY (mu)
obs::Span span	ABSL_GUARDED_BY (mu)

Public Attributes
thread::Mutex	mu
const std::shared_ptr< internal::BinaryChannel >	channel
const std::string	id
const ChannelEndpointRole	role
const OpenOperation	open_operation
const WireStreamOptions	options
const ChannelFramingOptions	framing
ByteReassembler	reassembler
const std::shared_ptr< a11::Promise< a11::Unit > >	startup_promise
const a11::Task	startup_future
const std::shared_ptr< a11::Promise< a11::Unit > >	drain_promise
const a11::Task	drain_future

Constructor & Destructor Documentation

State()

a11::net::ChannelWireStream::State::State ( std::shared_ptr< internal::BinaryChannel >  value_channel, std::string  value_id, ChannelEndpointRole  value_role, OpenOperation  operation, WireStreamOptions  value_options, ChannelFramingOptions  value_framing  )

inline

~State()

a11::net::ChannelWireStream::State::~State ( )

inline

Member Function Documentation

ABSL_GUARDED_BY() [1/21]

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

(

mu

)

ABSL_GUARDED_BY() [2/21]

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

(

mu

)

ABSL_GUARDED_BY() [3/21]

OnMessage on_message a11::net::ChannelWireStream::State::ABSL_GUARDED_BY

(

mu

)

ABSL_GUARDED_BY() [4/21]

OnDone on_done a11::net::ChannelWireStream::State::ABSL_GUARDED_BY

(

mu

)

ABSL_GUARDED_BY() [5/21]

bool started a11::net::ChannelWireStream::State::ABSL_GUARDED_BY

(

mu

)

ABSL_GUARDED_BY() [6/21]

bool open a11::net::ChannelWireStream::State::ABSL_GUARDED_BY

(

mu

)

ABSL_GUARDED_BY() [7/21]

bool channel_closed a11::net::ChannelWireStream::State::ABSL_GUARDED_BY

(

mu

)

ABSL_GUARDED_BY() [8/21]

bool finished a11::net::ChannelWireStream::State::ABSL_GUARDED_BY

(

mu

)

ABSL_GUARDED_BY() [9/21]

bool done_called a11::net::ChannelWireStream::State::ABSL_GUARDED_BY

(

mu

)

ABSL_GUARDED_BY() [10/21]

End local_end a11::net::ChannelWireStream::State::ABSL_GUARDED_BY

(

mu

)

ABSL_GUARDED_BY() [11/21]

End local_end_sent a11::net::ChannelWireStream::State::ABSL_GUARDED_BY

(

mu

)

ABSL_GUARDED_BY() [12/21]

bool remote_half_closed a11::net::ChannelWireStream::State::ABSL_GUARDED_BY

(

mu

)

ABSL_GUARDED_BY() [13/21]

bool remote_aborted a11::net::ChannelWireStream::State::ABSL_GUARDED_BY

(

mu

)

ABSL_GUARDED_BY() [14/21]

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

(

mu

)

ABSL_GUARDED_BY() [15/21]

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

(

mu

)

ABSL_GUARDED_BY() [16/21]

std::deque< Outbound > outgoing a11::net::ChannelWireStream::State::ABSL_GUARDED_BY

(

mu

)

ABSL_GUARDED_BY() [17/21]

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

(

mu

)

ABSL_GUARDED_BY() [18/21]

std::uint64_t next_outgoing_message_id a11::net::ChannelWireStream::State::ABSL_GUARDED_BY

(

mu

)

ABSL_GUARDED_BY() [19/21]

std::shared_ptr< thread::PermanentEvent > changed a11::net::ChannelWireStream::State::ABSL_GUARDED_BY

(

mu

)

ABSL_GUARDED_BY() [20/21]

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

(

mu

)

ABSL_GUARDED_BY() [21/21]

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

pure virtual

Member Data Documentation

channel

const std::shared_ptr<internal::BinaryChannel> a11::net::ChannelWireStream::State::channel

drain_future

const a11::Task a11::net::ChannelWireStream::State::drain_future

drain_promise

const std::shared_ptr<a11::Promise<a11::Unit> > a11::net::ChannelWireStream::State::drain_promise

framing

const ChannelFramingOptions a11::net::ChannelWireStream::State::framing

id

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

mu

thread::Mutex a11::net::ChannelWireStream::State::mu

mutable

open_operation

const OpenOperation a11::net::ChannelWireStream::State::open_operation

options

const WireStreamOptions a11::net::ChannelWireStream::State::options

reassembler

ByteReassembler a11::net::ChannelWireStream::State::reassembler

role

const ChannelEndpointRole a11::net::ChannelWireStream::State::role

startup_future

const a11::Task a11::net::ChannelWireStream::State::startup_future

startup_promise

const std::shared_ptr<a11::Promise<a11::Unit> > a11::net::ChannelWireStream::State::startup_promise

---

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

• cpp/a11/net/channel_wire_stream.cc