1 #ifndef PROTON_IO_CONNECTION_ENGINE_HPP
2 #define PROTON_IO_CONNECTION_ENGINE_HPP
25 #include "../internal/config.hpp"
26 #include "../connection.hpp"
27 #include "../connection_options.hpp"
28 #include "../error.hpp"
29 #include "../error_condition.hpp"
30 #include "../internal/export.hpp"
31 #include "../internal/pn_unique_ptr.hpp"
32 #include "../transport.hpp"
33 #include "../types.hpp"
39 struct pn_collector_t;
107 PN_CPP_EXTERN ~connection_engine();
133 PN_CPP_EXTERN
void read_done(
size_t n);
137 PN_CPP_EXTERN
void read_close();
147 PN_CPP_EXTERN
void write_done(
size_t n);
151 PN_CPP_EXTERN
void write_close();
178 PN_CPP_EXTERN
bool dispatch();
190 connection_engine(
const connection_engine&);
191 connection_engine& operator=(
const connection_engine&);
194 proton::proton_handler* handler_;
197 proton::internal::pn_ptr<pn_collector_t> collector_;
204 #endif // PROTON_IO_CONNECTION_ENGINE_HPP
size_t size
Number of bytes in the buffer.
Definition: connection_engine.hpp:62
A top-level container of connections, sessions, senders, and receivers.
Definition: container.hpp:59
Experimental - Generate default link names that are unique within a container.
Definition: link_namer.hpp:33
Experimental - Pointer to a const memory region with a size.
Definition: connection_engine.hpp:60
A connection to a remote AMQP peer.
Definition: connection.hpp:48
Options for creating a connection.
Definition: connection_options.hpp:67
mutable_buffer(char *data_=0, size_t size_=0)
Construct a buffer starting at data_ with size_ bytes.
Definition: connection_engine.hpp:56
Experimental - A serial execution context.
Definition: event_loop.hpp:56
const char * data
Beginning of the buffered data.
Definition: connection_engine.hpp:61
char * data
Beginning of the buffered data.
Definition: connection_engine.hpp:52
Experimental - An AMQP protocol engine for a single connection.
Definition: connection_engine.hpp:100
size_t size
Number of bytes in the buffer.
Definition: connection_engine.hpp:53
const_buffer(const char *data_=0, size_t size_=0)
Construct a buffer starting at data_ with size_ bytes.
Definition: connection_engine.hpp:65
A network channel supporting an AMQP connection.
Definition: transport.hpp:42
Experimental - Pointer to a mutable memory region with a size.
Definition: connection_engine.hpp:51
Describes an endpoint error state.
Definition: error_condition.hpp:37