| 3449 | } |
| 3450 | |
| 3451 | void routing_manager_impl::cleanup_server_endpoint(service_t _service, const std::shared_ptr<boardnet_endpoint>& _endpoint) { |
| 3452 | if (_endpoint) { |
| 3453 | // Clear service_instances_, check whether any service still |
| 3454 | // uses this endpoint and clear server endpoint if no service |
| 3455 | // remains using it |
| 3456 | if (ep_mgr_impl_->remove_instance(_service, _endpoint.get())) { |
| 3457 | if (ep_mgr_impl_->remove_server_endpoint(_endpoint->get_local_port(), _endpoint->is_reliable())) { |
| 3458 | // Stop endpoint (close socket) to release its async_handlers! |
| 3459 | _endpoint->stop(false); |
| 3460 | } |
| 3461 | } |
| 3462 | } |
| 3463 | } |
| 3464 | |
| 3465 | pending_remote_offer_id_t routing_manager_impl::pending_remote_offer_add(service_t _service, instance_t _instance) { |
| 3466 | std::scoped_lock its_lock{pending_remote_offers_mutex_}; |
nothing calls this directly
no test coverage detected