RTOS API for bare metal

Provide partial RTOS API for bare metal builds - things that
can be done in a single threaded environment.

Allows more code to work in both RTOS and bare metal builds without
change, and in particular gives easy access to the ability to
efficiently wait for something occurring in interrupt.

Available in bare-metal:
* ThisThread
* osThreadFlagsSet to set flags on main thread (can be set from IRQ)
* EventFlags (can be set from IRQ)
* Semaphores (can be released from IRQ)
* Mutex (dummy implementation)

Not useful:
* ConditionVariable (could only be signalled from 2nd thread)
* RtosTimer (calls in a second thread context)
* Thread

Unimplemented:
* Mail, Queue, MemoryPool

Possible future work:
* ConditionVariableCS to act as IRQ signalled ConditionVariable

Author: kjbracey

mbed.h

@@ -18,7 +18,7 @@
 
 #include "platform/mbed_version.h"
 
-#if MBED_CONF_RTOS_PRESENT
+#if MBED_CONF_RTOS_API_PRESENT
 #include "rtos/rtos.h"
 #endif
 

rtos/ConditionVariable.cpp

@@ -26,6 +26,8 @@
 #include "mbed_error.h"
 #include "mbed_assert.h"
 
+#if MBED_CONF_RTOS_PRESENT
+
 namespace rtos {
 
 ConditionVariable::Waiter::Waiter(): sem(0), prev(NULL), next(NULL), in_list(false)
@@ -151,3 +153,5 @@ ConditionVariable::~ConditionVariable()
 }
 
 }
+
+#endif

rtos/ConditionVariable.h

@@ -23,12 +23,14 @@
 #define CONDITIONVARIABLE_H
 
 #include <stdint.h>
-#include "cmsis_os.h"
+#include "mbed_rtos_types.h"
 #include "rtos/Mutex.h"
 #include "rtos/Semaphore.h"
 
 #include "platform/NonCopyable.h"
 
+#if MBED_CONF_RTOS_PRESENT || defined(DOXYGEN_ONLY)
+
 namespace rtos {
 /** \addtogroup rtos */
 /** @{*/
@@ -328,4 +330,6 @@ class ConditionVariable : private mbed::NonCopyable<ConditionVariable> {
 }
 #endif
 
+#endif
+
 /** @}*/

rtos/EventFlags.cpp

@@ -20,6 +20,8 @@
  * SOFTWARE.
  */
 #include "rtos/EventFlags.h"
+#include "rtos/ThisThread.h"
+#include "mbed_os_timer.h"
 #include <string.h>
 #include "mbed_error.h"
 #include "mbed_assert.h"
@@ -38,27 +40,43 @@ EventFlags::EventFlags(const char *name)
 
 void EventFlags::constructor(const char *name)
 {
+#if MBED_CONF_RTOS_PRESENT
     osEventFlagsAttr_t attr = { 0 };
     attr.name = name ? name : "application_unnamed_event_flags";
     attr.cb_mem = &_obj_mem;
     attr.cb_size = sizeof(_obj_mem);
     _id = osEventFlagsNew(&attr);
     MBED_ASSERT(_id);
+#else
+    _flags = 0;
+#endif
 }
 
 uint32_t EventFlags::set(uint32_t flags)
 {
+#if MBED_CONF_RTOS_PRESENT
     return osEventFlagsSet(_id, flags);
+#else
+    return core_util_atomic_fetch_or_u32(&_flags, flags) | flags;
+#endif
 }
 
 uint32_t EventFlags::clear(uint32_t flags)
 {
+#if MBED_CONF_RTOS_PRESENT
     return osEventFlagsClear(_id, flags);
+#else
+    return core_util_atomic_fetch_and_u32(&_flags, ~flags);
+#endif
 }
 
 uint32_t EventFlags::get() const
 {
+#if MBED_CONF_RTOS_PRESENT
     return osEventFlagsGet(_id);
+#else
+    return core_util_atomic_load_u32(&_flags);
+#endif
 }
 
 uint32_t EventFlags::wait_all(uint32_t flags, uint32_t millisec, bool clear)
@@ -73,7 +91,9 @@ uint32_t EventFlags::wait_any(uint32_t flags, uint32_t millisec, bool clear)
 
 EventFlags::~EventFlags()
 {
+#if MBED_CONF_RTOS_PRESENT
     osEventFlagsDelete(_id);
+#endif
 }
 
 uint32_t EventFlags::wait(uint32_t flags, uint32_t opt, uint32_t millisec, bool clear)
@@ -82,7 +102,24 @@ uint32_t EventFlags::wait(uint32_t flags, uint32_t opt, uint32_t millisec, bool
         opt |= osFlagsNoClear;
     }
 
+#if MBED_CONF_RTOS_PRESENT
     return osEventFlagsWait(_id, flags, opt, millisec);
+#else
+    rtos::internal::flags_check_capture check;
+    check.flags = &_flags;
+    check.options = opt;
+    check.flags_wanted = flags;
+    check.result = 0;
+    check.match = false;
+    mbed::internal::do_timed_sleep_relative_or_forever(millisec, rtos::internal::non_rtos_check_flags, &check);
+    if (check.match) {
+        return check.result;
+    } else if (millisec == 0) {
+        return osErrorResource;
+    } else {
+        return osErrorTimeout;
+    }
+#endif
 }
 
 }

