8.0.4

Author: quantum-leaps

.gitignore

@@ -49,6 +49,7 @@ src/qxk/qxk.cpp
 src/qxk/qxk_mutex.cpp
 src/qxk/qxk_sema.cpp
 src/qxk/qxk_xthr.cpp
+zephyr/qutest_port.cpp
 
 ports/arm-cm/qxk/
 ports/arm-cm/qutest/

3rd_party

@@ -51,31 +51,8 @@ class QEvt; // forward declaration
 namespace QP {
 
 class QEQueue {
-private:
-    QEvt const * volatile m_frontEvt;
-    QEvt const * * m_ring;
-    QEQueueCtr m_end;
-    QEQueueCtr volatile m_head;
-    QEQueueCtr volatile m_tail;
-    QEQueueCtr volatile m_nFree;
-    QEQueueCtr m_nMin;
-
-    // friends...
-    friend class QActive;
-    friend class QTicker;
-    friend class QXMutex;
-    friend class QXThread;
-
 public:
-    QEQueue() noexcept
-      : m_frontEvt(nullptr),
-        m_ring(nullptr),
-        m_end(0U),
-        m_head(0U),
-        m_tail(0U),
-        m_nFree(0U),
-        m_nMin(0U)
-    {}
+    QEQueue() noexcept;
     void init(
         QEvt const * * const qSto,
         std::uint_fast16_t const qLen) noexcept;
@@ -96,13 +73,31 @@ class QEQueue {
     bool isEmpty() const noexcept {
         return m_frontEvt == nullptr;
     }
+    QEvt const *peekFront() const noexcept {
+        return m_frontEvt;
+    }
 
 private:
+    QEvt const * volatile m_frontEvt;
+    QEvt const * * m_ring;
+    QEQueueCtr m_end;
+    QEQueueCtr volatile m_head;
+    QEQueueCtr volatile m_tail;
+    QEQueueCtr volatile m_nFree;
+    QEQueueCtr m_nMin;
+
     QEQueue(QEQueue const & other) = delete;
     QEQueue & operator=(QEQueue const & other) = delete;
     void postFIFO_(
         QEvt const * const e,
         void const * const sender);
+
+    // friends...
+    friend class QActive;
+    friend class QTicker;
+    friend class QXMutex;
+    friend class QXThread;
+    friend class QS;
 }; // class QEQueue
 
 } // namespace QP

examples

@@ -41,22 +41,16 @@ extern "C" {
 class QK_Attr {
 public:
     QP::QPSet readySet;
-    std::uint_fast8_t actPrio;
-    std::uint_fast8_t nextPrio;
-    std::uint_fast8_t actThre;
-    std::uint_fast8_t lockCeil;
-    std::uint_fast8_t intNest;
+    std::uint8_t actPrio;
+    std::uint8_t nextPrio;
+    std::uint8_t actThre;
+    std::uint8_t lockCeil;
+    std::uint8_t intNest;
 }; // class QK_Attr
 
 extern QK_Attr QK_priv_;
 
-std::uint_fast8_t QK_sched_() noexcept;
-
-std::uint_fast8_t QK_sched_act_(
-    QP::QActive const * const act,
-    std::uint_fast8_t const pthre_in) noexcept;
-
-void QK_activate_() noexcept;
+// NOTE: the extern "C" QK functions already declared in qp.hpp
 
 } // extern "C"
 

include/qequeue.hpp

@@ -76,15 +76,7 @@ class QMPool {
     QMPoolCtr m_nMin;
 
 public:
-    QMPool()
-      : m_start(nullptr),
-        m_end(nullptr),
-        m_freeHead(nullptr),
-        m_blockSize(0U),
-        m_nTot(0U),
-        m_nFree(0U),
-        m_nMin(0U)
-    {}
+    QMPool() noexcept;
     void init(
         void * const poolSto,
         std::uint_fast32_t const poolSize,
@@ -113,13 +105,16 @@ class QMPool {
     QMPool(QEQueue const & other) = delete;
     QMPool & operator=(QMPool const & other) = delete;
 
+    // friends...
+    friend class QS;
+
 public:
 
 #ifdef QF_ISR_API
     void * getFromISR(
         std::uint_fast16_t const margin,
         std::uint_fast8_t const qsId) noexcept;
-#endif // def QF_ISR_API
+#endif
 
 #ifdef QF_ISR_API
     void putFromISR(