| 71 | } |
| 72 | |
| 73 | void local_socket_uds_impl::async_connect(connect_handler _handler) { |
| 74 | std::unique_lock lock{socket_mtx_}; |
| 75 | if (socket_->is_open()) { |
| 76 | socket_->async_connect(peer_endpoint_, std::move(_handler)); |
| 77 | } else { |
| 78 | boost::asio::post(io_context_, [h = std::move(_handler)] { h(boost::asio::error::fault); }); |
| 79 | } |
| 80 | } |
| 81 | |
| 82 | void local_socket_uds_impl::async_receive(boost::asio::mutable_buffer _buffer, read_handler _r_handler) { |
| 83 | std::unique_lock lock{socket_mtx_}; |
no test coverage detected