mirror of
https://github.com/alexhopeoconnor/firmware.git
synced 2026-10-14 07:21:30 +10:00
Mike RobbinsandBen Meadors
8feb34e7a8
* Fix potential race condition (read, ISR write, clear) in NotifiedWorkerThread * Check for missed edge-triggered interrupts race condition between startReceive and enableInterrupt * Occasionally poll to catch missed RX_DONE interrupts. (RadioLibInterface::pollMissedIrqs) * Simplify RadioLibInterface::checkRxDoneIrqFlag() --------- Co-authored-by: Ben Meadors <benmmeadors@gmail.com>
58 lines
1.5 KiB
C++
58 lines
1.5 KiB
C++
#pragma once
|
|
|
|
#include "OSThread.h"
|
|
#include <atomic>
|
|
|
|
namespace concurrency
|
|
{
|
|
|
|
/**
|
|
* @brief A worker thread that waits on a freertos notification
|
|
*/
|
|
class NotifiedWorkerThread : public OSThread
|
|
{
|
|
/**
|
|
* The notification that was most recently used to wake the thread. Read from runOnce()
|
|
*/
|
|
std::atomic<uint32_t> notification{0};
|
|
|
|
public:
|
|
NotifiedWorkerThread(const char *name) : OSThread(name) {}
|
|
|
|
/**
|
|
* Notify this thread so it can run
|
|
*/
|
|
bool notify(uint32_t v, bool overwrite);
|
|
|
|
/**
|
|
* Notify from an ISR
|
|
*
|
|
* This must be inline or IRAM_ATTR on ESP32
|
|
*/
|
|
bool notifyFromISR(BaseType_t *highPriWoken, uint32_t v, bool overwrite);
|
|
|
|
/**
|
|
* Schedule a notification to fire in delay msecs
|
|
*/
|
|
bool notifyLater(uint32_t delay, uint32_t v, bool overwrite);
|
|
|
|
protected:
|
|
virtual void onNotify(uint32_t notification) = 0;
|
|
|
|
/// just calls checkNotification()
|
|
virtual int32_t runOnce() override;
|
|
|
|
/// Sometimes we might want to check notifications independently of when our thread was getting woken up (i.e. if we are about
|
|
/// to change radio transmit/receive modes we want to handle any pending interrupts first). You can call this method and if
|
|
/// any notifications are currently pending they will be handled immediately.
|
|
void checkNotification();
|
|
|
|
private:
|
|
/**
|
|
* Notify this thread so it can run
|
|
*/
|
|
bool notifyCommon(uint32_t v, bool overwrite);
|
|
};
|
|
|
|
} // namespace concurrency
|