PiPedal 1.2.33 initial commit

2024-08-08 12:53:02 -04:00
parent 0e378997a5
commit a3847c8184
255 changed files with 22008 additions and 1791 deletions
@@ -0,0 +1,58 @@
+#pragma once
+#include <functional>
+#include <atomic>
+#include <map>
+#include <vector>
+#include <mutex>
+#include <memory>
+
+namespace impl {
+    extern std::atomic<uint64_t> NextHandle;
+}
+
+template <typename... ARG_TYPES>
+class DBusEvent {
+public:
+    using Callback=std::function<void (ARG_TYPES...)>;
+    using Handle=uint64_t;
+
+    Handle add(Callback&&cb)
+    {
+        auto handle = impl::NextHandle.fetch_add(1,std::memory_order::acq_rel);
+        {
+            std::lock_guard<std::mutex> lock{m};
+            callbacks[handle] = std::make_shared<Callback>(std::move(cb));
+        }
+        return handle;
+    }
+    void remove(Handle h)
+    {
+        std::lock_guard<std::mutex> lock{m};
+        callbacks.erase(h);
+    }
+
+    void fire(ARG_TYPES...args)
+    {
+        std::vector<std::shared_ptr<Callback>> cbs;
+        cbs.reserve(callbacks.size());
+        {
+            std::lock_guard<std::mutex> lock{m};
+            for (const auto &cb: callbacks)
+            {
+                cbs.push_back(cb.second);
+            }
+        }
+        for (auto&cb: cbs)
+        {
+            (*cb)(args...);
+        }
+        {
+            // destruct shared_ptrs with mutex held.
+            std::lock_guard<std::mutex> lock{m};
+            cbs.clear(); 
+        }
+    }
+private:
+    std::map<Handle,std::shared_ptr<Callback>> callbacks;
+    std::mutex m;
+};