|
| connection (server &s, connected_socket &&fd, socket_address &&addr, const logger &l, void *seralizer, connection_id id) |
|
future | process () |
|
future | respond (int64_t msg_id, snd_buf &&data, std::optional< rpc_clock_type::time_point > timeout) |
|
client_info & | info () |
|
const client_info & | info () const |
|
stats | get_stats () const |
|
stats & | get_stats_internal () |
|
socket_address | peer_address () const override |
|
future< resource_permit > | wait_for_resources (size_t memory_consumed, std::optional< rpc_clock_type::time_point > timeout) |
|
size_t | estimate_request_size (size_t serialized_size) |
|
size_t | max_request_size () const |
|
server & | get_server () |
|
future | deregister_this_stream () |
|
void | set_socket (connected_socket &&fd) |
|
future | send_negotiation_frame (feature_map features) |
|
future | send (snd_buf buf, std::optional< rpc_clock_type::time_point > timeout={}, cancellable *cancel=nullptr) |
|
bool | error () |
|
void | abort () |
|
future | stop () |
|
future | stream_receive (circular_buffer< foreign_ptr< std::unique_ptr< rcv_buf >>> &bufs) |
|
future | close_sink () |
|
bool | sink_closed () |
|
future | close_source () |
|
connection_id | get_connection_id () const |
|
xshard_connection_ptr | get_stream (connection_id id) const |
|
void | register_stream (connection_id id, xshard_connection_ptr c) |
|
const logger & | get_logger () const |
|
template<typename Serializer > |
Serializer & | serializer () |
|
template<typename FrameType > |
FrameType::return_type | read_frame (socket_address info, input_stream< char > &in) |
|
template<typename FrameType > |
FrameType::return_type | read_frame_compressed (socket_address info, std::unique_ptr< compressor > &compressor, input_stream< char > &in) |
|
shared_ptr< connection > | shared_from_this () |
|
shared_ptr< const connection > | shared_from_this () const |
|
long | use_count () const noexcept |
|