////////////////////////////////////////////////////////////////////////// class tcp_service_impl::connection //////////////////////////////////////////////////////////////////////////
| 462 | // class tcp_service_impl::connection |
| 463 | /////////////////////////////////////////////////////////////////////////////// |
| 464 | tcp_server_endpoint_impl::connection::connection(const std::weak_ptr<tcp_server_endpoint_impl>& _server, std::uint32_t _max_message_size, |
| 465 | std::uint32_t _recv_buffer_size_initial, std::uint32_t _buffer_shrink_threshold, |
| 466 | bool _use_magic_cookies, boost::asio::io_context& _io, |
| 467 | std::chrono::milliseconds _send_timeout) : |
| 468 | socket_(abstract_socket_factory::get()->create_tcp_socket(_io)), server_(_server), max_message_size_(_max_message_size), |
| 469 | recv_buffer_size_initial_(_recv_buffer_size_initial), recv_buffer_(_recv_buffer_size_initial, 0), recv_buffer_size_(0), |
| 470 | missing_capacity_(0), shrink_count_(0), buffer_shrink_threshold_(_buffer_shrink_threshold), remote_port_(0), |
| 471 | use_magic_cookies_(_use_magic_cookies), last_cookie_sent_(std::chrono::steady_clock::now() - std::chrono::seconds(11)), |
| 472 | send_timeout_(_send_timeout), send_timeout_warning_(_send_timeout / 2) { |
| 473 | if (auto its_server = _server.lock()) { |
| 474 | instance_name_ = its_server->instance_name_; |
| 475 | } else { |
| 476 | instance_name_ = ""; |
| 477 | } |
| 478 | } |
| 479 | |
| 480 | tcp_server_endpoint_impl::connection::~connection() { |
| 481 |
nothing calls this directly
no test coverage detected