Denislam Valeev / Mbed OS Nucleo_rtos_basic

1

mbed-os/events/mbed_shared_queues.cpp@0:e056ac8fecf8, 2018-03-13 (annotated)

Committer:
valeyev
Date:
Tue Mar 13 07:17:50 2018 +0000
Revision:
0:e056ac8fecf8
looking for...

Who changed what in which revision?

UserRevisionLine numberNew contents of line
valeyev 0:e056ac8fecf8 1 /* events
valeyev 0:e056ac8fecf8 2 * Copyright (c) 2017 ARM Limited
valeyev 0:e056ac8fecf8 3 *
valeyev 0:e056ac8fecf8 4 * Licensed under the Apache License, Version 2.0 (the "License");
valeyev 0:e056ac8fecf8 5 * you may not use this file except in compliance with the License.
valeyev 0:e056ac8fecf8 6 * You may obtain a copy of the License at
valeyev 0:e056ac8fecf8 7 *
valeyev 0:e056ac8fecf8 8 * http://www.apache.org/licenses/LICENSE-2.0
valeyev 0:e056ac8fecf8 9 *
valeyev 0:e056ac8fecf8 10 * Unless required by applicable law or agreed to in writing, software
valeyev 0:e056ac8fecf8 11 * distributed under the License is distributed on an "AS IS" BASIS,
valeyev 0:e056ac8fecf8 12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
valeyev 0:e056ac8fecf8 13 * See the License for the specific language governing permissions and
valeyev 0:e056ac8fecf8 14 * limitations under the License.
valeyev 0:e056ac8fecf8 15 */
valeyev 0:e056ac8fecf8 16
valeyev 0:e056ac8fecf8 17 #include "events/mbed_shared_queues.h"
valeyev 0:e056ac8fecf8 18 #include "mbed.h"
valeyev 0:e056ac8fecf8 19
valeyev 0:e056ac8fecf8 20 using namespace events;
valeyev 0:e056ac8fecf8 21
valeyev 0:e056ac8fecf8 22 namespace mbed {
valeyev 0:e056ac8fecf8 23
valeyev 0:e056ac8fecf8 24 #ifdef MBED_CONF_RTOS_PRESENT
valeyev 0:e056ac8fecf8 25 /* Create an event queue, and start the thread that dispatches it. Static
valeyev 0:e056ac8fecf8 26 * variables mean this happens once the first time each template instantiation
valeyev 0:e056ac8fecf8 27 * is called. This is currently instantiated no more than twice.
valeyev 0:e056ac8fecf8 28 */
valeyev 0:e056ac8fecf8 29 template
valeyev 0:e056ac8fecf8 30 <osPriority Priority, size_t QueueSize, size_t StackSize>
valeyev 0:e056ac8fecf8 31 EventQueue *do_shared_event_queue_with_thread()
valeyev 0:e056ac8fecf8 32 {
valeyev 0:e056ac8fecf8 33 static uint64_t queue_buffer[QueueSize / sizeof(uint64_t)];
valeyev 0:e056ac8fecf8 34 static EventQueue queue(sizeof queue_buffer, (unsigned char *) queue_buffer);
valeyev 0:e056ac8fecf8 35
valeyev 0:e056ac8fecf8 36 static uint64_t stack[StackSize / sizeof(uint64_t)];
valeyev 0:e056ac8fecf8 37 static Thread thread(Priority, StackSize, (unsigned char *) stack);
valeyev 0:e056ac8fecf8 38
valeyev 0:e056ac8fecf8 39 Thread::State state = thread.get_state();
valeyev 0:e056ac8fecf8 40 if (state == Thread::Inactive || state == Thread::Deleted) {
valeyev 0:e056ac8fecf8 41 osStatus status = thread.start(callback(&queue, &EventQueue::dispatch_forever));
valeyev 0:e056ac8fecf8 42 MBED_ASSERT(status == osOK);
valeyev 0:e056ac8fecf8 43 if (status != osOK) {
valeyev 0:e056ac8fecf8 44 return NULL;
valeyev 0:e056ac8fecf8 45 }
valeyev 0:e056ac8fecf8 46 }
valeyev 0:e056ac8fecf8 47
valeyev 0:e056ac8fecf8 48 return &queue;
valeyev 0:e056ac8fecf8 49 }
valeyev 0:e056ac8fecf8 50 #endif
valeyev 0:e056ac8fecf8 51
valeyev 0:e056ac8fecf8 52 EventQueue *mbed_event_queue()
valeyev 0:e056ac8fecf8 53 {
valeyev 0:e056ac8fecf8 54 #if MBED_CONF_EVENTS_SHARED_DISPATCH_FROM_APPLICATION || !defined MBED_CONF_RTOS_PRESENT
valeyev 0:e056ac8fecf8 55 /* Only create the EventQueue, but no dispatching thread */
valeyev 0:e056ac8fecf8 56 static unsigned char queue_buffer[MBED_CONF_EVENTS_SHARED_EVENTSIZE];
valeyev 0:e056ac8fecf8 57 static EventQueue queue(sizeof queue_buffer, queue_buffer);
valeyev 0:e056ac8fecf8 58
valeyev 0:e056ac8fecf8 59 return &queue;
valeyev 0:e056ac8fecf8 60 #else
valeyev 0:e056ac8fecf8 61 return do_shared_event_queue_with_thread<osPriorityNormal, MBED_CONF_EVENTS_SHARED_EVENTSIZE, MBED_CONF_EVENTS_SHARED_STACKSIZE>();
valeyev 0:e056ac8fecf8 62 #endif
valeyev 0:e056ac8fecf8 63 }
valeyev 0:e056ac8fecf8 64
valeyev 0:e056ac8fecf8 65 #ifdef MBED_CONF_RTOS_PRESENT
valeyev 0:e056ac8fecf8 66 EventQueue *mbed_highprio_event_queue()
valeyev 0:e056ac8fecf8 67 {
valeyev 0:e056ac8fecf8 68 return do_shared_event_queue_with_thread<osPriorityHigh, MBED_CONF_EVENTS_SHARED_HIGHPRIO_EVENTSIZE, MBED_CONF_EVENTS_SHARED_HIGHPRIO_STACKSIZE>();
valeyev 0:e056ac8fecf8 69 }
valeyev 0:e056ac8fecf8 70 #endif
valeyev 0:e056ac8fecf8 71
valeyev 0:e056ac8fecf8 72 }