Apply expected formatting for C, C++, Java, Python

Author: alexcamposruiz

tutorials/content_filtering/c++11/home_automation_publisher.cxx

@@ -16,8 +16,8 @@
 #include "home_automation.hpp"
 
 void publish_sensor(
-    const std::string& sensor_name,
-    const std::string& room_name)
+        const std::string &sensor_name,
+        const std::string &room_name)
 {
     dds::domain::DomainParticipant participant(0);
     dds::topic::Topic<DeviceStatus> topic(participant, "WindowStatus");

tutorials/content_filtering/c++11/home_automation_subscriber.cxx

@@ -30,16 +30,16 @@ int main(int argc, char **argv)
     rti::sub::SampleProcessor sample_processor;
     sample_processor.attach_reader(
             reader,
-            [](const rti::sub::LoanedSample<DeviceStatus>& sample)
-            {
-                if (sample.info().valid()) { // ignore samples with only meta-data
+            [](const rti::sub::LoanedSample<DeviceStatus> &sample) {
+                if (sample.info().valid()) {  // ignore samples with only
+                                              // meta-data
                     std::cout << "WARNING: " << sample.data().sensor_name()
-                            << " in " << sample.data().room_name()
-                            << " is open!" << std::endl;
+                              << " in " << sample.data().room_name()
+                              << " is open!" << std::endl;
                 }
             });
 
-    while (true) { // wait in a loop
+    while (true) {  // wait in a loop
         std::this_thread::sleep_for(std::chrono::seconds(4));
     }
 }

tutorials/content_filtering/c++11/home_automation_subscriber_update_filter.cxx

@@ -25,25 +25,29 @@ int main(int argc, char **argv)
     dds::topic::ContentFilteredTopic<DeviceStatus> content_filtered_topic(
             topic,
             "FilterRoomAndOpenWindows",
-            dds::topic::Filter("is_open = true and room_name = %0", parameters));
+            dds::topic::Filter(
+                    "is_open = true and room_name = %0",
+                    parameters));
     dds::sub::DataReader<DeviceStatus> reader(content_filtered_topic);
 
     parameters[0] = "'Kitchen'";
-    content_filtered_topic.filter_parameters(parameters.begin(), parameters.end());
+    content_filtered_topic.filter_parameters(
+            parameters.begin(),
+            parameters.end());
 
     rti::sub::SampleProcessor sample_processor;
     sample_processor.attach_reader(
             reader,
-            [](const rti::sub::LoanedSample<DeviceStatus>& sample)
-            {
-                if (sample.info().valid()) { // ignore samples with only meta-data
+            [](const rti::sub::LoanedSample<DeviceStatus> &sample) {
+                if (sample.info().valid()) {  // ignore samples with only
+                                              // meta-data
                     std::cout << "WARNING: " << sample.data().sensor_name()
-                            << " in " << sample.data().room_name()
-                            << " is open!" << std::endl;
+                              << " in " << sample.data().room_name()
+                              << " is open!" << std::endl;
                 }
             });
 
-    while (true) { // wait in a loop
+    while (true) {  // wait in a loop
         std::this_thread::sleep_for(std::chrono::seconds(4));
     }
 }

tutorials/content_filtering/py/home_automation_subscriber_update_filter.py

@@ -20,7 +20,9 @@ async def sensor_monitoring():
     content_filtered_topic = dds.ContentFilteredTopic(
         topic,
         "FilterRoomAndOpenWindows",
-        dds.Filter("is_open = true and room_name = %0", parameters=["'LivingRoom'"]),
+        dds.Filter(
+            "is_open = true and room_name = %0", parameters=["'LivingRoom'"]
+        ),
     )
     reader = dds.DataReader(content_filtered_topic)
 

tutorials/data_persistence/c++11/temperature_durable_publisher.cxx

@@ -15,19 +15,24 @@
 #include <rti/rti.hpp>
 #include "temperature.hpp"
 
-void publish_temperature(const std::string& sensor_name)
+void publish_temperature(const std::string &sensor_name)
 {
     dds::domain::DomainParticipant participant(0);
     dds::topic::Topic<Temperature> topic(participant, "Temperature");
 
     dds::pub::qos::DataWriterQos writer_qos {
-            dds::core::QosProvider::Default().datawriter_qos("MyLibrary::Persistence")
+        dds::core::QosProvider::Default().datawriter_qos(
+                "MyLibrary::Persistence")
     };
 
-    writer_qos.policy<dds::core::policy::Durability>().extensions()
-            .storage_settings().enable(true);
-    writer_qos.policy<dds::core::policy::Durability>().extensions()
-            .storage_settings().file_name(sensor_name);
+    writer_qos.policy<dds::core::policy::Durability>()
+            .extensions()
+            .storage_settings()
+            .enable(true);
+    writer_qos.policy<dds::core::policy::Durability>()
+            .extensions()
+            .storage_settings()
+            .file_name(sensor_name);
 
     dds::pub::DataWriter<Temperature> writer(topic, writer_qos);
 

tutorials/data_persistence/c++11/temperature_durable_subscriber.cxx

@@ -24,21 +24,25 @@ void sensor_monitoring(std::string subscriber_name)
     dds::topic::Topic<Temperature> topic(participant, "Temperature");
 
     dds::sub::qos::DataReaderQos reader_qos {
-            dds::core::QosProvider::Default().datareader_qos("MyLibrary::Persistence")
+        dds::core::QosProvider::Default().datareader_qos(
+                "MyLibrary::Persistence")
     };
 
-    reader_qos.policy<dds::core::policy::Durability>().extensions()
-            .storage_settings().enable(true);
-    reader_qos.policy<dds::core::policy::Durability>().extensions()
-            .storage_settings().file_name(subscriber_name);
+    reader_qos.policy<dds::core::policy::Durability>()
+            .extensions()
+            .storage_settings()
+            .enable(true);
+    reader_qos.policy<dds::core::policy::Durability>()
+            .extensions()
+            .storage_settings()
+            .file_name(subscriber_name);
 
     dds::sub::DataReader<Temperature> reader(topic, reader_qos);
 
     rti::sub::SampleProcessor sample_processor;
     sample_processor.attach_reader(
             reader,
-            [](const rti::sub::LoanedSample<Temperature>& sample)
-            {
+            [](const rti::sub::LoanedSample<Temperature> &sample) {
                 if (!sample.info().valid()) {
                     // ignore samples with only meta-data
                     return;
@@ -47,13 +51,13 @@ void sensor_monitoring(std::string subscriber_name)
                 uint64_t timestamp =
                         sample.info().source_timestamp().to_millisecs();
 
-                std::cout << sample.data().sensor_name() << ": "
-                        << std::fixed << std::setprecision(2)
-                        << sample.data().degrees() << " degrees ("
-                        << timestamp / 1000.0 << "s)" << std::endl;
+                std::cout << sample.data().sensor_name() << ": " << std::fixed
+                          << std::setprecision(2) << sample.data().degrees()
+                          << " degrees (" << timestamp / 1000.0 << "s)"
+                          << std::endl;
             });
 
-    while (true) { // wait in a loop
+    while (true) {  // wait in a loop
         std::this_thread::sleep_for(std::chrono::seconds(4));
     }
 }

tutorials/data_persistence/c++11/temperature_publisher.cxx

@@ -15,7 +15,7 @@
 #include <rti/rti.hpp>
 #include "temperature.hpp"
 
-void publish_temperature(const std::string& sensor_name)
+void publish_temperature(const std::string &sensor_name)
 {
     dds::domain::DomainParticipant participant(0);
     dds::topic::Topic<Temperature> topic(participant, "Temperature");

tutorials/data_persistence/c++11/temperature_subscriber.cxx

@@ -26,8 +26,7 @@ int main(int argc, char **argv)
     rti::sub::SampleProcessor sample_processor;
     sample_processor.attach_reader(
             reader,
-            [](const rti::sub::LoanedSample<Temperature>& sample)
-            {
+            [](const rti::sub::LoanedSample<Temperature> &sample) {
                 if (!sample.info().valid()) {
                     // ignore samples with only meta-data
                     return;
@@ -36,13 +35,13 @@ int main(int argc, char **argv)
                 uint64_t timestamp =
                         sample.info().source_timestamp().to_millisecs();
 
-                std::cout << sample.data().sensor_name() << ": "
-                        << std::fixed << std::setprecision(2)
-                        << sample.data().degrees() << " degrees ("
-                        << timestamp / 1000.0 << "s)" << std::endl;
+                std::cout << sample.data().sensor_name() << ": " << std::fixed
+                          << std::setprecision(2) << sample.data().degrees()
+                          << " degrees (" << timestamp / 1000.0 << "s)"
+                          << std::endl;
             });
 
-    while (true) { // wait in a loop
+    while (true) {  // wait in a loop
         std::this_thread::sleep_for(std::chrono::seconds(4));
     }
 }

tutorials/data_persistence/py/temperature.py

@@ -11,9 +11,8 @@
 
 import rti.types as idl
 
-@idl.struct(
-    member_annotations={"sensor_name": [idl.key, idl.bound(100)]}
-)
+
+@idl.struct(member_annotations={"sensor_name": [idl.key, idl.bound(100)]})
 class Temperature:
     sensor_name: str = ""
     degrees: float = 0.0

tutorials/data_persistence/py/temperature_durable_publisher.py

@@ -16,6 +16,7 @@
 import rti.connextdds as dds
 from temperature import Temperature
 
+
 def publish_temperature(sensor_name: str):
     participant = dds.DomainParticipant(domain_id=0)
     topic = dds.Topic(participant, "Temperature", Temperature)

tutorials/data_persistence/py/temperature_durable_subscriber.py

@@ -34,9 +34,7 @@ async def sensor_monitoring(subscriber_name: str):
             continue  # skip updates with only meta-data
 
         timestamp = datetime.fromtimestamp(info.source_timestamp.to_seconds())
-        print(
-            f"{data.sensor_name}: {data.degrees:.2f} degrees ({timestamp})"
-        )
+        print(f"{data.sensor_name}: {data.degrees:.2f} degrees ({timestamp})")
 
 
 if __name__ == "__main__":

tutorials/data_persistence/py/temperature_publisher.py

@@ -16,6 +16,7 @@
 import rti.connextdds as dds
 from temperature import Temperature
 
+
 def publish_temperature(sensor_name: str):
     participant = dds.DomainParticipant(domain_id=0)
     topic = dds.Topic(participant, "Temperature", Temperature)

tutorials/data_persistence/py/temperature_subscriber.py

@@ -26,9 +26,7 @@ async def sensor_monitoring():
             continue  # skip updates with only meta-data
 
         timestamp = datetime.fromtimestamp(info.source_timestamp.to_seconds())
-        print(
-            f"{data.sensor_name}: {data.degrees:.2f} degrees ({timestamp})"
-        )
+        print(f"{data.sensor_name}: {data.degrees:.2f} degrees ({timestamp})")
 
 
 if __name__ == "__main__":

tutorials/discovery/c++11/home_automation_publisher.cxx

@@ -16,8 +16,8 @@
 #include "home_automation.hpp"
 
 void publish_sensor(
-    const std::string& sensor_name,
-    const std::string& room_name)
+        const std::string &sensor_name,
+        const std::string &room_name)
 {
     dds::domain::DomainParticipant participant(0);
     dds::topic::Topic<DeviceStatus> topic(participant, "WindowStatus");

tutorials/discovery/c++11/home_automation_subscriber.cxx

@@ -17,16 +17,14 @@
 #include "rti/sub/SampleProcessor.hpp"
 #include "home_automation.hpp"
 
-class SensorListener
-        : public dds::sub::NoOpDataReaderListener<DeviceStatus> {
-
+class SensorListener : public dds::sub::NoOpDataReaderListener<DeviceStatus> {
     void on_subscription_matched(
             dds::sub::DataReader<DeviceStatus> &reader,
             const dds::core::status::SubscriptionMatchedStatus &status) override
     {
-        std::cout << std::endl << "Total publishers: " << status.current_count()
-                << ", Change: " << status.current_count_change()
-                << std::endl;
+        std::cout << std::endl
+                  << "Total publishers: " << status.current_count()
+                  << ", Change: " << status.current_count_change() << std::endl;
 
         dds::core::InstanceHandleSeq publications =
                 dds::sub::matched_publications(reader);
@@ -37,11 +35,12 @@ class SensorListener
 
             std::cout << "Publisher " << i << ": " << std::endl;
             std::cout << "    Publisher Virtual GUID: "
-                    << pub_data.extensions().virtual_guid() << std::endl;
+                      << pub_data.extensions().virtual_guid() << std::endl;
             std::cout << "    Publisher Name: "
-                    << (pub_data.extensions().publication_name().name()
-                            ? pub_data->publication_name().name().value()
-                            : "(N/A)") << std::endl;
+                      << (pub_data.extensions().publication_name().name()
+                                  ? pub_data->publication_name().name().value()
+                                  : "(N/A)")
+                      << std::endl;
         }
     }
 };
@@ -61,18 +60,18 @@ int main(int argc, char **argv)
     rti::sub::SampleProcessor sample_processor;
     sample_processor.attach_reader(
             reader,
-            [](const rti::sub::LoanedSample<DeviceStatus>& sample)
-            {
-                if (sample.info().valid()) { // ignore samples with only meta-data
+            [](const rti::sub::LoanedSample<DeviceStatus> &sample) {
+                if (sample.info().valid()) {  // ignore samples with only
+                                              // meta-data
                     if (sample.data().is_open()) {
                         std::cout << "WARNING: " << sample.data().sensor_name()
-                                << " in " << sample.data().room_name()
-                                << " is open!" << std::endl;
+                                  << " in " << sample.data().room_name()
+                                  << " is open!" << std::endl;
                     }
                 }
             });
 
-    while (true) { // wait in a loop
+    while (true) {  // wait in a loop
         std::this_thread::sleep_for(std::chrono::seconds(4));
     }
 }

tutorials/distributed_data_cache/c++11/home_automation_subscriber.cxx

@@ -19,7 +19,8 @@
 
 void wait_for_input(std::string query)
 {
-    std::cout << std::endl << std::endl
+    std::cout << std::endl
+              << std::endl
               << "Press Enter to " << query << std::endl;
     std::cin.get();
 }
@@ -45,10 +46,9 @@ int main(int argc, char **argv)
 
     wait_for_input(
             "obtain all the samples with the attribute is_open set to true.");
-    print_data(
-            reader.select()
-                    .content(dds::sub::Query(reader, "is_open = true"))
-                    .read());
+    print_data(reader.select()
+                       .content(dds::sub::Query(reader, "is_open = true"))
+                       .read());
 
 
     wait_for_input(
@@ -65,7 +65,8 @@ int main(int argc, char **argv)
             "LivingRoom.");
     print_data(
             reader.select()
-                    .content(dds::sub::Query(reader, "room_name = 'LivingRoom'"))
+                    .content(
+                            dds::sub::Query(reader, "room_name = 'LivingRoom'"))
                     .read());
 
 
@@ -78,24 +79,21 @@ int main(int argc, char **argv)
 
 
     wait_for_input("obtain all the samples that you have not read yet.");
-    print_data(
-            reader.select()
-                    .state(dds::sub::status::SampleState::not_read())
-                    .read());
+    print_data(reader.select()
+                       .state(dds::sub::status::SampleState::not_read())
+                       .read());
 
 
     wait_for_input("obtain again, all the samples that you have not read yet.");
-    print_data(
-            reader.select()
-                .state(dds::sub::status::SampleState::not_read())
-                .read());
+    print_data(reader.select()
+                       .state(dds::sub::status::SampleState::not_read())
+                       .read());
 
 
     wait_for_input("obtain the new instances.");
-    print_data(
-            reader.select()
-                    .state(dds::sub::status::ViewState::new_view())
-                    .read());
+    print_data(reader.select()
+                       .state(dds::sub::status::ViewState::new_view())
+                       .read());
 
 
     wait_for_input(