ThreadedBLEMIDISender.hpp

Go to the documentation of this file.

#pragma once
 
#include <Settings/NamespaceSettings.hpp>
 
#include <chrono>
#include <condition_variable>
#include <mutex>
#include <thread>
 
#include "BLEAPI.hpp"
#include <MIDI_Interfaces/BLEMIDI/BLEMIDIPacketBuilder.hpp>
 
BEGIN_CS_NAMESPACE

template <class Derived>
class ThreadedBLEMIDISender {
  public:
    ThreadedBLEMIDISender() = default;
    ThreadedBLEMIDISender(const ThreadedBLEMIDISender &) = delete;
    ThreadedBLEMIDISender &operator=(const ThreadedBLEMIDISender &) = delete;
    ~ThreadedBLEMIDISender();

    void begin();
 
    struct ProtectedBuilder;

    ProtectedBuilder acquirePacket();
    void releasePacketAndNotify(ProtectedBuilder &lck);

    void sendNow(ProtectedBuilder &lck);

    void updateMTU(uint16_t mtu);
    uint16_t getMinMTU() const { return min_mtu; }
    void forceMinMTU(uint16_t mtu);

    void setTimeout(std::chrono::milliseconds timeout);
 
  private:
    void sendData(BLEDataView) = delete; // should be implemented by subclass

    bool handleSendEvents();
 
  private:
    struct {
        BLEMIDIPacketBuilder packet;
        bool stop = false;
        bool flush = false;
        std::chrono::milliseconds timeout {10};
        std::mutex mtx;
    } shared {};
    std::condition_variable cv;
    using lock_t = std::unique_lock<std::mutex>;
    std::thread send_thread;
 
  private:
    std::atomic_uint_fast16_t min_mtu {23};
    std::atomic_uint_fast16_t force_min_mtu {515};
 
  public:
    struct ProtectedBuilder {
        BLEMIDIPacketBuilder *packet;
        lock_t lck;
    };
};
 
END_CS_NAMESPACE
 
#include "ThreadedBLEMIDISender.ipp"