signal.hpp

Go to the documentation of this file.

// === AUDIT STATUS ===
// internal:    { status: not started, auditors: [], date: YYYY-MM-DD }
// external_1:  { status: not started, auditors: [], date: YYYY-MM-DD }
// external_2:  { status: not started, auditors: [], date: YYYY-MM-DD }
// =====================
 
#pragma once
#include <atomic>
#include <cstdint>
 
namespace bb::crypto::merkle_tree {
class Signal {
  public:
    Signal(uint32_t initial_level = 1)
        : signal_(initial_level) {};
    ~Signal() = default;
    Signal(const Signal& other)
        : signal_(other.signal_.load())
    {}
    Signal(const Signal&& other) = delete;
    Signal& operator=(const Signal& other)
    {
        if (this != &other) {
            signal_.store(other.signal_.load());
        }
        return *this;
    }
    Signal& operator=(const Signal&& other) = delete;
 
    void wait_for_level(uint32_t level = 0)
    {
        uint32_t current_level = signal_.load();
        while (current_level > level) {
            signal_.wait(current_level);
            current_level = signal_.load();
        }
    }
 
    void signal_level(uint32_t level = 0)
    {
        signal_.store(level);
        signal_.notify_all();
    }
 
    void signal_decrement(uint32_t delta = 1)
    {
        signal_.fetch_sub(delta);
        signal_.notify_all();
    }
 
  private:
    std::atomic<uint32_t> signal_;
};
} // namespace bb::crypto::merkle_tree