A container of senders and receivers. More...
#include <session.hpp>
Public Member Functions | |
session () | |
bool | uninitialized () const |
True if the local end is uninitialized. | |
bool | active () const |
True if the local end is active. | |
bool | closed () const |
True if the local and remote ends are closed. | |
class error_condition | error () const |
Get the error condition of the remote endpoint. | |
void | open () |
Open the session. | |
void | open (const session_options &opts) |
void | close () |
Close the endpoint. | |
void | close (const error_condition &) |
Close the endpoint with an error condition. | |
class container & | container () const |
Get the container for this session. | |
class connection | connection () const |
Get the connection this session belongs to. | |
sender | open_sender (const std::string &addr) |
Open a sender for `addr`. | |
sender | open_sender (const std::string &addr, const sender_options &opts) |
receiver | open_receiver (const std::string &addr) |
Open a receiver for `addr`. | |
receiver | open_receiver (const std::string &addr, const receiver_options &opts) |
size_t | incoming_bytes () const |
The number of incoming bytes currently buffered. | |
size_t | outgoing_bytes () const |
The number of outgoing bytes currently buffered. | |
sender_range | senders () const |
Return the senders on this session. | |
receiver_range | receivers () const |
Return the receivers on this session. |
A container of senders and receivers.
broker.cpp, and mt/broker.cpp.
void close | ( | const error_condition & | ) | [virtual] |
void open | ( | const session_options & | opts | ) |
Open the session.
void open | ( | ) |
Open the session.
receiver open_receiver | ( | const std::string & | addr, | |
const receiver_options & | opts | |||
) |
Open a receiver for `addr`.
sender open_sender | ( | const std::string & | addr, | |
const sender_options & | opts | |||
) |
Open a sender for `addr`.