Format sources

Author: vertexodessa

app/wfbngrtl8812/src/main/cpp/FecChangeController.h

@@ -1,19 +1,17 @@
 #pragma once
 
-#include <mutex>
-#include <chrono>
 #include <android/log.h>
+#include <chrono>
+#include <mutex>
 
-class FecChangeController
-{
+class FecChangeController {
     static constexpr const char *TAG = "FecChangeController";
-public:
+
+  public:
     /// \brief Query the current (possibly decayed) fec_change value.
     ///        Call this as often as you like; the class handles its own timing.
-    int value()
-    {
-        if (!mEnabled)
-            return 0;
+    int value() {
+        if (!mEnabled) return 0;
 
         std::lock_guard<std::mutex> lock(mx_);
         decayLocked_();
@@ -22,52 +20,47 @@ class FecChangeController
 
     /// \brief Raise fec_change.  If newValue <= current, the call is ignored.
     ///        A successful bump resets the 5-second “hold” timer.
-    void bump(int newValue)
-    {
+    void bump(int newValue) {
         std::lock_guard<std::mutex> lock(mx_);
         if (newValue > val_) {
             __android_log_print(ANDROID_LOG_ERROR, TAG, "bumping FEC: %d", newValue);
 
-            val_        = newValue;
+            val_ = newValue;
             lastChange_ = Clock::now();
         }
     }
 
-    void setEnabled(bool use){
-        mEnabled = use;
-    }
+    void setEnabled(bool use) { mEnabled = use; }
 
-private:
+  private:
     using Clock = std::chrono::steady_clock;
-    static constexpr std::chrono::seconds kTick{1};   // length of one hold/decay window
+    static constexpr std::chrono::seconds kTick{1}; // length of one hold/decay window
 
-    void decayLocked_()
-    {
+    void decayLocked_() {
         if (val_ == 0) return;
 
-        auto now     = Clock::now();
+        auto now = Clock::now();
         auto elapsed = now - lastChange_;
 
         // Still inside the mandatory 5-second hold?  Do nothing.
         if (elapsed < kTick) return;
 
         // How many *full* ticks have passed since lastChange_?
         auto ticks = std::chrono::duration_cast<std::chrono::seconds>(elapsed).count() / kTick.count();
-        if (ticks == 0) return;   // safety net (shouldn’t hit)
+        if (ticks == 0) return; // safety net (shouldn’t hit)
 
         int decayed = val_ - static_cast<int>(ticks);
         if (decayed < 0) decayed = 0;
 
         // Commit the decay and anchor lastChange_ on the most recent tick boundary
         if (decayed != val_) {
-            val_        = decayed;
+            val_ = decayed;
             lastChange_ += kTick * ticks;
         }
     }
 
-    int                   val_        {0};
-    Clock::time_point     lastChange_ {Clock::now()};
-    std::mutex            mx_;
+    int val_{0};
+    Clock::time_point lastChange_{Clock::now()};
+    std::mutex mx_;
     bool mEnabled = false;
 };
-

app/wfbngrtl8812/src/main/cpp/WfbngLink.cpp

@@ -33,7 +33,11 @@
 #undef TAG
 #define TAG "pixelpilot"
 
-#define CRASH() do{ int* i=0; *i = 42; }while(0)
+#define CRASH()                                                                                                        \
+    do {                                                                                                               \
+        int *i = 0;                                                                                                    \
+        *i = 42;                                                                                                       \
+    } while (0)
 
 std::string generate_random_string(size_t length) {
     const std::string characters = "abcdefghijklmnopqrstuvwxyz";
@@ -470,16 +474,11 @@ void WfbngLink::start_link_quality_thread(int fd) {
                 if (quality.lost_last_second > 2)
                     fec.bump(5);
                 else {
-                    if(quality.recovered_last_second > 30)
-                        fec.bump(5);
-                    if (quality.recovered_last_second > 24)
-                        fec.bump(3);
-                    if (quality.recovered_last_second > 22)
-                        fec.bump(2);
-                    if (quality.recovered_last_second > 18)
-                        fec.bump(1);
-                    if (quality.recovered_last_second < 18)
-                        fec.bump(0);
+                    if (quality.recovered_last_second > 30) fec.bump(5);
+                    if (quality.recovered_last_second > 24) fec.bump(3);
+                    if (quality.recovered_last_second > 22) fec.bump(2);
+                    if (quality.recovered_last_second > 18) fec.bump(1);
+                    if (quality.recovered_last_second < 18) fec.bump(0);
                 }
 
                 snprintf(message + sizeof(len),
@@ -560,7 +559,7 @@ extern "C" JNIEXPORT void JNICALL Java_com_openipc_wfbngrtl8812_WfbNgLink_native
 }
 
 extern "C" JNIEXPORT void JNICALL Java_com_openipc_wfbngrtl8812_WfbNgLink_nativeSetUseFec(JNIEnv *env,
-                                                                                           jclass clazz,
+                                                                                          jclass clazz,
                                                                                           jlong wfbngLinkN,
                                                                                           jint use) {
     WfbngLink *link = native(wfbngLinkN);

app/wfbngrtl8812/src/main/cpp/WfbngLink.hpp

@@ -2,8 +2,8 @@
 #define FPV_VR_WFBNG_LINK_H
 
 #include "FecChangeController.h"
-#include "TxFrame.h"
 #include "SignalQualityCalculator.h"
+#include "TxFrame.h"
 
 extern "C" {
 #include "wfb-ng/src/fec.h"