PHung Tung / SRC_STM32F7

SPKT

Dependents:   WAV

common/ticker_api.c@0:e87aa4c49e95, 2019-06-04 (annotated)

Committer:
phungductung
Date:
Tue Jun 04 21:51:46 2019 +0000
Revision:
0:e87aa4c49e95
libray

Who changed what in which revision?

UserRevisionLine numberNew contents of line
phungductung 0:e87aa4c49e95 1 /* mbed Microcontroller Library
phungductung 0:e87aa4c49e95 2 * Copyright (c) 2015 ARM Limited
phungductung 0:e87aa4c49e95 3 *
phungductung 0:e87aa4c49e95 4 * Licensed under the Apache License, Version 2.0 (the "License");
phungductung 0:e87aa4c49e95 5 * you may not use this file except in compliance with the License.
phungductung 0:e87aa4c49e95 6 * You may obtain a copy of the License at
phungductung 0:e87aa4c49e95 7 *
phungductung 0:e87aa4c49e95 8 * http://www.apache.org/licenses/LICENSE-2.0
phungductung 0:e87aa4c49e95 9 *
phungductung 0:e87aa4c49e95 10 * Unless required by applicable law or agreed to in writing, software
phungductung 0:e87aa4c49e95 11 * distributed under the License is distributed on an "AS IS" BASIS,
phungductung 0:e87aa4c49e95 12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
phungductung 0:e87aa4c49e95 13 * See the License for the specific language governing permissions and
phungductung 0:e87aa4c49e95 14 * limitations under the License.
phungductung 0:e87aa4c49e95 15 */
phungductung 0:e87aa4c49e95 16 #include <stddef.h>
phungductung 0:e87aa4c49e95 17 #include "ticker_api.h"
phungductung 0:e87aa4c49e95 18 #include "cmsis.h"
phungductung 0:e87aa4c49e95 19
phungductung 0:e87aa4c49e95 20 void ticker_set_handler(const ticker_data_t *const data, ticker_event_handler handler) {
phungductung 0:e87aa4c49e95 21 data->interface->init();
phungductung 0:e87aa4c49e95 22
phungductung 0:e87aa4c49e95 23 data->queue->event_handler = handler;
phungductung 0:e87aa4c49e95 24 }
phungductung 0:e87aa4c49e95 25
phungductung 0:e87aa4c49e95 26 void ticker_irq_handler(const ticker_data_t *const data) {
phungductung 0:e87aa4c49e95 27 data->interface->clear_interrupt();
phungductung 0:e87aa4c49e95 28
phungductung 0:e87aa4c49e95 29 /* Go through all the pending TimerEvents */
phungductung 0:e87aa4c49e95 30 while (1) {
phungductung 0:e87aa4c49e95 31 if (data->queue->head == NULL) {
phungductung 0:e87aa4c49e95 32 // There are no more TimerEvents left, so disable matches.
phungductung 0:e87aa4c49e95 33 data->interface->disable_interrupt();
phungductung 0:e87aa4c49e95 34 return;
phungductung 0:e87aa4c49e95 35 }
phungductung 0:e87aa4c49e95 36
phungductung 0:e87aa4c49e95 37 if ((int)(data->queue->head->timestamp - data->interface->read()) <= 0) {
phungductung 0:e87aa4c49e95 38 // This event was in the past:
phungductung 0:e87aa4c49e95 39 // point to the following one and execute its handler
phungductung 0:e87aa4c49e95 40 ticker_event_t *p = data->queue->head;
phungductung 0:e87aa4c49e95 41 data->queue->head = data->queue->head->next;
phungductung 0:e87aa4c49e95 42 if (data->queue->event_handler != NULL) {
phungductung 0:e87aa4c49e95 43 (*data->queue->event_handler)(p->id); // NOTE: the handler can set new events
phungductung 0:e87aa4c49e95 44 }
phungductung 0:e87aa4c49e95 45 /* Note: We continue back to examining the head because calling the
phungductung 0:e87aa4c49e95 46 * event handler may have altered the chain of pending events. */
phungductung 0:e87aa4c49e95 47 } else {
phungductung 0:e87aa4c49e95 48 // This event and the following ones in the list are in the future:
phungductung 0:e87aa4c49e95 49 // set it as next interrupt and return
phungductung 0:e87aa4c49e95 50 data->interface->set_interrupt(data->queue->head->timestamp);
phungductung 0:e87aa4c49e95 51 return;
phungductung 0:e87aa4c49e95 52 }
phungductung 0:e87aa4c49e95 53 }
phungductung 0:e87aa4c49e95 54 }
phungductung 0:e87aa4c49e95 55
phungductung 0:e87aa4c49e95 56 void ticker_insert_event(const ticker_data_t *const data, ticker_event_t *obj, timestamp_t timestamp, uint32_t id) {
phungductung 0:e87aa4c49e95 57 /* disable interrupts for the duration of the function */
phungductung 0:e87aa4c49e95 58 __disable_irq();
phungductung 0:e87aa4c49e95 59
phungductung 0:e87aa4c49e95 60 // initialise our data
phungductung 0:e87aa4c49e95 61 obj->timestamp = timestamp;
phungductung 0:e87aa4c49e95 62 obj->id = id;
phungductung 0:e87aa4c49e95 63
phungductung 0:e87aa4c49e95 64 /* Go through the list until we either reach the end, or find
phungductung 0:e87aa4c49e95 65 an element this should come before (which is possibly the
phungductung 0:e87aa4c49e95 66 head). */
phungductung 0:e87aa4c49e95 67 ticker_event_t *prev = NULL, *p = data->queue->head;
phungductung 0:e87aa4c49e95 68 while (p != NULL) {
phungductung 0:e87aa4c49e95 69 /* check if we come before p */
phungductung 0:e87aa4c49e95 70 if ((int)(timestamp - p->timestamp) < 0) {
phungductung 0:e87aa4c49e95 71 break;
phungductung 0:e87aa4c49e95 72 }
phungductung 0:e87aa4c49e95 73 /* go to the next element */
phungductung 0:e87aa4c49e95 74 prev = p;
phungductung 0:e87aa4c49e95 75 p = p->next;
phungductung 0:e87aa4c49e95 76 }
phungductung 0:e87aa4c49e95 77 /* if prev is NULL we're at the head */
phungductung 0:e87aa4c49e95 78 if (prev == NULL) {
phungductung 0:e87aa4c49e95 79 data->queue->head = obj;
phungductung 0:e87aa4c49e95 80 data->interface->set_interrupt(timestamp);
phungductung 0:e87aa4c49e95 81 } else {
phungductung 0:e87aa4c49e95 82 prev->next = obj;
phungductung 0:e87aa4c49e95 83 }
phungductung 0:e87aa4c49e95 84 /* if we're at the end p will be NULL, which is correct */
phungductung 0:e87aa4c49e95 85 obj->next = p;
phungductung 0:e87aa4c49e95 86
phungductung 0:e87aa4c49e95 87 __enable_irq();
phungductung 0:e87aa4c49e95 88 }
phungductung 0:e87aa4c49e95 89
phungductung 0:e87aa4c49e95 90 void ticker_remove_event(const ticker_data_t *const data, ticker_event_t *obj) {
phungductung 0:e87aa4c49e95 91 __disable_irq();
phungductung 0:e87aa4c49e95 92
phungductung 0:e87aa4c49e95 93 // remove this object from the list
phungductung 0:e87aa4c49e95 94 if (data->queue->head == obj) {
phungductung 0:e87aa4c49e95 95 // first in the list, so just drop me
phungductung 0:e87aa4c49e95 96 data->queue->head = obj->next;
phungductung 0:e87aa4c49e95 97 if (data->queue->head == NULL) {
phungductung 0:e87aa4c49e95 98 data->interface->disable_interrupt();
phungductung 0:e87aa4c49e95 99 } else {
phungductung 0:e87aa4c49e95 100 data->interface->set_interrupt(data->queue->head->timestamp);
phungductung 0:e87aa4c49e95 101 }
phungductung 0:e87aa4c49e95 102 } else {
phungductung 0:e87aa4c49e95 103 // find the object before me, then drop me
phungductung 0:e87aa4c49e95 104 ticker_event_t* p = data->queue->head;
phungductung 0:e87aa4c49e95 105 while (p != NULL) {
phungductung 0:e87aa4c49e95 106 if (p->next == obj) {
phungductung 0:e87aa4c49e95 107 p->next = obj->next;
phungductung 0:e87aa4c49e95 108 break;
phungductung 0:e87aa4c49e95 109 }
phungductung 0:e87aa4c49e95 110 p = p->next;
phungductung 0:e87aa4c49e95 111 }
phungductung 0:e87aa4c49e95 112 }
phungductung 0:e87aa4c49e95 113
phungductung 0:e87aa4c49e95 114 __enable_irq();
phungductung 0:e87aa4c49e95 115 }
phungductung 0:e87aa4c49e95 116
phungductung 0:e87aa4c49e95 117 timestamp_t ticker_read(const ticker_data_t *const data)
phungductung 0:e87aa4c49e95 118 {
phungductung 0:e87aa4c49e95 119 return data->interface->read();
phungductung 0:e87aa4c49e95 120 }
phungductung 0:e87aa4c49e95 121
phungductung 0:e87aa4c49e95 122 int ticker_get_next_timestamp(const ticker_data_t *const data, timestamp_t *timestamp)
phungductung 0:e87aa4c49e95 123 {
phungductung 0:e87aa4c49e95 124 int ret = 0;
phungductung 0:e87aa4c49e95 125
phungductung 0:e87aa4c49e95 126 /* if head is NULL, there are no pending events */
phungductung 0:e87aa4c49e95 127 __disable_irq();
phungductung 0:e87aa4c49e95 128 if (data->queue->head != NULL) {
phungductung 0:e87aa4c49e95 129 *timestamp = data->queue->head->timestamp;
phungductung 0:e87aa4c49e95 130 ret = 1;
phungductung 0:e87aa4c49e95 131 }
phungductung 0:e87aa4c49e95 132 __enable_irq();
phungductung 0:e87aa4c49e95 133
phungductung 0:e87aa4c49e95 134 return ret;
phungductung 0:e87aa4c49e95 135 }