| 2105 | } |
| 2106 | |
| 2107 | void routing_manager_client::send_unsubscribe_ack(service_t _service, instance_t _instance, eventgroup_t _eventgroup, |
| 2108 | remote_subscription_id_t _id) { |
| 2109 | |
| 2110 | protocol::unsubscribe_ack_command its_command; |
| 2111 | its_command.set_client(get_client()); |
| 2112 | its_command.set_service(_service); |
| 2113 | its_command.set_instance(_instance); |
| 2114 | its_command.set_eventgroup(_eventgroup); |
| 2115 | its_command.set_pending_id(_id); |
| 2116 | |
| 2117 | std::vector<byte_t> its_buffer; |
| 2118 | its_command.serialize(its_buffer); |
| 2119 | |
| 2120 | std::scoped_lock its_sender_lock{sender_mutex_}; |
| 2121 | if (sender_) { |
| 2122 | sender_->send(&its_buffer[0], uint32_t(its_buffer.size())); |
| 2123 | } else { |
| 2124 | VSOMEIP_ERROR_P << "Failed due to a missing sender"; |
| 2125 | } |
| 2126 | } |
| 2127 | |
| 2128 | void routing_manager_client::resend_provided_event_registrations() { |
| 2129 | std::scoped_lock its_lock(pending_event_registrations_mutex_); |
nothing calls this directly
no test coverage detected