summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorfynnwilliam <fynnwilliam@gmail.com>2022-06-25 23:28:47 -0400
committerfynnwilliam <fynnwilliam@gmail.com>2022-06-25 23:29:33 -0400
commit0c4d18be3faff0bfc1c8cfbbc26ad4037f3dac12 (patch)
treecef4ad4821ad3edcfa10ea1da3edf0e5308ba30a
parent98e9062094466a393b122440a323582fecf43b39 (diff)
downloadvSomeIP-0c4d18be3faff0bfc1c8cfbbc26ad4037f3dac12.tar.gz
Use reference to prevent copying
Since the variables are marked as const - we are not going to change them, we may also take them by ref. Which means we just want to see the variables. This improves the performance and also helps to generate minimal code.
-rw-r--r--implementation/compat/runtime/src/application_impl.cpp2
-rw-r--r--implementation/configuration/src/configuration_impl.cpp2
-rw-r--r--implementation/endpoints/src/endpoint_manager_base.cpp2
-rw-r--r--implementation/endpoints/src/endpoint_manager_impl.cpp10
-rw-r--r--implementation/endpoints/src/server_endpoint_impl.cpp2
-rw-r--r--implementation/routing/src/eventgroupinfo.cpp6
-rw-r--r--implementation/routing/src/remote_subscription.cpp2
-rw-r--r--implementation/routing/src/routing_manager_impl.cpp28
-rw-r--r--implementation/routing/src/routing_manager_proxy.cpp6
-rw-r--r--implementation/routing/src/routing_manager_stub.cpp4
-rw-r--r--implementation/runtime/src/application_impl.cpp2
-rw-r--r--implementation/security/src/policy.cpp8
-rw-r--r--implementation/security/src/security_impl.cpp28
-rwxr-xr-ximplementation/service_discovery/src/eventgroupentry_impl.cpp10
-rw-r--r--implementation/service_discovery/src/service_discovery_impl.cpp16
-rw-r--r--implementation/service_discovery/src/subscription.cpp2
-rw-r--r--test/client_id_tests/client_id_test_utility.cpp4
-rw-r--r--test/npdu_tests/npdu_test_service.cpp2
18 files changed, 68 insertions, 68 deletions
diff --git a/implementation/compat/runtime/src/application_impl.cpp b/implementation/compat/runtime/src/application_impl.cpp
index f1934e4..ce65136 100644
--- a/implementation/compat/runtime/src/application_impl.cpp
+++ b/implementation/compat/runtime/src/application_impl.cpp
@@ -638,7 +638,7 @@ application_impl::is_selective_event(
if (its_service != eventgroups_.end()) {
const auto its_instance = its_service->second.find(_instance);
if (its_instance != its_service->second.end()) {
- for (const auto eg : _eventgroups) {
+ for (const auto& eg : _eventgroups) {
const auto its_egrp = its_instance->second.find(eg);
if (its_egrp != its_instance->second.end()) {
is_selective = true;
diff --git a/implementation/configuration/src/configuration_impl.cpp b/implementation/configuration/src/configuration_impl.cpp
index 90f1a7b..0e9ca51 100644
--- a/implementation/configuration/src/configuration_impl.cpp
+++ b/implementation/configuration/src/configuration_impl.cpp
@@ -3972,7 +3972,7 @@ configuration_impl::load_overlay(const std::string &_name) {
its_input.insert(its_overlay);
read_data(its_input, its_elements, its_failed, false);
- for (const auto f : its_failed)
+ for (const auto& f : its_failed)
VSOMEIP_ERROR << "Reading configuration data from " << f << " failed!";
is_overlay_ = true;
diff --git a/implementation/endpoints/src/endpoint_manager_base.cpp b/implementation/endpoints/src/endpoint_manager_base.cpp
index 6c63e4f..a79ae48 100644
--- a/implementation/endpoints/src/endpoint_manager_base.cpp
+++ b/implementation/endpoints/src/endpoint_manager_base.cpp
@@ -158,7 +158,7 @@ endpoint_manager_base::log_client_states() const {
{
std::lock_guard<std::mutex> its_lock(local_endpoint_mutex_);
- for (const auto e : local_endpoints_) {
+ for (const auto& e : local_endpoints_) {
size_t its_queue_size = e.second->get_queue_size();
if (its_queue_size > VSOMEIP_DEFAULT_QUEUE_WARN_SIZE) {
its_client_queue_sizes.push_back(
diff --git a/implementation/endpoints/src/endpoint_manager_impl.cpp b/implementation/endpoints/src/endpoint_manager_impl.cpp
index 38dabf7..a82a173 100644
--- a/implementation/endpoints/src/endpoint_manager_impl.cpp
+++ b/implementation/endpoints/src/endpoint_manager_impl.cpp
@@ -983,9 +983,9 @@ endpoint_manager_impl::log_client_states() const {
its_client_endpoints = client_endpoints_by_ip_;
}
- for (const auto its_address : its_client_endpoints) {
- for (const auto its_port : its_address.second) {
- for (const auto its_reliability : its_port.second) {
+ for (const auto& its_address : its_client_endpoints) {
+ for (const auto& its_port : its_address.second) {
+ for (const auto& its_reliability : its_port.second) {
size_t its_queue_size = its_reliability.second->get_queue_size();
if (its_queue_size > VSOMEIP_DEFAULT_QUEUE_WARN_SIZE)
its_client_queue_sizes.push_back(
@@ -1040,8 +1040,8 @@ endpoint_manager_impl::log_server_states() const {
its_server_endpoints = server_endpoints_;
}
- for (const auto its_port : its_server_endpoints) {
- for (const auto its_reliability : its_port.second) {
+ for (const auto& its_port : its_server_endpoints) {
+ for (const auto& its_reliability : its_port.second) {
size_t its_queue_size = its_reliability.second->get_queue_size();
if (its_queue_size > VSOMEIP_DEFAULT_QUEUE_WARN_SIZE)
its_client_queue_sizes.push_back(
diff --git a/implementation/endpoints/src/server_endpoint_impl.cpp b/implementation/endpoints/src/server_endpoint_impl.cpp
index 46e2397..cfb5ea1 100644
--- a/implementation/endpoints/src/server_endpoint_impl.cpp
+++ b/implementation/endpoints/src/server_endpoint_impl.cpp
@@ -757,7 +757,7 @@ size_t server_endpoint_impl<Protocol>::get_queue_size() const {
{
std::lock_guard<std::mutex> its_lock(mutex_);
- for (const auto q : queues_) {
+ for (const auto& q : queues_) {
its_queue_size += q.second.second.size();
}
}
diff --git a/implementation/routing/src/eventgroupinfo.cpp b/implementation/routing/src/eventgroupinfo.cpp
index 3b3a808..d09ed1b 100644
--- a/implementation/routing/src/eventgroupinfo.cpp
+++ b/implementation/routing/src/eventgroupinfo.cpp
@@ -223,7 +223,7 @@ eventgroupinfo::update_remote_subscription(
_id = its_item.second->get_id();
// Copy acknowledgment states from existing subscription
- for (const auto its_client : _subscription->get_clients()) {
+ for (const auto& its_client : _subscription->get_clients()) {
_subscription->set_client_state(its_client,
its_item.second->get_client_state(its_client));
}
@@ -390,10 +390,10 @@ eventgroupinfo::send_initial_events(
}
// Send events
- for (const auto its_event : its_reliable_events)
+ for (const auto& its_event : its_reliable_events)
its_event->notify_one(VSOMEIP_ROUTING_CLIENT, _reliable);
- for (const auto its_event : its_unreliable_events)
+ for (const auto& its_event : its_unreliable_events)
its_event->notify_one(VSOMEIP_ROUTING_CLIENT, _unreliable);
}
diff --git a/implementation/routing/src/remote_subscription.cpp b/implementation/routing/src/remote_subscription.cpp
index 939e0d1..daec6f9 100644
--- a/implementation/routing/src/remote_subscription.cpp
+++ b/implementation/routing/src/remote_subscription.cpp
@@ -135,7 +135,7 @@ std::set<client_t>
remote_subscription::get_clients() const {
std::lock_guard<std::mutex> its_lock(mutex_);
std::set<client_t> its_clients;
- for (const auto its_item : clients_)
+ for (const auto& its_item : clients_)
its_clients.insert(its_item.first);
return its_clients;
}
diff --git a/implementation/routing/src/routing_manager_impl.cpp b/implementation/routing/src/routing_manager_impl.cpp
index 74e556c..34150fe 100644
--- a/implementation/routing/src/routing_manager_impl.cpp
+++ b/implementation/routing/src/routing_manager_impl.cpp
@@ -278,7 +278,7 @@ void routing_manager_impl::stop() {
discovery_->stop();
stub_->stop();
- for (const auto client : ep_mgr_->get_connected_clients()) {
+ for (const auto& client : ep_mgr_->get_connected_clients()) {
if (client != VSOMEIP_ROUTING_CLIENT) {
remove_local(client, true);
}
@@ -1163,7 +1163,7 @@ void routing_manager_impl::notify_one(service_t _service, instance_t _instance,
if (its_event) {
std::set<std::shared_ptr<endpoint_definition> > its_targets;
const auto its_reliability = its_event->get_reliability();
- for (const auto g : its_event->get_eventgroups()) {
+ for (const auto& g : its_event->get_eventgroups()) {
const auto its_eventgroup = find_eventgroup(_service, _instance, g);
if (its_eventgroup) {
const auto its_subscriptions = its_eventgroup->get_remote_subscriptions();
@@ -1887,7 +1887,7 @@ bool routing_manager_impl::deliver_notification(
// no subscribers for this specific event / check subscriptions
// to other events of the event's eventgroups
bool cache_event = false;
- for (const auto eg : its_event->get_eventgroups()) {
+ for (const auto& eg : its_event->get_eventgroups()) {
std::shared_ptr<eventgroupinfo> egi = find_eventgroup(_service, _instance, eg);
if (egi) {
for (const auto &e : egi->get_events()) {
@@ -1927,7 +1927,7 @@ bool routing_manager_impl::deliver_notification(
utility::get_payload_size(_data, _length));
if (its_event->get_type() != event_type_e::ET_SELECTIVE_EVENT) {
- for (const auto its_local_client : its_event->get_subscribers()) {
+ for (const auto& its_local_client : its_event->get_subscribers()) {
if (its_local_client == host_->get_client()) {
deliver_message(_data, _length, _instance, _reliable,
_bound_client, _credentials, _status_check, _is_from_remote);
@@ -2412,7 +2412,7 @@ void routing_manager_impl::del_routing_info(service_t _service, instance_t _inst
// longer valid.
for (auto &its_event : its_eventgroup.second->get_events()) {
const auto its_subscribers = its_event->get_subscribers();
- for (const auto its_subscriber : its_subscribers) {
+ for (const auto& its_subscriber : its_subscribers) {
if (its_subscriber != get_client()) {
its_event->remove_subscriber(
its_eventgroup.first, its_subscriber);
@@ -2436,14 +2436,14 @@ void routing_manager_impl::del_routing_info(service_t _service, instance_t _inst
std::set<std::tuple<
service_t, instance_t, eventgroup_t, client_t> > its_invalid;
- for (const auto its_state : remote_subscription_state_) {
+ for (const auto& its_state : remote_subscription_state_) {
if (std::get<0>(its_state.first) == _service
&& std::get<1>(its_state.first) == _instance) {
its_invalid.insert(its_state.first);
}
}
- for (const auto its_key : its_invalid)
+ for (const auto& its_key : its_invalid)
remote_subscription_state_.erase(its_key);
}
@@ -3770,7 +3770,7 @@ void routing_manager_impl::clear_targets_and_pending_sub_from_eventgroups(
// longer valid.
for (auto &its_event : its_eventgroup.second->get_events()) {
const auto its_subscribers = its_event->get_subscribers();
- for (const auto its_subscriber : its_subscribers) {
+ for (const auto& its_subscriber : its_subscribers) {
if (its_subscriber != get_client()) {
its_event->remove_subscriber(
its_eventgroup.first, its_subscriber);
@@ -4112,7 +4112,7 @@ void routing_manager_impl::send_subscription(
const remote_subscription_id_t _id) {
if (host_->get_client() == _offering_client) {
auto self = shared_from_this();
- for (const auto its_client : _clients) {
+ for (const auto& its_client : _clients) {
host_->on_subscription(_service, _instance, _eventgroup, its_client, own_uid_, own_gid_, true,
[this, self, _service, _instance, _eventgroup, its_client, _id]
(const bool _is_accepted) {
@@ -4138,7 +4138,7 @@ void routing_manager_impl::send_subscription(
});
}
} else { // service hosted by local client
- for (const auto its_client : _clients) {
+ for (const auto& its_client : _clients) {
if (!stub_->send_subscribe(find_local(_offering_client), its_client,
_service, _instance, _eventgroup, _major, ANY_EVENT, _id)) {
try {
@@ -4266,7 +4266,7 @@ routing_manager_impl::send_unsubscription(client_t _offering_client,
if (host_->get_client() == _offering_client) {
auto self = shared_from_this();
- for (const auto its_client : _removed) {
+ for (const auto& its_client : _removed) {
host_->on_subscription(_service, _instance,
_eventgroup, its_client, own_uid_, own_gid_, false,
[this, self, _service, _instance, _eventgroup,
@@ -4286,7 +4286,7 @@ routing_manager_impl::send_unsubscription(client_t _offering_client,
);
}
} else {
- for (const auto its_client : _removed) {
+ for (const auto& its_client : _removed) {
if (!stub_->send_unsubscribe(find_local(_offering_client), its_client,
_service, _instance, _eventgroup, ANY_EVENT, _id)) {
try {
@@ -4347,7 +4347,7 @@ bool routing_manager_impl::insert_event_statistics(service_t _service, instance_
// check list for entry with least counter value
uint32_t its_min_count(0xFFFFFFFF);
auto its_tuple_to_discard = std::make_tuple(0xFFFF, 0xFFFF, 0xFFFF);
- for (const auto it : message_statistics_) {
+ for (const auto& it : message_statistics_) {
if (it.second.counter_ < its_min_count) {
its_min_count = it.second.counter_;
its_tuple_to_discard = it.first;
@@ -4389,7 +4389,7 @@ void routing_manager_impl::statistics_log_timer_cbk(boost::system::error_code co
std::stringstream its_log;
{
std::lock_guard<std::mutex> its_lock(message_statistics_mutex_);
- for (const auto s : message_statistics_) {
+ for (const auto& s : message_statistics_) {
if (s.second.counter_ / (its_interval / 1000) >= its_min_freq) {
uint16_t its_subscribed(0);
std::shared_ptr<event> its_event = find_event(std::get<0>(s.first), std::get<1>(s.first), std::get<2>(s.first));
diff --git a/implementation/routing/src/routing_manager_proxy.cpp b/implementation/routing/src/routing_manager_proxy.cpp
index 2af0eb5..872067c 100644
--- a/implementation/routing/src/routing_manager_proxy.cpp
+++ b/implementation/routing/src/routing_manager_proxy.cpp
@@ -125,7 +125,7 @@ void routing_manager_proxy::stop() {
sender_ = nullptr;
}
- for (const auto client : ep_mgr_->get_connected_clients()) {
+ for (const auto& client : ep_mgr_->get_connected_clients()) {
if (client != VSOMEIP_ROUTING_CLIENT) {
remove_local(client, true);
}
@@ -1733,7 +1733,7 @@ void routing_manager_proxy::on_routing_info(const byte_t *_data,
for (const client_t client : known_clients_) {
auto its_client = pending_incoming_subscripitons_.find(client);
if (its_client != pending_incoming_subscripitons_.end()) {
- for (const auto subscription : its_client->second) {
+ for (const auto& subscription : its_client->second) {
subscription_actions.push_front(
{ subscription.service_, subscription.instance_,
subscription.eventgroup_, client,
@@ -1850,7 +1850,7 @@ void routing_manager_proxy::reconnect(const std::unordered_set<client_t> &_clien
// Remove all local connections/endpoints
- for (const auto its_client : _clients) {
+ for (const auto& its_client : _clients) {
if (its_client != VSOMEIP_ROUTING_CLIENT) {
remove_local(its_client, true);
}
diff --git a/implementation/routing/src/routing_manager_stub.cpp b/implementation/routing/src/routing_manager_stub.cpp
index 72668ea..9668352 100644
--- a/implementation/routing/src/routing_manager_stub.cpp
+++ b/implementation/routing/src/routing_manager_stub.cpp
@@ -2257,7 +2257,7 @@ routing_manager_stub::send_requester_policies(const std::unordered_set<client_t>
pending_security_update_id_t its_policy_id;
// serialize the policies and send them...
- for (const auto p : _policies) {
+ for (const auto& p : _policies) {
std::vector<byte_t> its_policy_data;
if (p->serialize(its_policy_data)) {
std::vector<byte_t> its_message;
@@ -2279,7 +2279,7 @@ routing_manager_stub::send_requester_policies(const std::unordered_set<client_t>
its_message.insert(its_message.end(), its_policy_data.begin(), its_policy_data.end());
- for (const auto c : _clients) {
+ for (const auto& c : _clients) {
std::shared_ptr<endpoint> its_endpoint = host_->find_local(c);
if (its_endpoint)
its_endpoint->send(&its_message[0], static_cast<uint32_t>(its_message.size()));
diff --git a/implementation/runtime/src/application_impl.cpp b/implementation/runtime/src/application_impl.cpp
index 45ac83f..aba8647 100644
--- a/implementation/runtime/src/application_impl.cpp
+++ b/implementation/runtime/src/application_impl.cpp
@@ -2157,7 +2157,7 @@ bool application_impl::check_for_active_subscription(service_t _service,
std::shared_ptr<event> its_event = routing_->find_event(
_service, _instance, _event);
if (its_event) {
- for (const auto eg : its_event->get_eventgroups()) {
+ for (const auto& eg : its_event->get_eventgroups()) {
auto found_eventgroup = found_any_event->second.find(eg);
if (found_eventgroup != found_any_event->second.end()) {
// set the flag for initial event received to true
diff --git a/implementation/security/src/policy.cpp b/implementation/security/src/policy.cpp
index 4babd06..9630e5f 100644
--- a/implementation/security/src/policy.cpp
+++ b/implementation/security/src/policy.cpp
@@ -175,7 +175,7 @@ policy::deserialize_ids(const byte_t * &_data, uint32_t &_size,
if (its_result == false)
return (false);
- for (const auto i : its_instances)
+ for (const auto& i : its_instances)
its_ids += std::make_pair(i, its_methods);
its_array_length -= (its_current_size - _size);
@@ -305,7 +305,7 @@ policy::serialize(std::vector<byte_t> &_data) const {
uint32_t its_requests_size(0);
serialize_u32(its_requests_size, _data);
- for (const auto its_request : requests_) {
+ for (const auto& its_request : requests_) {
for (auto its_service = its_request.first.lower();
its_service <= its_request.first.upper();
its_service++) {
@@ -316,7 +316,7 @@ policy::serialize(std::vector<byte_t> &_data) const {
uint32_t its_instances_size(0);
serialize_u32(its_instances_size, _data);
- for (const auto i : its_request.second) {
+ for (const auto& i : its_request.second) {
boost::icl::interval_set<instance_t> its_instances;
its_instances.insert(i.first);
serialize_interval_set(its_instances, _data);
@@ -378,7 +378,7 @@ policy::serialize_interval_set(
uint32_t its_interval_set_size(0);
serialize_u32(its_interval_set_size, _data);
- for (const auto i : _intervals)
+ for (const auto& i : _intervals)
serialize_interval(i, _data);
its_interval_set_size = static_cast<uint32_t>(_data.size()
diff --git a/implementation/security/src/security_impl.cpp b/implementation/security/src/security_impl.cpp
index 12bb9db..8a3d276 100644
--- a/implementation/security/src/security_impl.cpp
+++ b/implementation/security/src/security_impl.cpp
@@ -470,7 +470,7 @@ security_impl::update_security_policy(uint32_t _uid, uint32_t _gid,
}
if (its_matching_policy) {
- for (const auto r : _policy->requests_) {
+ for (const auto& r : _policy->requests_) {
service_t its_lower, its_upper;
get_bounds(r.first, its_lower, its_upper);
for (auto s = its_lower; s <= its_upper; s++) {
@@ -479,7 +479,7 @@ security_impl::update_security_policy(uint32_t _uid, uint32_t _gid,
its_matching_policy->requests_ += std::make_pair(its_service, r.second);
}
}
- for (const auto o : _policy->offers_) {
+ for (const auto& o : _policy->offers_) {
service_t its_lower, its_upper;
get_bounds(o.first, its_lower, its_upper);
for (auto s = its_lower; s <= its_upper; s++) {
@@ -758,7 +758,7 @@ security_impl::load_policy(const boost::property_tree::ptree &_tree) {
policy->allow_who_ = true;
}
if (has_uid_range && has_gid_range) {
- for (const auto u : its_uid_interval_set)
+ for (const auto& u : its_uid_interval_set)
policy->credentials_ += std::make_pair(u, its_gid_interval_set);
policy->allow_who_ = true;
}
@@ -819,7 +819,7 @@ security_impl::load_policy_body(std::shared_ptr<policy> &_policy,
its_instance_interval_set.insert(all_instances);
its_method_interval_set.insert(all_methods);
}
- for (const auto i : its_instance_interval_set) {
+ for (const auto& i : its_instance_interval_set) {
its_instance_method_intervals
+= std::make_pair(i, its_method_interval_set);
}
@@ -838,7 +838,7 @@ security_impl::load_policy_body(std::shared_ptr<policy> &_policy,
}
if (its_method_interval_set.empty())
its_method_interval_set.insert(all_methods);
- for (const auto i : its_instance_interval_set) {
+ for (const auto& i : its_instance_interval_set) {
its_instance_method_intervals
+= std::make_pair(i, its_method_interval_set);
}
@@ -853,7 +853,7 @@ security_impl::load_policy_body(std::shared_ptr<policy> &_policy,
// try to only load instance ranges with any method to be allowed
load_interval_set(k->second, its_legacy_instance_interval_set);
- for (const auto i : its_legacy_instance_interval_set) {
+ for (const auto& i : its_legacy_instance_interval_set) {
its_instance_method_intervals
+= std::make_pair(i, its_legacy_method_interval_set);
}
@@ -929,7 +929,7 @@ security_impl::load_credential(
}
}
- for (const auto its_uid_interval : its_uid_interval_set) {
+ for (const auto& its_uid_interval : its_uid_interval_set) {
_credentials
+= std::make_pair(its_uid_interval, its_gid_interval_set);
}
@@ -1081,8 +1081,8 @@ security_impl::get_requester_policies(const std::shared_ptr<policy> _policy,
}
std::lock_guard<std::mutex> its_lock(_policy->mutex_);
- for (const auto o : _policy->offers_) {
- for (const auto p : its_policies) {
+ for (const auto& o : _policy->offers_) {
+ for (const auto& p : its_policies) {
if (p == _policy)
continue;
@@ -1091,7 +1091,7 @@ security_impl::get_requester_policies(const std::shared_ptr<policy> _policy,
auto its_policy = std::make_shared<policy>();
its_policy->credentials_ = p->credentials_;
- for (const auto r : p->requests_) {
+ for (const auto& r : p->requests_) {
// o represents an offer by a service interval and its instances
// (a set of intervals)
// r represents a request by a service interval and its instances
@@ -1109,9 +1109,9 @@ security_impl::get_requester_policies(const std::shared_ptr<policy> _policy,
auto its_service_min = std::max(its_o_lower, its_r_lower);
auto its_service_max = std::min(its_r_upper, its_o_upper);
- for (const auto i : o.second) {
- for (const auto j : r.second) {
- for (const auto k : j.second) {
+ for (const auto& i : o.second) {
+ for (const auto& j : r.second) {
+ for (const auto& k : j.second) {
instance_t its_i_lower, its_i_upper, its_k_lower, its_k_upper;
get_bounds(i, its_i_lower, its_i_upper);
get_bounds(k, its_k_lower, its_k_upper);
@@ -1151,7 +1151,7 @@ security_impl::get_clients(uid_t _uid, gid_t _gid,
std::unordered_set<client_t> &_clients) const {
std::lock_guard<std::mutex> its_lock(ids_mutex_);
- for (const auto i : ids_) {
+ for (const auto& i : ids_) {
if (i.second.first == _uid && i.second.second == _gid)
_clients.insert(i.first);
}
diff --git a/implementation/service_discovery/src/eventgroupentry_impl.cpp b/implementation/service_discovery/src/eventgroupentry_impl.cpp
index bd5a491..28fdcec 100755
--- a/implementation/service_discovery/src/eventgroupentry_impl.cpp
+++ b/implementation/service_discovery/src/eventgroupentry_impl.cpp
@@ -118,8 +118,8 @@ bool eventgroupentry_impl::matches(const eventgroupentry_impl& _other,
std::vector<std::shared_ptr<ip_option_impl>> its_options_current;
std::vector<std::shared_ptr<ip_option_impl>> its_options_other;
const std::size_t its_options_size = _options.size();
- for (const auto option_run : {0,1}) {
- for (const auto option_index : options_[option_run]) {
+ for (const auto& option_run : {0,1}) {
+ for (const auto& option_index : options_[option_run]) {
if (its_options_size > option_index) {
switch (_options[option_index]->get_type()) {
case option_type_e::IP4_ENDPOINT:
@@ -137,7 +137,7 @@ bool eventgroupentry_impl::matches(const eventgroupentry_impl& _other,
}
}
}
- for (const auto option_index : _other.options_[option_run]) {
+ for (const auto& option_index : _other.options_[option_run]) {
if (its_options_size > option_index) {
switch (_options[option_index]->get_type()) {
case option_type_e::IP4_ENDPOINT:
@@ -212,8 +212,8 @@ std::shared_ptr<endpoint_definition> eventgroupentry_impl::get_target(
std::shared_ptr<selective_option_impl>
eventgroupentry_impl::get_selective_option() const {
- for (const auto i : {0, 1}) {
- for (const auto j : options_[i]) {
+ for (const auto& i : {0, 1}) {
+ for (const auto& j : options_[i]) {
auto its_option = std::dynamic_pointer_cast<
selective_option_impl>(owner_->get_option(j));
if (its_option)
diff --git a/implementation/service_discovery/src/service_discovery_impl.cpp b/implementation/service_discovery/src/service_discovery_impl.cpp
index 0fc6190..ca4e131 100644
--- a/implementation/service_discovery/src/service_discovery_impl.cpp
+++ b/implementation/service_discovery/src/service_discovery_impl.cpp
@@ -248,8 +248,8 @@ service_discovery_impl::subscribe(
if (!its_subscription->is_selective() && is_selective) {
its_subscription->set_selective(true);
its_subscription->remove_client(VSOMEIP_ROUTING_CLIENT);
- for (const auto e : _info->get_events()) {
- for (const auto c : e->get_subscribers(_eventgroup)) {
+ for (const auto& e : _info->get_events()) {
+ for (const auto& c : e->get_subscribers(_eventgroup)) {
its_subscription->add_client(c);
}
}
@@ -769,7 +769,7 @@ service_discovery_impl::create_eventgroup_entry(
its_entry->set_ttl(_subscription->get_ttl());
its_data.entry_ = its_entry;
- for (const auto its_client : _subscription->get_clients()) {
+ for (const auto& its_client : _subscription->get_clients()) {
if (_subscription->get_state(its_client)
== subscription_state_e::ST_RESUBSCRIBING_NOT_ACKNOWLEDGED) {
its_other = std::make_shared<eventgroupentry_impl>();
@@ -821,7 +821,7 @@ service_discovery_impl::create_eventgroup_entry(
its_data.entry_ = its_entry;
}
- for (const auto its_client : _subscription->get_clients()) {
+ for (const auto& its_client : _subscription->get_clients()) {
if (_subscription->get_state(its_client)
== subscription_state_e::ST_RESUBSCRIBING_NOT_ACKNOWLEDGED) {
if (!its_other) {
@@ -1473,7 +1473,7 @@ service_discovery_impl::process_offerservice_serviceentry(
if (its_data.entry_) {
add_entry_data(_resubscribes, its_data);
}
- for (const auto its_client : its_subscription->get_clients()) {
+ for (const auto& its_client : its_subscription->get_clients()) {
its_subscription->set_state(its_client,
subscription_state_e::ST_NOT_ACKNOWLEDGED);
}
@@ -1616,7 +1616,7 @@ service_discovery_impl::on_endpoint_connected(
its_subscription->set_endpoint(its_reliable, true);
its_subscription->set_endpoint(its_unreliable, false);
- for (const auto its_client : its_subscription->get_clients())
+ for (const auto& its_client : its_subscription->get_clients())
its_subscription->set_state(its_client,
subscription_state_e::ST_NOT_ACKNOWLEDGED);
@@ -2377,7 +2377,7 @@ service_discovery_impl::handle_eventgroup_subscription_nack(
auto found_eventgroup = found_instance->second.find(_eventgroup);
if (found_eventgroup != found_instance->second.end()) {
auto its_subscription = found_eventgroup->second;
- for (const auto its_client : _clients) {
+ for (const auto& its_client : _clients) {
host_->on_subscribe_nack(its_client,
_service, _instance, _eventgroup, ANY_EVENT,
PENDING_SUBSCRIPTION_ID); // TODO: This is a dummy call...
@@ -2412,7 +2412,7 @@ service_discovery_impl::handle_eventgroup_subscription_ack(
if (found_instance != found_service->second.end()) {
auto found_eventgroup = found_instance->second.find(_eventgroup);
if (found_eventgroup != found_instance->second.end()) {
- for (const auto its_client : _clients) {
+ for (const auto& its_client : _clients) {
if (found_eventgroup->second->get_state(its_client)
== subscription_state_e::ST_NOT_ACKNOWLEDGED) {
found_eventgroup->second->set_state(its_client,
diff --git a/implementation/service_discovery/src/subscription.cpp b/implementation/service_discovery/src/subscription.cpp
index 8869f50..9a95bec 100644
--- a/implementation/service_discovery/src/subscription.cpp
+++ b/implementation/service_discovery/src/subscription.cpp
@@ -100,7 +100,7 @@ std::set<client_t> subscription::get_clients() const {
std::set<client_t> its_clients;
{
std::lock_guard<std::mutex> its_lock(clients_mutex_);
- for (const auto its_item : clients_)
+ for (const auto& its_item : clients_)
its_clients.insert(its_item.first);
}
return its_clients;
diff --git a/test/client_id_tests/client_id_test_utility.cpp b/test/client_id_tests/client_id_test_utility.cpp
index 189bb65..9cfe5ab 100644
--- a/test/client_id_tests/client_id_test_utility.cpp
+++ b/test/client_id_tests/client_id_test_utility.cpp
@@ -312,7 +312,7 @@ TEST_F(client_id_utility_test, exhaust_client_id_range_sequential) {
EXPECT_EQ(VSOMEIP_CLIENT_UNSET, vsomeip::utility::request_client_id(
configuration_, APPLICATION_NAME_NOT_PREDEFINED + "max",
VSOMEIP_CLIENT_UNSET));
- for (const auto c : its_clients) {
+ for (const auto& c : its_clients) {
utility::release_client_id(c);
}
}
@@ -396,7 +396,7 @@ TEST_F(client_id_utility_test, exhaust_client_id_range_fragmented) {
VSOMEIP_CLIENT_UNSET));
// release all
- for (const auto c : its_clients) {
+ for (const auto& c : its_clients) {
utility::release_client_id(c);
}
its_clients.clear();
diff --git a/test/npdu_tests/npdu_test_service.cpp b/test/npdu_tests/npdu_test_service.cpp
index 901084b..ccbdd66 100644
--- a/test/npdu_tests/npdu_test_service.cpp
+++ b/test/npdu_tests/npdu_test_service.cpp
@@ -92,7 +92,7 @@ void npdu_test_service::stop()
VSOMEIP_INFO << "Stopping...";
if (!undershot_debounce_times_.empty()) {
std::chrono::microseconds sum(0);
- for (const auto t : undershot_debounce_times_) {
+ for (const auto& t : undershot_debounce_times_) {
sum += t;
}
double average = static_cast<double>(sum.count())/static_cast<double>(undershot_debounce_times_.size());