diff --git a/ddsenabler/examples/action/CLIParser.hpp b/ddsenabler/examples/action/CLIParser.hpp index 6479a079..6d4bae66 100644 --- a/ddsenabler/examples/action/CLIParser.hpp +++ b/ddsenabler/examples/action/CLIParser.hpp @@ -50,50 +50,50 @@ class CLIParser static void print_help( uint8_t return_code) { - std::cout << "Usage: ddsenabler_example_action [options]" << - std::endl; - std::cout << "" << - std::endl; - std::cout << "--config Path to the configuration file" << - std::endl; - std::cout << " (optional, if not provided default config is used)" << - std::endl; - std::cout << "--action-name Name of the action to be registered" << - std::endl; - std::cout << " (Default: 'fibonacci')" << - std::endl; - std::cout << "--timeout Time (seconds) to wait before stopping the" << - std::endl; - std::cout << " program if expectations are not met" << - std::endl; - std::cout << " (Default: 30)" << - std::endl; - std::cout << "--persistence-path Path to the persistence directory" << - std::endl; - std::cout << " (No default value as it is required)" << - std::endl; - std::cout << "\n-------------------------------------SERVER OPTIONS------------------------------------\n" << - std::endl; - std::cout << "--expected-requests Number of requests expected to be received" << - std::endl; - std::cout << " (Default: 0, meaning infinite)" << - std::endl; - std::cout << "\n-------------------------------------CLIENT OPTIONS------------------------------------\n" << - std::endl; - std::cout << "--request-initial-wait Time (seconds) to wait before starting" << - std::endl; - std::cout << " requests publication since server matching" << - std::endl; - std::cout << " (Default: 0)" << - std::endl; - std::cout << "--cancel-requests Whether to cancel requests after sending them" << - std::endl; - std::cout << " (Default: false)" << - std::endl; - std::cout << "--goals-path Directory containing goal JSON files" << - std::endl; - std::cout << " (No default value as it is required for client mode)" << - std::endl; + std::cout << "Usage: ddsenabler_example_action [options]" + << std::endl; + std::cout << "" + << std::endl; + std::cout << "--config Path to the configuration file" + << std::endl; + std::cout << " (optional, if not provided default config is used)" + << std::endl; + std::cout << "--action-name Name of the action to be registered" + << std::endl; + std::cout << " (Default: 'fibonacci')" + << std::endl; + std::cout << "--timeout Time (seconds) to wait before stopping the" + << std::endl; + std::cout << " program if expectations are not met" + << std::endl; + std::cout << " (Default: 30)" + << std::endl; + std::cout << "--persistence-path Path to the persistence directory" + << std::endl; + std::cout << " (No default value as it is required)" + << std::endl; + std::cout << "\n-------------------------------------SERVER OPTIONS------------------------------------\n" + << std::endl; + std::cout << "--expected-requests Number of requests expected to be received" + << std::endl; + std::cout << " (Default: 0, meaning infinite)" + << std::endl; + std::cout << "\n-------------------------------------CLIENT OPTIONS------------------------------------\n" + << std::endl; + std::cout << "--request-initial-wait Time (seconds) to wait before starting" + << std::endl; + std::cout << " requests publication since server matching" + << std::endl; + std::cout << " (Default: 0)" + << std::endl; + std::cout << "--cancel-requests Whether to cancel requests after sending them" + << std::endl; + std::cout << " (Default: false)" + << std::endl; + std::cout << "--goals-path Directory containing goal JSON files" + << std::endl; + std::cout << " (No default value as it is required for client mode)" + << std::endl; std::exit(return_code); } @@ -223,8 +223,8 @@ class CLIParser } catch (const std::exception& e) { - std::cerr << "Invalid --expected-requests argument " << argv[i] << ": " << e.what() << - std::endl; + std::cerr << "Invalid --expected-requests argument " << argv[i] << ": " << e.what() + << std::endl; print_help(EXIT_FAILURE); } } @@ -244,8 +244,8 @@ class CLIParser } catch (const std::exception& e) { - std::cerr << "Invalid --request-initial-wait argument " << argv[i] << ": " << e.what() << - std::endl; + std::cerr << "Invalid --request-initial-wait argument " << argv[i] << ": " << e.what() + << std::endl; print_help(EXIT_FAILURE); } } diff --git a/ddsenabler/examples/publish/CLIParser.hpp b/ddsenabler/examples/publish/CLIParser.hpp index 8dfae01d..309c5008 100644 --- a/ddsenabler/examples/publish/CLIParser.hpp +++ b/ddsenabler/examples/publish/CLIParser.hpp @@ -135,8 +135,8 @@ class CLIParser } catch (const std::exception& e) { - std::cerr << "Invalid --expected-types argument " << std::string(argv[i]) << ": " << - std::string(e.what()) << std::endl; + std::cerr << "Invalid --expected-types argument " << std::string(argv[i]) << ": " + << std::string(e.what()) << std::endl; print_help(EXIT_FAILURE); } } @@ -156,8 +156,8 @@ class CLIParser } catch (const std::exception& e) { - std::cerr << "Invalid --expected-topics argument " << std::string(argv[i]) << ": " << - std::string(e.what()) << std::endl; + std::cerr << "Invalid --expected-topics argument " << std::string(argv[i]) << ": " + << std::string(e.what()) << std::endl; print_help(EXIT_FAILURE); } } @@ -261,8 +261,8 @@ class CLIParser } catch (const std::exception& e) { - std::cerr << "Invalid --publish-period argument " << std::string(argv[i]) << ": " << - std::string( + std::cerr << "Invalid --publish-period argument " << std::string(argv[i]) << ": " + << std::string( e.what()) << std::endl; print_help(EXIT_FAILURE); } @@ -283,8 +283,8 @@ class CLIParser } catch (const std::exception& e) { - std::cerr << "Invalid --publish-initial-wait argument " << std::string(argv[i]) << ": " << - std::string( + std::cerr << "Invalid --publish-initial-wait argument " << std::string(argv[i]) << ": " + << std::string( e.what()) << std::endl; print_help(EXIT_FAILURE); } diff --git a/ddsenabler/examples/publish/main.cpp b/ddsenabler/examples/publish/main.cpp index e144dd75..324c2a53 100644 --- a/ddsenabler/examples/publish/main.cpp +++ b/ddsenabler/examples/publish/main.cpp @@ -85,8 +85,8 @@ static void test_type_notification_callback( { std::lock_guard lock(app_mutex_); notify = ++received_types_ >= config.expected_types; - std::cout << "Type callback received: " << type_name << ", Total types: " << - received_types_ << std::endl << serialized_type << std::endl << std::endl; + std::cout << "Type callback received: " << type_name << ", Total types: " + << received_types_ << std::endl << serialized_type << std::endl << std::endl; if (!config.persistence_path.empty() && !utils::save_type_to_file((std::filesystem::path(config.persistence_path) / TYPES_SUBDIR).string(), type_name, @@ -132,9 +132,9 @@ static void test_topic_notification_callback( { std::lock_guard lock(app_mutex_); notify = ++received_topics_ >= config.expected_topics; - std::cout << "Topic callback received: " << topic_name << " of type " << topic_info.type_name << - ", Total topics: " << - received_topics_ << std::endl << topic_info.serialized_qos << std::endl << std::endl; + std::cout << "Topic callback received: " << topic_name << " of type " << topic_info.type_name + << ", Total topics: " + << received_topics_ << std::endl << topic_info.serialized_qos << std::endl << std::endl; if (!config.persistence_path.empty() && !utils::save_topic_to_file((std::filesystem::path(config.persistence_path) / TOPICS_SUBDIR).string(), topic_name, @@ -181,8 +181,8 @@ static void test_data_notification_callback( { std::lock_guard lock(app_mutex_); notify = ++received_data_ >= config.expected_data; - std::cout << "Data callback received: " << topic_name << ", Total data: " << - received_data_ << std::endl << json << std::endl << std::endl; + std::cout << "Data callback received: " << topic_name << ", Total data: " + << received_data_ << std::endl << json << std::endl << std::endl; if (!config.persistence_path.empty() && !utils::save_data_to_file((std::filesystem::path(config.persistence_path) / SAMPLES_SUBDIR).string(), topic_name, json, diff --git a/ddsenabler/examples/service/CLIParser.hpp b/ddsenabler/examples/service/CLIParser.hpp index f874daa5..aafb7856 100644 --- a/ddsenabler/examples/service/CLIParser.hpp +++ b/ddsenabler/examples/service/CLIParser.hpp @@ -49,46 +49,46 @@ class CLIParser static void print_help( uint8_t return_code) { - std::cout << "Usage: ddsenabler_example_service [options]" << - std::endl; - std::cout << "" << - std::endl; - std::cout << "--config Path to the configuration file" << - std::endl; - std::cout << " (optional, if not provided default config is used)" << - std::endl; - std::cout << "--service-name Name of the service to be registered" << - std::endl; - std::cout << " (Default: 'add_two_ints')" << - std::endl; - std::cout << "--timeout Time (seconds) to wait before stopping the" << - std::endl; - std::cout << " program if expectations are not met" << - std::endl; - std::cout << " (Default: 30)" << - std::endl; - std::cout << "--persistence-path Path to the persistence directory" << - std::endl; - std::cout << " (No default value as it is required)" << - std::endl; - std::cout << "\n-------------------------------------SERVER OPTIONS------------------------------------\n" << - std::endl; - std::cout << "--expected-requests Number of requests expected to be received" << - std::endl; - std::cout << " (Default: 0, meaning infinite)" << - std::endl; - std::cout << "\n-------------------------------------CLIENT OPTIONS------------------------------------\n" << - std::endl; - std::cout << "--request-initial-wait Time (seconds) to wait before starting" << - std::endl; - std::cout << " requests publication since server matching" << - std::endl; - std::cout << " (Default: 0)" << - std::endl; - std::cout << "--requests-path Directory containing request JSON files" << - std::endl; - std::cout << " (No default value as it is required for client mode)" << - std::endl; + std::cout << "Usage: ddsenabler_example_service [options]" + << std::endl; + std::cout << "" + << std::endl; + std::cout << "--config Path to the configuration file" + << std::endl; + std::cout << " (optional, if not provided default config is used)" + << std::endl; + std::cout << "--service-name Name of the service to be registered" + << std::endl; + std::cout << " (Default: 'add_two_ints')" + << std::endl; + std::cout << "--timeout Time (seconds) to wait before stopping the" + << std::endl; + std::cout << " program if expectations are not met" + << std::endl; + std::cout << " (Default: 30)" + << std::endl; + std::cout << "--persistence-path Path to the persistence directory" + << std::endl; + std::cout << " (No default value as it is required)" + << std::endl; + std::cout << "\n-------------------------------------SERVER OPTIONS------------------------------------\n" + << std::endl; + std::cout << "--expected-requests Number of requests expected to be received" + << std::endl; + std::cout << " (Default: 0, meaning infinite)" + << std::endl; + std::cout << "\n-------------------------------------CLIENT OPTIONS------------------------------------\n" + << std::endl; + std::cout << "--request-initial-wait Time (seconds) to wait before starting" + << std::endl; + std::cout << " requests publication since server matching" + << std::endl; + std::cout << " (Default: 0)" + << std::endl; + std::cout << "--requests-path Directory containing request JSON files" + << std::endl; + std::cout << " (No default value as it is required for client mode)" + << std::endl; std::exit(return_code); } @@ -218,8 +218,8 @@ class CLIParser } catch (const std::exception& e) { - std::cerr << "Invalid --expected-requests argument " << argv[i] << ": " << e.what() << - std::endl; + std::cerr << "Invalid --expected-requests argument " << argv[i] << ": " << e.what() + << std::endl; print_help(EXIT_FAILURE); } } @@ -239,8 +239,8 @@ class CLIParser } catch (const std::exception& e) { - std::cerr << "Invalid --request-initial-wait argument " << argv[i] << ": " << e.what() << - std::endl; + std::cerr << "Invalid --request-initial-wait argument " << argv[i] << ": " << e.what() + << std::endl; print_help(EXIT_FAILURE); } } @@ -290,8 +290,8 @@ class CLIParser if (config.persistence_path.empty()) { - std::cerr << "Warning: persistence path is not set, persistence features will be disabled" << - std::endl; + std::cerr << "Warning: persistence path is not set, persistence features will be disabled" + << std::endl; } return config; diff --git a/ddsenabler/examples/service/main.cpp b/ddsenabler/examples/service/main.cpp index 03864ae3..ced7cad1 100644 --- a/ddsenabler/examples/service/main.cpp +++ b/ddsenabler/examples/service/main.cpp @@ -438,8 +438,8 @@ bool server_routine( return false; } - std::cout << "Received request for service: " << service_name << " with request ID: " << request_id << - std::endl; + std::cout << "Received request for service: " << service_name << " with request ID: " << request_id + << std::endl; // Example response server_specific_logic( diff --git a/ddsenabler/src/cpp/DDSEnabler.cpp b/ddsenabler/src/cpp/DDSEnabler.cpp index 3a5577d1..94f90f90 100644 --- a/ddsenabler/src/cpp/DDSEnabler.cpp +++ b/ddsenabler/src/cpp/DDSEnabler.cpp @@ -140,7 +140,7 @@ bool DDSEnabler::set_file_watcher( // WARNING: it is needed to pass file_path, as FileWatcher only retrieves file_name std::function file_watcher_callback = [this, file_path] - (std::string file_name) + (std::string file_name) { EPROSIMA_LOG_INFO(DDSENABLER_EXECUTION, "FileWatcher notified changes in file " << file_path << ". Reloading configuration"); diff --git a/ddsenabler/test/DDSEnablerTester.hpp b/ddsenabler/test/DDSEnablerTester.hpp index 50cc9cdf..92f2ee1e 100644 --- a/ddsenabler/test/DDSEnablerTester.hpp +++ b/ddsenabler/test/DDSEnablerTester.hpp @@ -186,16 +186,16 @@ class DDSEnablerTester : public ::testing::Test if (RETCODE_OK != a_type.type_sup_.register_type(participant)) { - std::cout << "ERROR DDSEnablerTester: fail to register type: " << - a_type.type_sup_.get_type_name() << std::endl; + std::cout << "ERROR DDSEnablerTester: fail to register type: " + << a_type.type_sup_.get_type_name() << std::endl; return false; } Publisher* publisher = participant->create_publisher(PUBLISHER_QOS_DEFAULT); if (publisher == nullptr) { - std::cout << "ERROR DDSEnablerTester: create_publisher: " << - a_type.type_sup_.get_type_name() << std::endl; + std::cout << "ERROR DDSEnablerTester: create_publisher: " + << a_type.type_sup_.get_type_name() << std::endl; return false; } @@ -204,8 +204,8 @@ class DDSEnablerTester : public ::testing::Test Topic* topic = participant->create_topic(topic_name.str(), a_type.type_sup_.get_type_name(), TOPIC_QOS_DEFAULT); if (topic == nullptr) { - std::cout << "ERROR DDSEnablerTester: create_topic: " << - a_type.type_sup_.get_type_name() << std::endl; + std::cout << "ERROR DDSEnablerTester: create_topic: " + << a_type.type_sup_.get_type_name() << std::endl; return false; } @@ -213,8 +213,8 @@ class DDSEnablerTester : public ::testing::Test a_type.writer_ = publisher->create_datawriter(topic, wqos); if (a_type.writer_ == nullptr) { - std::cout << "ERROR DDSEnablerTester: create_datawriter: " << - a_type.type_sup_.get_type_name() << std::endl; + std::cout << "ERROR DDSEnablerTester: create_datawriter: " + << a_type.type_sup_.get_type_name() << std::endl; return false; } std::this_thread::sleep_for(std::chrono::milliseconds(wait_after_writer_creation_ms_)); @@ -235,16 +235,16 @@ class DDSEnablerTester : public ::testing::Test if (RETCODE_OK != a_type.type_sup_.register_type(participant)) { - std::cout << "ERROR DDSEnablerTester: fail to register type: " << - a_type.type_sup_.get_type_name() << std::endl; + std::cout << "ERROR DDSEnablerTester: fail to register type: " + << a_type.type_sup_.get_type_name() << std::endl; return false; } Publisher* publisher = participant->create_publisher(PUBLISHER_QOS_DEFAULT); if (publisher == nullptr) { - std::cout << "ERROR DDSEnablerTester: create_publisher: " << - a_type.type_sup_.get_type_name() << std::endl; + std::cout << "ERROR DDSEnablerTester: create_publisher: " + << a_type.type_sup_.get_type_name() << std::endl; return false; } @@ -253,8 +253,8 @@ class DDSEnablerTester : public ::testing::Test Topic* topic = participant->create_topic(topic_name.str(), a_type.type_sup_.get_type_name(), TOPIC_QOS_DEFAULT); if (topic == nullptr) { - std::cout << "ERROR DDSEnablerTester: create_topic: " << - a_type.type_sup_.get_type_name() << std::endl; + std::cout << "ERROR DDSEnablerTester: create_topic: " + << a_type.type_sup_.get_type_name() << std::endl; return false; } @@ -263,8 +263,8 @@ class DDSEnablerTester : public ::testing::Test a_type.writer_ = publisher->create_datawriter(topic, wqos); if (a_type.writer_ == nullptr) { - std::cout << "ERROR DDSEnablerTester: create_datawriter: " << - a_type.type_sup_.get_type_name() << std::endl; + std::cout << "ERROR DDSEnablerTester: create_datawriter: " + << a_type.type_sup_.get_type_name() << std::endl; return false; } std::this_thread::sleep_for(std::chrono::milliseconds(wait_after_writer_creation_ms_)); @@ -280,8 +280,8 @@ class DDSEnablerTester : public ::testing::Test void* sample = a_type.type_sup_.create_data(); if (RETCODE_OK != a_type.writer_->write(sample)) { - std::cout << "ERROR DDSEnablerTester: fail writing sample: " << - a_type.type_sup_.get_type_name() << std::endl; + std::cout << "ERROR DDSEnablerTester: fail writing sample: " + << a_type.type_sup_.get_type_name() << std::endl; return false; } @@ -291,8 +291,8 @@ class DDSEnablerTester : public ::testing::Test if (RETCODE_OK != a_type.writer_->wait_for_acknowledgments(Duration_t(0, wait_for_ack_ns_))) { - std::cout << "ERROR DDSEnablerTester: fail waiting for acknowledgments: " << - a_type.type_sup_.get_type_name() << std::endl; + std::cout << "ERROR DDSEnablerTester: fail waiting for acknowledgments: " + << a_type.type_sup_.get_type_name() << std::endl; return false; } @@ -310,8 +310,8 @@ class DDSEnablerTester : public ::testing::Test std::lock_guard lock(current_test_instance_->data_received_mutex_); current_test_instance_->received_data_++; - std::cout << "Data callback received: " << topic_name << ", Total data: " << - current_test_instance_->received_data_ << std::endl; + std::cout << "Data callback received: " << topic_name << ", Total data: " + << current_test_instance_->received_data_ << std::endl; } } @@ -328,8 +328,8 @@ class DDSEnablerTester : public ::testing::Test std::lock_guard lock(current_test_instance_->type_received_mutex_); current_test_instance_->received_types_++; - std::cout << "Type callback received: " << type_name << ", Total types: " << - current_test_instance_->received_types_ << std::endl; + std::cout << "Type callback received: " << type_name << ", Total types: " + << current_test_instance_->received_types_ << std::endl; } } @@ -343,8 +343,8 @@ class DDSEnablerTester : public ::testing::Test std::lock_guard lock(current_test_instance_->topic_received_mutex_); current_test_instance_->received_topics_++; - std::cout << "Topic callback received: " << topic_name << ", Total topics: " << - current_test_instance_->received_topics_ << std::endl; + std::cout << "Topic callback received: " << topic_name << ", Total topics: " + << current_test_instance_->received_topics_ << std::endl; } } diff --git a/ddsenabler_participants/src/cpp/EnablerParticipant.cpp b/ddsenabler_participants/src/cpp/EnablerParticipant.cpp index 2baef45a..854704f0 100644 --- a/ddsenabler_participants/src/cpp/EnablerParticipant.cpp +++ b/ddsenabler_participants/src/cpp/EnablerParticipant.cpp @@ -218,8 +218,8 @@ bool EnablerParticipant::publish_rpc( if (!it->second->external_server && rpc_info->service_type == ServiceType::REQUEST) { EPROSIMA_LOG_ERROR(DDSENABLER_ENABLER_PARTICIPANT, - "Failed to publish data in service " << rpc_info->service_name << - " : service is only announced on the enabler side."); + "Failed to publish data in service " << rpc_info->service_name + << " : service is only announced on the enabler side."); return false; } @@ -789,8 +789,8 @@ bool EnablerParticipant::query_topic_nts_( if (!topic_query_callback_) { EPROSIMA_LOG_ERROR(DDSENABLER_ENABLER_PARTICIPANT, - "Failed to query data from topic " << topic_name << - " : topic is unknown and topic query callback not set."); + "Failed to query data from topic " << topic_name + << " : topic is unknown and topic query callback not set."); return false; } TopicInfo topic_info; @@ -811,8 +811,8 @@ bool EnablerParticipant::query_service_nts_( if (!service_query_callback_) { EPROSIMA_LOG_ERROR(DDSENABLER_ENABLER_PARTICIPANT, - "Failed to announce service " << service->service_name << - " : service is unknown and service request callback not set."); + "Failed to announce service " << service->service_name + << " : service is unknown and service request callback not set."); return false; } @@ -841,8 +841,8 @@ bool EnablerParticipant::query_action_nts_( if (!action_query_callback_) { EPROSIMA_LOG_ERROR(DDSENABLER_ENABLER_PARTICIPANT, - "Failed to announce action " << action.action_name << - " : action is unknown and action request callback not set."); + "Failed to announce action " << action.action_name + << " : action is unknown and action request callback not set."); return false; } @@ -971,8 +971,8 @@ bool EnablerParticipant::query_action_nts_( lck)) { EPROSIMA_LOG_ERROR(DDSENABLER_ENABLER_PARTICIPANT, - "Failed to announce action " << action.action_name << - " : feedback topic writer creation failed."); + "Failed to announce action " << action.action_name + << " : feedback topic writer creation failed."); return false; } } @@ -1001,8 +1001,8 @@ bool EnablerParticipant::query_action_nts_( lck)) { EPROSIMA_LOG_ERROR(DDSENABLER_ENABLER_PARTICIPANT, - "Failed to announce action " << action.action_name << - " : status topic writer creation failed."); + "Failed to announce action " << action.action_name + << " : status topic writer creation failed."); return false; } } @@ -1042,8 +1042,8 @@ bool EnablerParticipant::create_topic_writer_nts_( })) { EPROSIMA_LOG_ERROR(DDSENABLER_ENABLER_PARTICIPANT, - "Failed to create internal reader for topic " << topic.m_topic_name << - " , please verify that the topic is allowed."); + "Failed to create internal reader for topic " << topic.m_topic_name + << " , please verify that the topic is allowed."); return false; } @@ -1074,8 +1074,8 @@ bool EnablerParticipant::create_service_request_writer_nts_( } EPROSIMA_LOG_ERROR(DDSENABLER_ENABLER_PARTICIPANT, - "Failed to create server as there is already a server running for service " << service->service_name << - "."); + "Failed to create server as there is already a server running for service " << service->service_name + << "."); return false; } diff --git a/ddsenabler_participants/src/cpp/Handler.cpp b/ddsenabler_participants/src/cpp/Handler.cpp index 468d7e94..994c20d8 100644 --- a/ddsenabler_participants/src/cpp/Handler.cpp +++ b/ddsenabler_participants/src/cpp/Handler.cpp @@ -671,9 +671,9 @@ bool Handler::register_type_nts_( if (_type_name != type_name) { EPROSIMA_LOG_ERROR(DDSENABLER_HANDLER, - "Unexpected dynamic types collection format: " << type_name << " expected to be last item, found " << - _type_name << - " instead."); + "Unexpected dynamic types collection format: " << type_name << " expected to be last item, found " + << _type_name + << " instead."); return false; } diff --git a/ddsenabler_participants/src/cpp/rpc/RpcStructs.cpp b/ddsenabler_participants/src/cpp/rpc/RpcStructs.cpp index 16a5e98f..a912fabf 100644 --- a/ddsenabler_participants/src/cpp/rpc/RpcStructs.cpp +++ b/ddsenabler_participants/src/cpp/rpc/RpcStructs.cpp @@ -166,8 +166,8 @@ void RpcInfo::extract_rpc_info() else { EPROSIMA_LOG_ERROR(DDSENABLER_RPC_UTILS, - "Failed to extract RPC info from topic name " << topic_name << - ": unknown action request type suffix"); + "Failed to extract RPC info from topic name " << topic_name + << ": unknown action request type suffix"); throw std::runtime_error("Unknown action request type suffix"); } return; @@ -215,8 +215,8 @@ void RpcInfo::extract_rpc_info() else { EPROSIMA_LOG_ERROR(DDSENABLER_RPC_UTILS, - "Failed to extract RPC info from topic name " << topic_name << - ": unknown action reply type suffix"); + "Failed to extract RPC info from topic name " << topic_name + << ": unknown action reply type suffix"); throw std::runtime_error("Unknown action reply type suffix"); } return; diff --git a/ddsenabler_yaml/src/cpp/EnablerConfiguration.cpp b/ddsenabler_yaml/src/cpp/EnablerConfiguration.cpp index eb8a6ef4..33af68ee 100644 --- a/ddsenabler_yaml/src/cpp/EnablerConfiguration.cpp +++ b/ddsenabler_yaml/src/cpp/EnablerConfiguration.cpp @@ -338,8 +338,8 @@ void EnablerConfiguration::load_ddsenabler_configuration_from_yaml_file_( catch (const std::exception& e) { throw eprosima::utils::ConfigurationException( - utils::Formatter() << "Error loading DDS Enabler configuration from file: <" << file_path << - "> :\n " << e.what()); + utils::Formatter() << "Error loading DDS Enabler configuration from file: <" << file_path + << "> :\n " << e.what()); } } else @@ -384,8 +384,8 @@ void EnablerConfiguration::load_ddsenabler_configuration_from_json_file_( else { throw eprosima::utils::ConfigurationException( - utils::Formatter() << - "\"ddsmodule\" not found or is not an object within \"dds\" in the JSON file"); + utils::Formatter() + << "\"ddsmodule\" not found or is not an object within \"dds\" in the JSON file"); } } else @@ -398,8 +398,8 @@ void EnablerConfiguration::load_ddsenabler_configuration_from_json_file_( catch (const std::exception& e) { throw eprosima::utils::ConfigurationException( - utils::Formatter() << "Error loading DDS Enabler configuration from file: <" << file_path << - "> :\n " << e.what()); + utils::Formatter() << "Error loading DDS Enabler configuration from file: <" << file_path + << "> :\n " << e.what()); } } else