mirror of
https://github.com/meshtastic/firmware.git
synced 2025-02-26 22:33:24 +00:00
0d758347af
* fix assertion failure ``` 22:57:36 64409 [PositionPlugin] FIXME-update-db Sniffing packet 22:57:36 64409 [PositionPlugin] Delivering rx packet (id=0x5851f437 Fr0xa1 To0xff, WantAck0, HopLim3 Ch0x0 Portnum=3 rxtime=1628895456 priority=10) 22:57:36 64409 [PositionPlugin] Forwarding to phone (id=0x5851f437 Fr0xa1 To0xff, WantAck0, HopLim3 Ch0x0 Portnum=3 rxtime=1628895456 priority=10) 22:57:36 64409 [PositionPlugin] Update DB node 0x85f4da1, rx_time=1628895456 22:57:36 64409 [PositionPlugin] Plugin routing considered 22:57:36 64409 [PositionPlugin] Add packet record (id=0x5851f437 Fr0xa1 To0xff, WantAck0, HopLim3 Ch0x0 Portnum=3 rxtime=1628895456 priority=10) 22:57:36 64409 [PositionPlugin] Expanding short PSK #1 22:57:36 64409 [PositionPlugin] Installing AES128 key! 22:57:36 64409 [PositionPlugin] enqueuing for send (id=0x5851f437 Fr0xa1 To0xff, WantAck0, HopLim3 Ch0xb1 encrypted rxtime=1628895456 priority=10) 22:57:36 64409 [PositionPlugin] (bw=125, sf=12, cr=4/8) packet symLen=32 ms, payloadSize=22, time 2596 ms 22:57:36 64409 [PositionPlugin] txGood=6,rxGood=10,rxBad=0 22:57:36 64409 [PositionPlugin] AirTime - Packet transmitted : 2596ms 22:57:36 64409 [RadioIf] assert failed src/mesh/RadioLibInterface.cpp: 240, void RadioLibInterface::handleReceiveInterrupt(), test=isReceiving ```
94 lines
2.0 KiB
C++
94 lines
2.0 KiB
C++
#include "configuration.h"
|
|
#include "NotifiedWorkerThread.h"
|
|
#include "main.h"
|
|
#include <assert.h>
|
|
|
|
namespace concurrency
|
|
{
|
|
|
|
static bool debugNotification;
|
|
|
|
/**
|
|
* Notify this thread so it can run
|
|
*/
|
|
bool NotifiedWorkerThread::notify(uint32_t v, bool overwrite)
|
|
{
|
|
bool r = notifyCommon(v, overwrite);
|
|
|
|
if (r)
|
|
mainDelay.interrupt();
|
|
|
|
return r;
|
|
}
|
|
|
|
/**
|
|
* Notify this thread so it can run
|
|
*/
|
|
IRAM_ATTR bool NotifiedWorkerThread::notifyCommon(uint32_t v, bool overwrite)
|
|
{
|
|
if (overwrite || notification == 0) {
|
|
enabled = true;
|
|
setInterval(0); // Run ASAP
|
|
runASAP = true;
|
|
|
|
notification = v;
|
|
if (debugNotification)
|
|
DEBUG_MSG("setting notification %d\n", v);
|
|
return true;
|
|
} else {
|
|
if (debugNotification)
|
|
DEBUG_MSG("dropping notification %d\n", v);
|
|
return false;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Notify from an ISR
|
|
*
|
|
* This must be inline or IRAM_ATTR on ESP32
|
|
*/
|
|
IRAM_ATTR bool NotifiedWorkerThread::notifyFromISR(BaseType_t *highPriWoken, uint32_t v, bool overwrite)
|
|
{
|
|
bool r = notifyCommon(v, overwrite);
|
|
if (r)
|
|
mainDelay.interruptFromISR(highPriWoken);
|
|
|
|
return r;
|
|
}
|
|
|
|
/**
|
|
* Schedule a notification to fire in delay msecs
|
|
*/
|
|
bool NotifiedWorkerThread::notifyLater(uint32_t delay, uint32_t v, bool overwrite)
|
|
{
|
|
bool didIt = notify(v, overwrite);
|
|
|
|
if (didIt) { // If we didn't already have something queued, override the delay to be larger
|
|
setIntervalFromNow(delay); // a new version of setInterval relative to the current time
|
|
if (debugNotification)
|
|
DEBUG_MSG("delaying notification %u\n", delay);
|
|
}
|
|
|
|
return didIt;
|
|
}
|
|
|
|
void NotifiedWorkerThread::checkNotification()
|
|
{
|
|
auto n = notification;
|
|
notification = 0; // clear notification
|
|
if (n) {
|
|
onNotify(n);
|
|
}
|
|
}
|
|
|
|
|
|
|
|
int32_t NotifiedWorkerThread::runOnce()
|
|
{
|
|
enabled = false; // Only run once per notification
|
|
checkNotification();
|
|
|
|
return RUN_SAME;
|
|
}
|
|
|
|
} // namespace concurrency
|