| 307 | } |
| 308 | |
| 309 | void local_endpoint::receive_unlock() { |
| 310 | socket_->async_receive( |
| 311 | receive_buffer_->buffer(), |
| 312 | [weak_self = weak_from_this(), |
| 313 | buffer_cp = receive_buffer_ /*ensure memory remains alive until the cbk is invoked*/](auto const& _ec, size_t _bytes) { |
| 314 | if (auto self = weak_self.lock(); self) { |
| 315 | self->receive_cbk(_ec, _bytes); |
| 316 | } |
| 317 | }); |
| 318 | } |
| 319 | void local_endpoint::send_unlock() { |
| 320 | if (is_started_ && state_ == state_e::CONNECTED && !is_sending_) { |
| 321 | send_buffer_unlock(); |
nothing calls this directly
no test coverage detected