mm::comm::spoe::SpoeConnection::Impl Struct Reference

Collaboration diagram for mm::comm::spoe::SpoeConnection::Impl:

Public Member Functions
void	closeLocked ()
ConnectionError	closedError (std::string message)
std::expected< std::optional< Frame >, std::string >	takeFrame ()

Public Attributes
asio::io_context	io
tcp::socket	socket {io}
std::mutex	mutex
std::atomic< bool >	open {false}
std::atomic< uint64_t >	discarded {0}
std::string	peer
uint16_t	nextSequenceId = 1
std::vector< uint8_t >	received

Member Function Documentation

closedError()

ConnectionError mm::comm::spoe::SpoeConnection::Impl::closedError ( std::string  message )

inline

closeLocked()

void mm::comm::spoe::SpoeConnection::Impl::closeLocked ( )

inline

takeFrame()

std::expected< std::optional< Frame >, std::string > mm::comm::spoe::SpoeConnection::Impl::takeFrame ( )

inline

Member Data Documentation

discarded

std::atomic<uint64_t> mm::comm::spoe::SpoeConnection::Impl::discarded {0}

io

asio::io_context mm::comm::spoe::SpoeConnection::Impl::io

mutex

std::mutex mm::comm::spoe::SpoeConnection::Impl::mutex

nextSequenceId

uint16_t mm::comm::spoe::SpoeConnection::Impl::nextSequenceId = 1

open

std::atomic<bool> mm::comm::spoe::SpoeConnection::Impl::open {false}

peer

std::string mm::comm::spoe::SpoeConnection::Impl::peer

received

std::vector<uint8_t> mm::comm::spoe::SpoeConnection::Impl::received

socket

tcp::socket mm::comm::spoe::SpoeConnection::Impl::socket {io}

---

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

• libs/comm/spoe_connection.cc