Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
8 changes: 4 additions & 4 deletions implementation/routing/src/routing_manager_base.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -263,7 +263,7 @@ void routing_manager_base::stop_offer_service(client_t _client, service_t _servi
for (auto& e : events) {
if (e.second->is_set()) {
VSOMEIP_INFO << "rmb::" << __func__ << " unsetting payload for [" << std::hex << std::setfill('0') << std::setw(4) << _service
<< "." << _instance << "." << e.first;
<< "." << _instance << "." << e.first << "]";
}
e.second->unset_payload();
e.second->clear_subscribers();
Expand Down Expand Up @@ -360,7 +360,7 @@ void routing_manager_base::register_event(client_t _client, service_t _service,
// don't cache payload for non-fields
if (its_event->is_set()) {
VSOMEIP_INFO << "rmb::" << __func__ << " unsetting payload for [" << std::hex << std::setfill('0') << std::setw(4)
<< _service << "." << _instance << "." << its_event;
<< _service << "." << _instance << "." << its_event << "]";
}
its_event->unset_payload(true);
}
Expand Down Expand Up @@ -879,7 +879,7 @@ void routing_manager_base::unset_all_eventpayloads(service_t _service, instance_
for (const auto& e : its_events) {
if (e->is_set()) {
VSOMEIP_INFO << "rmb::" << __func__ << " unsetting payload for [" << std::hex << std::setfill('0') << std::setw(4) << _service
<< "." << _instance << "." << e->get_event();
<< "." << _instance << "." << e->get_event() << "]";
}
e->unset_payload(true);
}
Expand All @@ -904,7 +904,7 @@ void routing_manager_base::unset_all_eventpayloads(service_t _service, instance_
for (const auto& e : its_events) {
if (e->is_set()) {
VSOMEIP_INFO << "rmb::" << __func__ << " unsetting payload for [" << std::hex << std::setfill('0') << std::setw(4) << _service
<< "." << _instance << "." << e->get_event();
<< "." << _instance << "." << e->get_event() << "]";
}
e->unset_payload(true);
}
Expand Down
2 changes: 1 addition & 1 deletion implementation/routing/src/routing_manager_client.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -2200,7 +2200,7 @@ void routing_manager_client::on_stop_offer_service(service_t _service, instance_
for (auto& e : events) {
if (e.second->is_set()) {
VSOMEIP_INFO << "rmc::" << __func__ << " unsetting payload for [" << std::hex << std::setfill('0') << std::setw(4) << _service
<< "." << _instance << "." << e.first;
<< "." << _instance << "." << e.first << "]";
}
e.second->unset_payload();
}
Expand Down
10 changes: 5 additions & 5 deletions implementation/routing/src/routing_manager_impl.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -598,7 +598,7 @@ void routing_manager_impl::release_service(client_t _client, service_t _service,
for (const auto& e : its_events) {
if (e->is_set()) {
VSOMEIP_INFO << "rmi::" << __func__ << " unsetting payload for [" << std::hex << std::setfill('0')
<< std::setw(4) << _service << "." << _instance << "." << e->get_event();
<< std::setw(4) << _service << "." << _instance << "." << e->get_event() << "]";
}
e->unset_payload(true);
}
Expand Down Expand Up @@ -2281,7 +2281,7 @@ void routing_manager_impl::del_routing_info(service_t _service, instance_t _inst
for (const auto& e : its_events) {
if (e->is_set()) {
VSOMEIP_INFO << "rmi::" << __func__ << " unsetting payload for [" << std::hex << std::setfill('0') << std::setw(4) << _service
<< "." << _instance << "." << e->get_event();
<< "." << _instance << "." << e->get_event() << "]";
}
e->unset_payload(true);
}
Expand Down Expand Up @@ -2901,7 +2901,7 @@ std::chrono::steady_clock::time_point routing_manager_impl::expire_subscriptions
if (!has_remote_subscriber && its_event->is_shadow()) {
if (its_event->is_set()) {
VSOMEIP_INFO << "rmi::" << __func__ << " unsetting payload for [" << std::hex << std::setfill('0')
<< std::setw(4) << its_service << "." << its_instance << "." << its_event->get_event();
<< std::setw(4) << its_service << "." << its_instance << "." << its_event->get_event() << "]";
}
its_event->unset_payload();
}
Expand Down Expand Up @@ -3781,7 +3781,7 @@ void routing_manager_impl::clear_targets_and_pending_sub_from_eventgroups(servic
for (const auto& e : its_events) {
if (e->is_set()) {
VSOMEIP_INFO << "rmi::" << __func__ << " unsetting payload for [" << std::hex << std::setfill('0') << std::setw(4) << _service
<< "." << _instance << "." << e->get_event();
<< "." << _instance << "." << e->get_event() << "]";
}
e->unset_payload(true);
}
Expand Down Expand Up @@ -4003,7 +4003,7 @@ void routing_manager_impl::on_unsubscribe_ack(client_t _client, service_t _servi
if (!has_remote_subscriber && its_event->is_shadow()) {
if (its_event->is_set()) {
VSOMEIP_INFO << "rmi::" << __func__ << " unsetting payload for [" << std::hex << std::setfill('0')
<< std::setw(4) << _service << "." << _instance << "." << its_event->get_event();
<< std::setw(4) << _service << "." << _instance << "." << its_event->get_event() << "]";
}
its_event->unset_payload();
}
Expand Down
Loading