| 281 | } |
| 282 | |
| 283 | void local_server::start_unlock(uint32_t _lc_count) { |
| 284 | acceptor_->async_accept([weak_self = weak_from_this(), _lc_count](auto const& _ec, auto _socket) { |
| 285 | if (auto self = weak_self.lock(); self) { |
| 286 | self->accept_cbk(_ec, std::move(_socket), _lc_count); |
| 287 | } |
| 288 | }); |
| 289 | } |
| 290 | |
| 291 | local_server::tmp_connection::tmp_connection(std::shared_ptr<local_socket> _socket, bool _is_router, uint32_t _lc_count, |
| 292 | std::weak_ptr<local_server> _parent, std::shared_ptr<configuration> _configuration) : |
no test coverage detected