bytes_blocks_str(size_t bytes) const | flow::net_flow::Peer_socket | private |
close_abruptly(Error_code *err_code=0) | flow::net_flow::Peer_socket | |
Congestion_control_classic | flow::net_flow::Peer_socket | friend |
Congestion_control_classic_data | flow::net_flow::Peer_socket | friend |
Congestion_control_classic_with_bandwidth_est | flow::net_flow::Peer_socket | friend |
Const_ptr typedef | flow::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() const | flow::net_flow::Peer_socket | |
Drop_timer | flow::net_flow::Peer_socket | friend |
Drop_timer_ptr typedef | flow::net_flow::Peer_socket | private |
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) const | flow::net_flow::Peer_socket | private |
get_connect_metadata(const boost::asio::mutable_buffer &buffer, Error_code *err_code=0) const | flow::net_flow::Peer_socket | |
get_log_component() const | flow::log::Log_context | |
get_logger() const | flow::log::Log_context | |
info() const | flow::net_flow::Peer_socket | |
Int_state enum name | flow::net_flow::Peer_socket | private |
local_port() const | flow::net_flow::Peer_socket | |
Lock_guard typedef | flow::net_flow::Peer_socket | private |
Log_context(Logger *logger=0) | flow::log::Log_context | explicit |
Log_context(Logger *logger, Component_payload component_payload) | flow::log::Log_context | explicit |
Log_context(const Log_context &src) | flow::log::Log_context | explicit |
Log_context(Log_context &&src) | flow::log::Log_context | |
m_active_connect | flow::net_flow::Peer_socket | private |
m_component | flow::log::Log_context | private |
m_connection_timeout_scheduled_task | flow::net_flow::Peer_socket | private |
m_disconnect_cause | flow::net_flow::Peer_socket | private |
m_info_on_close | flow::net_flow::Peer_socket | private |
m_init_rexmit_count | flow::net_flow::Peer_socket | private |
m_init_rexmit_scheduled_task | flow::net_flow::Peer_socket | private |
m_int_state | flow::net_flow::Peer_socket | private |
m_local_port | flow::net_flow::Peer_socket | private |
m_logger | flow::log::Log_context | private |
m_mutex | flow::net_flow::Peer_socket | mutableprivate |
m_node | flow::net_flow::Peer_socket | private |
m_open_sub_state | flow::net_flow::Peer_socket | private |
m_opts | flow::net_flow::Peer_socket | private |
m_opts_mutex | flow::net_flow::Peer_socket | mutableprivate |
m_originating_serv | flow::net_flow::Peer_socket | private |
m_rcv_acked_packets | flow::net_flow::Peer_socket | private |
m_rcv_buf | flow::net_flow::Peer_socket | private |
m_rcv_delayed_ack_timer | flow::net_flow::Peer_socket | private |
m_rcv_in_rcv_wnd_recovery | flow::net_flow::Peer_socket | private |
m_rcv_init_seq_num | flow::net_flow::Peer_socket | private |
m_rcv_last_sent_rcv_wnd | flow::net_flow::Peer_socket | private |
m_rcv_next_seq_num | flow::net_flow::Peer_socket | private |
m_rcv_packets_with_gaps | flow::net_flow::Peer_socket | private |
m_rcv_pending_acks | flow::net_flow::Peer_socket | private |
m_rcv_pending_acks_size_at_recv_handler_start | flow::net_flow::Peer_socket | private |
m_rcv_reassembly_q_data_size | flow::net_flow::Peer_socket | private |
m_rcv_stats | flow::net_flow::Peer_socket | private |
m_rcv_syn_rcvd_data_cumulative_size | flow::net_flow::Peer_socket | private |
m_rcv_syn_rcvd_data_q | flow::net_flow::Peer_socket | private |
m_rcv_wnd_recovery_scheduled_task | flow::net_flow::Peer_socket | private |
m_rcv_wnd_recovery_start_time | flow::net_flow::Peer_socket | private |
m_remote_endpoint | flow::net_flow::Peer_socket | private |
m_round_trip_time_variance | flow::net_flow::Peer_socket | private |
m_security_token | flow::net_flow::Peer_socket | private |
m_serialized_metadata | flow::net_flow::Peer_socket | private |
m_snd_bandwidth_estimator | flow::net_flow::Peer_socket | private |
m_snd_buf | flow::net_flow::Peer_socket | private |
m_snd_cong_ctl | flow::net_flow::Peer_socket | private |
m_snd_drop_timeout | flow::net_flow::Peer_socket | private |
m_snd_drop_timer | flow::net_flow::Peer_socket | private |
m_snd_flying_bytes | flow::net_flow::Peer_socket | private |
m_snd_flying_pkts_by_sent_when | flow::net_flow::Peer_socket | private |
m_snd_flying_pkts_by_seq_num | flow::net_flow::Peer_socket | private |
m_snd_init_seq_num | flow::net_flow::Peer_socket | private |
m_snd_last_data_sent_when | flow::net_flow::Peer_socket | private |
m_snd_last_loss_event_when | flow::net_flow::Peer_socket | private |
m_snd_last_order_num | flow::net_flow::Peer_socket | private |
m_snd_next_seq_num | flow::net_flow::Peer_socket | private |
m_snd_pacing_data | flow::net_flow::Peer_socket | private |
m_snd_pending_rcv_wnd | flow::net_flow::Peer_socket | private |
m_snd_remote_rcv_wnd | flow::net_flow::Peer_socket | private |
m_snd_rexmit_q | flow::net_flow::Peer_socket | private |
m_snd_rexmit_q_size | flow::net_flow::Peer_socket | private |
m_snd_smoothed_round_trip_time | flow::net_flow::Peer_socket | private |
m_snd_stats | flow::net_flow::Peer_socket | private |
m_snd_temp_pkts_marked_to_drop | flow::net_flow::Peer_socket | private |
m_state | flow::net_flow::Peer_socket | private |
max_block_size() const | flow::net_flow::Peer_socket | |
max_block_size_multiple(const size_t &opt_val_ref, const unsigned int *inflate_pct_val_ptr=0) const | flow::net_flow::Peer_socket | private |
Mutex typedef | flow::net_flow::Peer_socket | private |
Node | flow::net_flow::Peer_socket | friend |
node() const | flow::net_flow::Peer_socket | |
node_receive(const Function< size_t()> &rcv_buf_consume_func, Error_code *err_code) | flow::net_flow::Peer_socket | private |
node_send(const Function< size_t(size_t max_data_size)> &snd_buf_feed_func, Error_code *err_code) | flow::net_flow::Peer_socket | private |
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_socket | private |
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_socket | private |
Open_sub_state enum name | flow::net_flow::Peer_socket | |
operator<< | flow::net_flow::Peer_socket | friend |
operator<<(std::ostream &os, const Peer_socket *sock) | flow::net_flow::Peer_socket | related |
operator=(const Log_context &src) | flow::log::Log_context | |
operator=(Log_context &&src) | flow::log::Log_context | |
opt(const Opt_type &opt_val_ref) const | flow::net_flow::Peer_socket | private |
options() const | flow::net_flow::Peer_socket | |
Options_lock typedef | flow::net_flow::Peer_socket | private |
Options_mutex typedef | flow::net_flow::Peer_socket | private |
order_num_t typedef | flow::net_flow::Peer_socket | private |
Peer_socket(log::Logger *logger_ptr, util::Task_engine *task_engine, const Peer_socket_options &opts) | flow::net_flow::Peer_socket | explicitprotected |
Ptr typedef | flow::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 typedef | flow::net_flow::Peer_socket | private |
receive(const Mutable_buffer_sequence &target, Error_code *err_code=0) | flow::net_flow::Peer_socket | |
Recvd_pkt_const_iter typedef | flow::net_flow::Peer_socket | private |
Recvd_pkt_iter typedef | flow::net_flow::Peer_socket | private |
Recvd_pkt_map typedef | flow::net_flow::Peer_socket | private |
remote_endpoint() const | flow::net_flow::Peer_socket | |
rexmit_on() const | flow::net_flow::Peer_socket | private |
security_token_t typedef | flow::net_flow::Peer_socket | private |
send(const Const_buffer_sequence &data, Error_code *err_code=0) | flow::net_flow::Peer_socket | |
Send_bandwidth_estimator | flow::net_flow::Peer_socket | friend |
Sent_pkt_by_sent_when_map typedef | flow::net_flow::Peer_socket | private |
Sent_pkt_by_seq_num_map typedef | flow::net_flow::Peer_socket | private |
Sent_pkt_ordered_by_seq_const_iter typedef | flow::net_flow::Peer_socket | private |
Sent_pkt_ordered_by_seq_iter typedef | flow::net_flow::Peer_socket | private |
Sent_pkt_ordered_by_when_const_iter typedef | flow::net_flow::Peer_socket | private |
Sent_pkt_ordered_by_when_iter typedef | flow::net_flow::Peer_socket | private |
Server_socket | flow::net_flow::Peer_socket | friend |
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) const | flow::net_flow::Peer_socket | |
State enum name | flow::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_socket | private |
sync_receive_reactor_pattern_impl(const Fine_time_pt &wait_until, Error_code *err_code) | flow::net_flow::Peer_socket | private |
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_socket | private |
sync_send_reactor_pattern_impl(const Fine_time_pt &wait_until, Error_code *err_code) | flow::net_flow::Peer_socket | private |
~Null_interface()=0 | flow::util::Null_interface | pure virtual |
~Peer_socket() override | flow::net_flow::Peer_socket | |