| 3429 | } |
| 3430 | |
| 3431 | void routing_manager_impl::send_subscription(const client_t _offering_client, const service_t _service, const instance_t _instance, |
| 3432 | const eventgroup_t _eventgroup, const major_version_t _major, |
| 3433 | const std::set<client_t>& _clients, const remote_subscription_id_t _id) { |
| 3434 | { // service hosted by local client |
| 3435 | for (const auto its_client : _clients) { |
| 3436 | if (!stub_->send_subscribe(find_routing_endpoint(_offering_client), its_client, _service, _instance, _eventgroup, _major, |
| 3437 | ANY_EVENT, nullptr, _id)) { |
| 3438 | try { |
| 3439 | const auto its_callback = std::bind(&routing_manager_stub_host::on_subscribe_nack, |
| 3440 | std::dynamic_pointer_cast<routing_manager_stub_host>(shared_from_this()), |
| 3441 | its_client, _service, _instance, _eventgroup, true, _id); |
| 3442 | boost::asio::post(io_, its_callback); |
| 3443 | } catch (const std::exception& e) { |
| 3444 | VSOMEIP_ERROR_P << e.what(); |
| 3445 | } |
| 3446 | } |
| 3447 | } |
| 3448 | } |
| 3449 | } |
| 3450 | |
| 3451 | void routing_manager_impl::cleanup_server_endpoint(service_t _service, const std::shared_ptr<boardnet_endpoint>& _endpoint) { |
| 3452 | if (_endpoint) { |
nothing calls this directly
no test coverage detected