rtos/EventFlags.h

@@ -23,7 +23,7 @@
 #define EVENT_FLAG_H
 
 #include <stdint.h>
-#include "cmsis_os2.h"
+#include "mbed_rtos_types.h"
 #include "mbed_rtos1_types.h"
 #include "mbed_rtos_storage.h"
 
@@ -114,8 +114,12 @@ class EventFlags : private mbed::NonCopyable<EventFlags> {
 private:
     void constructor(const char *name = NULL);
     uint32_t wait(uint32_t flags, uint32_t opt, uint32_t millisec, bool clear);
+#if MBED_CONF_RTOS_PRESENT
     osEventFlagsId_t                _id;
     mbed_rtos_storage_event_flags_t _obj_mem;
+#else
+    uint32_t _flags;
+#endif
 };
 
 /** @}*/

rtos/Kernel.cpp

@@ -20,16 +20,17 @@
  * SOFTWARE.
  */
 
-#include "cmsis_os2.h"
 #include "rtos/Kernel.h"
 #include "rtos/rtos_idle.h"
 #include "rtos/rtos_handlers.h"
 #include "platform/mbed_critical.h"
+#include "platform/internal/mbed_os_timer.h"
 
 namespace rtos {
 
 uint64_t Kernel::get_ms_count()
 {
+#if MBED_CONF_RTOS_PRESENT
     // CMSIS-RTOS 2.1.0 and 2.1.1 differ in the time type. We assume
     // our header at least matches the implementation, so we don't try looking
     // at the run-time version report. (There's no compile-time version report)
@@ -61,8 +62,12 @@ uint64_t Kernel::get_ms_count()
         core_util_critical_section_exit();
         return ret;
     }
+#else
+    return mbed::internal::init_os_timer()->update_and_get_tick();
+#endif
 }
 
+#if MBED_CONF_RTOS_PRESENT
 void Kernel::attach_idle_hook(void (*fptr)(void))
 {
     rtos_attach_idle_hook(fptr);
@@ -72,5 +77,6 @@ void Kernel::attach_thread_terminate_hook(void (*fptr)(osThreadId_t id))
 {
     rtos_attach_thread_terminate_hook(fptr);
 }
+#endif
 
 }

rtos/Kernel.h

@@ -23,7 +23,7 @@
 #define KERNEL_H
 
 #include <stdint.h>
