Lint

Signed-off-by: Yadunund <yadunund@openrobotics.org>

rmw_zenoh_cpp/src/detail/guard_condition.cpp

@@ -39,7 +39,9 @@ void GuardCondition::trigger()
 }
 
 ///==============================================================================
-void GuardCondition::attach_condition(std::mutex * condition_mutex, std::condition_variable * condition_variable)
+void GuardCondition::attach_condition(
+  std::mutex * condition_mutex,
+  std::condition_variable * condition_variable)
 {
   std::lock_guard<std::mutex> lock(internal_mutex_);
   condition_mutex_ = condition_mutex;

rmw_zenoh_cpp/src/detail/rmw_data_types.cpp

@@ -63,7 +63,9 @@ size_t rmw_publisher_data_t::get_next_sequence_number()
 }
 
 ///=============================================================================
-void rmw_subscription_data_t::attach_condition(std::mutex * condition_mutex, std::condition_variable * condition_variable)
+void rmw_subscription_data_t::attach_condition(
+  std::mutex * condition_mutex,
+  std::condition_variable * condition_variable)
 {
   std::lock_guard<std::mutex> lock(update_condition_mutex_);
   condition_mutex_ = condition_mutex;
@@ -155,7 +157,9 @@ bool rmw_service_data_t::query_queue_is_empty() const
 }
 
 ///=============================================================================
-void rmw_service_data_t::attach_condition(std::mutex * condition_mutex, std::condition_variable * condition_variable)
+void rmw_service_data_t::attach_condition(
+  std::mutex * condition_mutex,
+  std::condition_variable * condition_variable)
 {
   std::lock_guard<std::mutex> lock(update_condition_mutex_);
   condition_mutex_ = condition_mutex;
@@ -238,7 +242,8 @@ bool rmw_service_data_t::add_to_query_map(
 
   std::lock_guard<std::mutex> lock(sequence_to_query_map_mutex_);
 
-  std::unordered_map<size_t, SequenceToQuery>::iterator it = sequence_to_query_map_.find(hash);
+  std::unordered_map<size_t, SequenceToQuery>::iterator it =
+    sequence_to_query_map_.find(hash);
 
   if (it == sequence_to_query_map_.end()) {
     SequenceToQuery stq;
@@ -254,7 +259,8 @@ bool rmw_service_data_t::add_to_query_map(
     }
   }
 
-  it->second.insert(std::make_pair(request_id.sequence_number, std::move(query)));
+  it->second.insert(
+    std::make_pair(request_id.sequence_number, std::move(query)));
 
   return true;
 }
@@ -333,7 +339,9 @@ bool rmw_client_data_t::reply_queue_is_empty() const
 }
 
 ///=============================================================================
-void rmw_client_data_t::attach_condition(std::mutex * condition_mutex, std::condition_variable * condition_variable)
+void rmw_client_data_t::attach_condition(
+  std::mutex * condition_mutex,
+  std::condition_variable * condition_variable)
 {
   std::lock_guard<std::mutex> lock(update_condition_mutex_);
   condition_mutex_ = condition_mutex;

rmw_zenoh_cpp/src/rmw_zenoh.cpp

@@ -2811,8 +2811,7 @@ rmw_take_request(
   request_header->received_timestamp = now_ns.count();
 
   // Add this query to the map, so that rmw_send_response can quickly look it up later
-  if (!service_data->add_to_query_map(request_header->request_id, std::move(query)))
-  {
+  if (!service_data->add_to_query_map(request_header->request_id, std::move(query))) {
     RMW_SET_ERROR_MSG("duplicate sequence number in the map");
     return RMW_RET_ERROR;
   }
@@ -3251,7 +3250,9 @@ rmw_wait(
       for (size_t i = 0; i < subscriptions->subscriber_count; ++i) {
         auto sub_data = static_cast<rmw_subscription_data_t *>(subscriptions->subscribers[i]);
         if (sub_data != nullptr) {
-          sub_data->attach_condition(&wait_set_data->condition_mutex, &wait_set_data->condition_variable);
+          sub_data->attach_condition(
+            &wait_set_data->condition_mutex,
+            &wait_set_data->condition_variable);
         }
       }
     }
@@ -3262,7 +3263,9 @@ rmw_wait(
       for (size_t i = 0; i < services->service_count; ++i) {
         auto serv_data = static_cast<rmw_service_data_t *>(services->services[i]);
         if (serv_data != nullptr) {
-          serv_data->attach_condition(&wait_set_data->condition_mutex, &wait_set_data->condition_variable);
+          serv_data->attach_condition(
+            &wait_set_data->condition_mutex,
+            &wait_set_data->condition_variable);
         }
       }
     }
@@ -3273,7 +3276,9 @@ rmw_wait(
       for (size_t i = 0; i < clients->client_count; ++i) {
         rmw_client_data_t * client_data = static_cast<rmw_client_data_t *>(clients->clients[i]);
         if (client_data != nullptr) {
-          client_data->attach_condition(&wait_set_data->condition_mutex, &wait_set_data->condition_variable);
+          client_data->attach_condition(
+            &wait_set_data->condition_mutex,
+            &wait_set_data->condition_variable);
         }
       }
     }
@@ -3296,7 +3301,8 @@ rmw_wait(
 
     std::unique_lock<std::mutex> lock(wait_set_data->condition_mutex);
 
-    // We have to check the triggered condition *again* under the lock so we don't miss notifications.
+    // We have to check the triggered condition *again* under the lock so we
+    // don't miss notifications.
     skip_wait = has_triggered_condition(
       subscriptions, guard_conditions, services, clients, events);
 
@@ -3309,7 +3315,8 @@ rmw_wait(
       } else {
         if (wait_timeout->sec != 0 || wait_timeout->nsec != 0) {
           std::cv_status wait_status = wait_set_data->condition_variable.wait_for(
-            lock, std::chrono::nanoseconds(wait_timeout->nsec + RCUTILS_S_TO_NS(wait_timeout->sec)));
+            lock,
+            std::chrono::nanoseconds(wait_timeout->nsec + RCUTILS_S_TO_NS(wait_timeout->sec)));
           wait_result = wait_status == std::cv_status::no_timeout;
         }
       }