Format code.

Author: Jiu-xiao

SharedTopic.hpp

@@ -27,22 +27,19 @@ required_hardware: uart_name, ramfs
 #include "thread.hpp"
 #include "uart.hpp"
 
-class SharedTopic : public LibXR::Application
-{
+class SharedTopic : public LibXR::Application {
  public:
   SharedTopic(LibXR::HardwareContainer &hw, LibXR::ApplicationManager &app,
-              const char *uart_name, uint32_t task_stack_depth, uint32_t buffer_size,
+              const char *uart_name, uint32_t task_stack_depth,
+              uint32_t buffer_size,
               std::initializer_list<const char *> topic_names)
       : uart_(hw.template Find<LibXR::UART>(uart_name)),
         server_(buffer_size),
         rx_buffer_(new uint8_t[buffer_size], buffer_size),
-        cmd_file_(LibXR::RamFS::CreateFile("shared_topic", CommandFunc, this))
-  {
-    for (const char *name : topic_names)
-    {
+        cmd_file_(LibXR::RamFS::CreateFile("shared_topic", CommandFunc, this)) {
+    for (const char *name : topic_names) {
       auto topic = LibXR::Topic::Find(name);
-      if (topic == nullptr)
-      {
+      if (topic == nullptr) {
         XR_LOG_ERROR("Topic not found: %s", name);
         ASSERT(false);
       }
@@ -51,27 +48,24 @@ class SharedTopic : public LibXR::Application
 
     hw.template FindOrExit<LibXR::RamFS>({"ramfs"})->Add(cmd_file_);
 
-    rx_thread_.Create(this, RxThreadFun, "SharedTopic::RxThread", task_stack_depth,
-                      LibXR::Thread::Priority::REALTIME);
+    rx_thread_.Create(this, RxThreadFun, "SharedTopic::RxThread",
+                      task_stack_depth, LibXR::Thread::Priority::REALTIME);
 
     app.Register(*this);
   }
 
-  static void RxThreadFun(SharedTopic *self)
-  {
+  static void RxThreadFun(SharedTopic *self) {
     LibXR::Semaphore sem;
     LibXR::ReadOperation op(sem);
-    while (true)
-    {
-      auto size =
-          LibXR::max(sizeof(LibXR::Topic::PackedDataHeader),
-                     LibXR::min(self->uart_->read_port_.Size(), self->rx_buffer_.size_));
-      auto ans =
-          self->uart_->read_port_(LibXR::RawData{self->rx_buffer_.addr_, size}, op);
-
-      if (ans == ErrorCode::OK)
-      {
-        auto ans = self->server_.ParseData(LibXR::RawData{self->rx_buffer_.addr_, size});
+    while (true) {
+      auto size = LibXR::max(
+          sizeof(LibXR::Topic::PackedDataHeader),
+          LibXR::min(self->uart_->read_port_.Size(), self->rx_buffer_.size_));
+      auto ans = self->uart_->read_port_(
+          LibXR::RawData{self->rx_buffer_.addr_, size}, op);
+
+      if (ans == ErrorCode::OK) {
+        self->server_.ParseData(LibXR::RawData{self->rx_buffer_.addr_, size});
       }
 
       self->rx_count_ += size;
@@ -80,34 +74,27 @@ class SharedTopic : public LibXR::Application
 
   void OnMonitor() override {}
 
-  static int CommandFunc(SharedTopic *self, int argc, char **argv)
-  {
-    if (argc == 1)
-    {
+  static int CommandFunc(SharedTopic *self, int argc, char **argv) {
+    if (argc == 1) {
       LibXR::STDIO::Printf("Usage:\r\n");
-      LibXR::STDIO::Printf("  monitor [time_ms] [interval_ms] - test received speed\r\n");
+      LibXR::STDIO::Printf(
+          "  monitor [time_ms] [interval_ms] - test received speed\r\n");
       return 0;
-    }
-    else if (argc == 4)
-    {
-      if (strcmp(argv[1], "monitor") == 0)
-      {
+    } else if (argc == 4) {
+      if (strcmp(argv[1], "monitor") == 0) {
         int time = atoi(argv[2]);
         int delay = atoi(argv[3]);
         auto start = self->rx_count_;
-        while (time > 0)
-        {
+        while (time > 0) {
           LibXR::Thread::Sleep(delay);
           LibXR::STDIO::Printf(
-              "%f Mbps\r\n", static_cast<float>(self->rx_count_ - start) * 8.0 / 1024.0 /
-                                 1024.0 / delay * 1000.0);
+              "%f Mbps\r\n", static_cast<float>(self->rx_count_ - start) * 8.0 /
+                                 1024.0 / 1024.0 / delay * 1000.0);
           time -= delay;
           start = self->rx_count_;
         }
       }
-    }
-    else
-    {
+    } else {
       LibXR::STDIO::Printf("Error: Invalid arguments.\r\n");
       return -1;
     }