Inheritance diagram for seastar::rpc::server::connection:

Public Member Functions
	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

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 ()

const server &	get_server () const

future	deregister_this_stream ()

future	abort_all_streams ()

size_t	outgoing_queue_length () const noexcept

void	set_socket (connected_socket &&fd)

future	send_negotiation_frame (feature_map features)

bool	error () const noexcept

void	abort ()

future	stop () noexcept

future	stream_receive (circular_buffer< foreign_ptr< std::unique_ptr< rcv_buf >>> &bufs)

future	close_sink ()

bool	sink_closed () const noexcept

future	close_source ()

connection_id	get_connection_id () const noexcept

stats &	get_stats_internal () noexcept

xshard_connection_ptr	get_stream (connection_id id) const

void	register_stream (connection_id id, xshard_connection_ptr c)

const logger &	get_logger () const noexcept

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)

void	suspend_for_testing (promise<> &p)

shared_ptr< connection >	shared_from_this () noexcept

shared_ptr< const connection >	shared_from_this () const noexcept

long	use_count () const noexcept

Protected Member Functions
void	withdraw (outgoing_entry::container_t::iterator it, std::exception_ptr ex=nullptr)

void	set_negotiated () noexcept

bool	is_stream () const noexcept

snd_buf	compress (snd_buf buf)

future	send_buffer (snd_buf buf)

future	send (snd_buf buf, std::optional< rpc_clock_type::time_point > timeout={}, cancellable *cancel=nullptr)

future	send_entry (outgoing_entry &d)

future	stop_send_loop (std::exception_ptr ex)

future< std::optional< rcv_buf > >	read_stream_frame_compressed (input_stream< char > &in)

bool	stream_check_twoway_closed () const noexcept

future	stream_close ()

future	stream_process_incoming (rcv_buf &&)

future	handle_stream_frame ()

Protected Attributes
connected_socket	_fd

input_stream< char >	_read_buf

output_stream< char >	_write_buf

bool	_error = false

bool	_connected = false

std::optional< shared_promise<> >	_negotiated = shared_promise<>()

promise	_stopped

stats	_stats

const logger &	_logger

void *	_serializer

future	_outgoing_queue_ready = _negotiated->get_shared_future()

outgoing_entry::container_t	_outgoing_queue

size_t	_outgoing_queue_size = 0

std::unique_ptr< compressor >	_compressor

bool	_propagate_timeout = false

bool	_timeout_negotiated = false

bool	_is_stream = false

connection_id	_id = invalid_connection_id

std::unordered_map< connection_id, xshard_connection_ptr >	_streams

queue< rcv_buf >	_stream_queue = queue<rcv_buf>(max_queued_stream_buffers)

semaphore	_stream_sem = semaphore(max_stream_buffers_memory)

bool	_sink_closed = true

bool	_source_closed = true

future< bool >	_sink_closed_future = make_ready_future<bool>(false)

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

seastar/rpc/rpc.hh

Public Member Functions

Protected Member Functions

Protected Attributes