| 583 | } |
| 584 | |
| 585 | void local_endpoint::trigger_error() { |
| 586 | // post to uphold the interface contract of the local_endpoint: |
| 587 | // No public API call will lead to a callback invocation |
| 588 | boost::asio::post(io_, [weak_self = weak_from_this()] { |
| 589 | if (auto self = weak_self.lock(); self) { |
| 590 | self->escalate(); |
| 591 | } |
| 592 | }); |
| 593 | } |
| 594 | |
| 595 | void local_endpoint::register_cleanup_handler(const cleanup_handler_t& _handler) { |
| 596 | std::scoped_lock const lock{mutex_}; |
no test coverage detected