-#include "cmsis_os2.h"
+#include "mbed_rtos_types.h"
 
 namespace rtos {
 /** \addtogroup rtos */

rtos/Mail.h

@@ -27,7 +27,7 @@
 
 #include "Queue.h"
 #include "MemoryPool.h"
-#include "cmsis_os2.h"
+#include "mbed_rtos_types.h"
 #include "mbed_rtos_storage.h"
 #include "mbed_rtos1_types.h"
 
@@ -37,6 +37,8 @@
 using namespace rtos;
 #endif
 
+#if MBED_CONF_RTOS_PRESENT || defined(DOXYGEN_ONLY)
+
 namespace rtos {
 /** \addtogroup rtos */
 /** @{*/
@@ -175,5 +177,5 @@ class Mail : private mbed::NonCopyable<Mail<T, queue_sz> > {
 
 #endif
 
-
+#endif
 

rtos/MemoryPool.h

@@ -25,11 +25,12 @@
 #include <stdint.h>
 #include <string.h>
 
-#include "cmsis_os2.h"
+#include "mbed_rtos_types.h"
 #include "mbed_rtos1_types.h"
 #include "mbed_rtos_storage.h"
 #include "platform/NonCopyable.h"
 
+#if MBED_CONF_RTOS_PRESENT || defined(DOXYGEN_ONLY)
 namespace rtos {
 /** \addtogroup rtos */
 /** @{*/
@@ -124,4 +125,6 @@ class MemoryPool : private mbed::NonCopyable<MemoryPool<T, pool_sz> > {
 }
 #endif
 
+#endif
+
 

rtos/Mutex.cpp

@@ -26,9 +26,11 @@
 #include "mbed_error.h"
 #include "mbed_assert.h"
 
+#if MBED_CONF_RTOS_PRESENT
+
 namespace rtos {
 
-Mutex::Mutex(): _count(0)
+Mutex::Mutex()
 {
     constructor();
 }
@@ -40,6 +42,7 @@ Mutex::Mutex(const char *name)
 
 void Mutex::constructor(const char *name)
 {
+    _count = 0;
     osMutexAttr_t attr =
     { 0 };
     attr.name = name ? name : "aplication_unnamed_mutex";
@@ -50,9 +53,9 @@ void Mutex::constructor(const char *name)
     MBED_ASSERT(_id);
 }
 
-osStatus Mutex::lock(void)
+osStatus_t Mutex::lock(void)
 {
-    osStatus status = osMutexAcquire(_id, osWaitForever);
+    osStatus_t status = osMutexAcquire(_id, osWaitForever);
     if (osOK == status) {
         _count++;
     }
@@ -64,9 +67,9 @@ osStatus Mutex::lock(void)
     return osOK;
 }
 
-osStatus Mutex::lock(uint32_t millisec)
+osStatus_t Mutex::lock(uint32_t millisec)
 {
-    osStatus status = osMutexAcquire(_id, millisec);
+    osStatus_t status = osMutexAcquire(_id, millisec);
     if (osOK == status) {
         _count++;
     }
@@ -89,7 +92,7 @@ bool Mutex::trylock()
 
 bool Mutex::trylock_for(uint32_t millisec)
 {
-    osStatus status = osMutexAcquire(_id, millisec);
+    osStatus_t status = osMutexAcquire(_id, millisec);
     if (status == osOK) {
         return true;
     }
@@ -119,11 +122,11 @@ bool Mutex::trylock_until(uint64_t millisec)
     }
 }
 
-osStatus Mutex::unlock()
+osStatus_t Mutex::unlock()
 {
     _count--;
 
-    osStatus status = osMutexRelease(_id);
+    osStatus_t status = osMutexRelease(_id);
 
     if (status != osOK) {
         MBED_ERROR1(MBED_MAKE_ERROR(MBED_MODULE_KERNEL, MBED_ERROR_CODE_MUTEX_UNLOCK_FAILED), "Mutex unlock failed", status);
@@ -143,3 +146,5 @@ Mutex::~Mutex()
 }
 
 }
+
+#endif