Flow 1.0.1
Flow project: Full implementation reference.
flow::net_flow::Peer_socket Member List

This is the complete list of members for flow::net_flow::Peer_socket, including all inherited members.

bytes_blocks_str(size_t bytes) constflow::net_flow::Peer_socketprivate
close_abruptly(Error_code *err_code=0)flow::net_flow::Peer_socket
Congestion_control_classicflow::net_flow::Peer_socketfriend
Congestion_control_classic_dataflow::net_flow::Peer_socketfriend
Congestion_control_classic_with_bandwidth_estflow::net_flow::Peer_socketfriend
Const_ptr typedefflow::util::Shared_ptr_alias_holder< boost::shared_ptr< Peer_socket > >
const_ptr_cast(const From_ptr &ptr_to_cast)flow::util::Shared_ptr_alias_holder< boost::shared_ptr< Peer_socket > >static
disconnect_cause() constflow::net_flow::Peer_socket
Drop_timerflow::net_flow::Peer_socketfriend
Drop_timer_ptr typedefflow::net_flow::Peer_socketprivate
dynamic_const_ptr_cast(const From_ptr &ptr_to_cast)flow::util::Shared_ptr_alias_holder< boost::shared_ptr< Peer_socket > >static
dynamic_ptr_cast(const From_ptr &ptr_to_cast)flow::util::Shared_ptr_alias_holder< boost::shared_ptr< Peer_socket > >static
ensure_open(Error_code *err_code) constflow::net_flow::Peer_socketprivate
get_connect_metadata(const boost::asio::mutable_buffer &buffer, Error_code *err_code=0) constflow::net_flow::Peer_socket
get_log_component() constflow::log::Log_context
get_logger() constflow::log::Log_context
info() constflow::net_flow::Peer_socket
Int_state enum nameflow::net_flow::Peer_socketprivate
local_port() constflow::net_flow::Peer_socket
Lock_guard typedefflow::net_flow::Peer_socketprivate
Log_context(Logger *logger=0)flow::log::Log_contextexplicit
Log_context(Logger *logger, Component_payload component_payload)flow::log::Log_contextexplicit
Log_context(const Log_context &src)flow::log::Log_contextexplicit
Log_context(Log_context &&src)flow::log::Log_context
m_active_connectflow::net_flow::Peer_socketprivate
m_componentflow::log::Log_contextprivate
m_connection_timeout_scheduled_taskflow::net_flow::Peer_socketprivate
m_disconnect_causeflow::net_flow::Peer_socketprivate
m_info_on_closeflow::net_flow::Peer_socketprivate
m_init_rexmit_countflow::net_flow::Peer_socketprivate
m_init_rexmit_scheduled_taskflow::net_flow::Peer_socketprivate
m_int_stateflow::net_flow::Peer_socketprivate
m_local_portflow::net_flow::Peer_socketprivate
m_loggerflow::log::Log_contextprivate
m_mutexflow::net_flow::Peer_socketmutableprivate
m_nodeflow::net_flow::Peer_socketprivate
m_open_sub_stateflow::net_flow::Peer_socketprivate
m_optsflow::net_flow::Peer_socketprivate
m_opts_mutexflow::net_flow::Peer_socketmutableprivate
m_originating_servflow::net_flow::Peer_socketprivate
m_rcv_acked_packetsflow::net_flow::Peer_socketprivate
m_rcv_bufflow::net_flow::Peer_socketprivate
m_rcv_delayed_ack_timerflow::net_flow::Peer_socketprivate
m_rcv_in_rcv_wnd_recoveryflow::net_flow::Peer_socketprivate
m_rcv_init_seq_numflow::net_flow::Peer_socketprivate
m_rcv_last_sent_rcv_wndflow::net_flow::Peer_socketprivate
m_rcv_next_seq_numflow::net_flow::Peer_socketprivate
m_rcv_packets_with_gapsflow::net_flow::Peer_socketprivate
m_rcv_pending_acksflow::net_flow::Peer_socketprivate
m_rcv_pending_acks_size_at_recv_handler_startflow::net_flow::Peer_socketprivate
m_rcv_reassembly_q_data_sizeflow::net_flow::Peer_socketprivate
m_rcv_statsflow::net_flow::Peer_socketprivate
m_rcv_syn_rcvd_data_cumulative_sizeflow::net_flow::Peer_socketprivate
m_rcv_syn_rcvd_data_qflow::net_flow::Peer_socketprivate
m_rcv_wnd_recovery_scheduled_taskflow::net_flow::Peer_socketprivate
m_rcv_wnd_recovery_start_timeflow::net_flow::Peer_socketprivate
m_remote_endpointflow::net_flow::Peer_socketprivate
m_round_trip_time_varianceflow::net_flow::Peer_socketprivate
m_security_tokenflow::net_flow::Peer_socketprivate
m_serialized_metadataflow::net_flow::Peer_socketprivate
m_snd_bandwidth_estimatorflow::net_flow::Peer_socketprivate
m_snd_bufflow::net_flow::Peer_socketprivate
m_snd_cong_ctlflow::net_flow::Peer_socketprivate
m_snd_drop_timeoutflow::net_flow::Peer_socketprivate
m_snd_drop_timerflow::net_flow::Peer_socketprivate
m_snd_flying_bytesflow::net_flow::Peer_socketprivate
m_snd_flying_pkts_by_sent_whenflow::net_flow::Peer_socketprivate
m_snd_flying_pkts_by_seq_numflow::net_flow::Peer_socketprivate
m_snd_init_seq_numflow::net_flow::Peer_socketprivate
m_snd_last_data_sent_whenflow::net_flow::Peer_socketprivate
m_snd_last_loss_event_whenflow::net_flow::Peer_socketprivate
m_snd_last_order_numflow::net_flow::Peer_socketprivate
m_snd_next_seq_numflow::net_flow::Peer_socketprivate
m_snd_pacing_dataflow::net_flow::Peer_socketprivate
m_snd_pending_rcv_wndflow::net_flow::Peer_socketprivate
m_snd_remote_rcv_wndflow::net_flow::Peer_socketprivate
m_snd_rexmit_qflow::net_flow::Peer_socketprivate
m_snd_rexmit_q_sizeflow::net_flow::Peer_socketprivate
m_snd_smoothed_round_trip_timeflow::net_flow::Peer_socketprivate
m_snd_statsflow::net_flow::Peer_socketprivate
m_snd_temp_pkts_marked_to_dropflow::net_flow::Peer_socketprivate
m_stateflow::net_flow::Peer_socketprivate
max_block_size() constflow::net_flow::Peer_socket
max_block_size_multiple(const size_t &opt_val_ref, const unsigned int *inflate_pct_val_ptr=0) constflow::net_flow::Peer_socketprivate
Mutex typedefflow::net_flow::Peer_socketprivate
Nodeflow::net_flow::Peer_socketfriend
node() constflow::net_flow::Peer_socket
node_receive(const Function< size_t()> &rcv_buf_consume_func, Error_code *err_code)flow::net_flow::Peer_socketprivate
node_send(const Function< size_t(size_t max_data_size)> &snd_buf_feed_func, Error_code *err_code)flow::net_flow::Peer_socketprivate
node_sync_receive(const Function< size_t()> &rcv_buf_consume_func_or_empty, const Fine_time_pt &wait_until, Error_code *err_code)flow::net_flow::Peer_socketprivate
node_sync_send(const Function< size_t(size_t max_data_size)> &snd_buf_feed_func_or_empty, const Fine_time_pt &wait_until, Error_code *err_code)flow::net_flow::Peer_socketprivate
Open_sub_state enum nameflow::net_flow::Peer_socket
operator<<flow::net_flow::Peer_socketfriend
operator<<(std::ostream &os, const Peer_socket *sock)flow::net_flow::Peer_socketrelated
operator=(const Log_context &src)flow::log::Log_context
operator=(Log_context &&src)flow::log::Log_context
opt(const Opt_type &opt_val_ref) constflow::net_flow::Peer_socketprivate
options() constflow::net_flow::Peer_socket
Options_lock typedefflow::net_flow::Peer_socketprivate
Options_mutex typedefflow::net_flow::Peer_socketprivate
order_num_t typedefflow::net_flow::Peer_socketprivate
Peer_socket(log::Logger *logger_ptr, util::Task_engine *task_engine, const Peer_socket_options &opts)flow::net_flow::Peer_socketexplicitprotected
Ptr typedefflow::util::Shared_ptr_alias_holder< boost::shared_ptr< Peer_socket > >
ptr_cast(const From_ptr &ptr_to_cast)flow::util::Shared_ptr_alias_holder< boost::shared_ptr< Peer_socket > >static
Rcv_syn_rcvd_data_q typedefflow::net_flow::Peer_socketprivate
receive(const Mutable_buffer_sequence &target, Error_code *err_code=0)flow::net_flow::Peer_socket
Recvd_pkt_const_iter typedefflow::net_flow::Peer_socketprivate
Recvd_pkt_iter typedefflow::net_flow::Peer_socketprivate
Recvd_pkt_map typedefflow::net_flow::Peer_socketprivate
remote_endpoint() constflow::net_flow::Peer_socket
rexmit_on() constflow::net_flow::Peer_socketprivate
security_token_t typedefflow::net_flow::Peer_socketprivate
send(const Const_buffer_sequence &data, Error_code *err_code=0)flow::net_flow::Peer_socket
Send_bandwidth_estimatorflow::net_flow::Peer_socketfriend
Sent_pkt_by_sent_when_map typedefflow::net_flow::Peer_socketprivate
Sent_pkt_by_seq_num_map typedefflow::net_flow::Peer_socketprivate
Sent_pkt_ordered_by_seq_const_iter typedefflow::net_flow::Peer_socketprivate
Sent_pkt_ordered_by_seq_iter typedefflow::net_flow::Peer_socketprivate
Sent_pkt_ordered_by_when_const_iter typedefflow::net_flow::Peer_socketprivate
Sent_pkt_ordered_by_when_iter typedefflow::net_flow::Peer_socketprivate
Server_socketflow::net_flow::Peer_socketfriend
set_options(const Peer_socket_options &opts, Error_code *err_code=0)flow::net_flow::Peer_socket
state(Open_sub_state *open_sub_state=0) constflow::net_flow::Peer_socket
State enum nameflow::net_flow::Peer_socket
swap(Log_context &other)flow::log::Log_context
sync_receive(const Mutable_buffer_sequence &target, const boost::chrono::duration< Rep, Period > &max_wait, Error_code *err_code=0)flow::net_flow::Peer_socket
sync_receive(const boost::asio::null_buffers &, const boost::chrono::duration< Rep, Period > &max_wait, Error_code *err_code=0)flow::net_flow::Peer_socket
sync_receive(const Mutable_buffer_sequence &target, Error_code *err_code=0)flow::net_flow::Peer_socket
sync_receive(const boost::asio::null_buffers &, Error_code *err_code=0)flow::net_flow::Peer_socket
sync_receive_impl(const Mutable_buffer_sequence &target, const Fine_time_pt &wait_until, Error_code *err_code)flow::net_flow::Peer_socketprivate
sync_receive_reactor_pattern_impl(const Fine_time_pt &wait_until, Error_code *err_code)flow::net_flow::Peer_socketprivate
sync_send(const Const_buffer_sequence &data, const boost::chrono::duration< Rep, Period > &max_wait, Error_code *err_code=0)flow::net_flow::Peer_socket
sync_send(const boost::asio::null_buffers &, const boost::chrono::duration< Rep, Period > &max_wait, Error_code *err_code=0)flow::net_flow::Peer_socket
sync_send(const Const_buffer_sequence &data, Error_code *err_code=0)flow::net_flow::Peer_socket
sync_send(const boost::asio::null_buffers &, Error_code *err_code=0)flow::net_flow::Peer_socket
sync_send_impl(const Const_buffer_sequence &data, const Fine_time_pt &wait_until, Error_code *err_code)flow::net_flow::Peer_socketprivate
sync_send_reactor_pattern_impl(const Fine_time_pt &wait_until, Error_code *err_code)flow::net_flow::Peer_socketprivate
~Null_interface()=0flow::util::Null_interfacepure virtual
~Peer_socket() overrideflow::net_flow::Peer_socket