text: /*
   * Licensed to the Apache Software Foundation (ASF) under one
   * or more contributor license agreements.  See the NOTICE file
   * distributed with this work for additional information
   * regarding copyright ownership.  The ASF licenses this file
   * to you under the Apache License, Version 2.0 (the
   * "License"); you may not use this file except in compliance
   * with the License.  You may obtain a copy of the License at
   *
   *  http://www.apache.org/licenses/LICENSE-2.0
   *
   * Unless required by applicable law or agreed to in writing,
   * software distributed under the License is distributed on an
   * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
   * KIND, either express or implied.  See the License for the
   * specific language governing permissions and limitations
   * under the License.
   */
  
  #ifndef _NIMBLE_NPL_OS_H_
  #define _NIMBLE_NPL_OS_H_
  
  #include <assert.h>
  #include <stdint.h>
  #include <string.h>
  #include "FreeRTOS.h"
  #include "queue.h"
  #include "semphr.h"
  #include "task.h"
  #include "timers.h"
  
  #ifdef __cplusplus
  extern "C" {
  #endif
  
  #ifndef _Static_assert
  #define _Static_assert(...)
  #endif
  
  #define console_printf printf
  
  #define BLE_NPL_OS_ALIGNMENT    4
  
  #define BLE_NPL_TIME_FOREVER    portMAX_DELAY
  
  /* This should be compatible with TickType_t */
  typedef uint32_t ble_npl_time_t;
  typedef int32_t ble_npl_stime_t;
  
  struct ble_npl_event {
      bool queued;
      ble_npl_event_fn *fn;
      void *arg;
  };
  
  struct ble_npl_eventq {
      QueueHandle_t q;
  };
  
  struct ble_npl_callout {
      TimerHandle_t handle;
      struct ble_npl_eventq *evq;
      struct ble_npl_event ev;
  };
  
  struct ble_npl_mutex {
      SemaphoreHandle_t handle;
  };
  
  struct ble_npl_sem {
      SemaphoreHandle_t handle;
  };
  
  /*
   * Simple APIs are just defined as static inline below, but some are a bit more
   * complex or require some global state variables and thus are defined in .c
   * file instead and static inline wrapper just calls proper implementation.
   * We need declarations of these functions and they are defined in header below.
   */
  #include "npl_freertos.h"
  
  static inline bool
  ble_npl_os_started(void)
  {
      return xTaskGetSchedulerState() != taskSCHEDULER_NOT_STARTED;
  }
  
  static inline void *
  ble_npl_get_current_task_id(void)
  {
      return xTaskGetCurrentTaskHandle();
  }
  
  static inline void
  ble_npl_eventq_init(struct ble_npl_eventq *evq)
  {
      evq->q = xQueueCreate(32, sizeof(struct ble_npl_eventq *));
  }
  
  static inline struct ble_npl_event *
  ble_npl_eventq_get(struct ble_npl_eventq *evq, ble_npl_time_t tmo)
  {
      return npl_freertos_eventq_get(evq, tmo);
  }
  
  static inline void
  ble_npl_eventq_put(struct ble_npl_eventq *evq, struct ble_npl_event *ev)
  {
      npl_freertos_eventq_put(evq, ev);
  }
  
  static inline void
  ble_npl_eventq_remove(struct ble_npl_eventq *evq, struct ble_npl_event *ev)
  {
      npl_freertos_eventq_remove(evq, ev);
  }
  
  static inline void
  ble_npl_event_run(struct ble_npl_event *ev)
  {
      ev->fn(ev);
  }
  
  static inline bool
  ble_npl_eventq_is_empty(struct ble_npl_eventq *evq)
  {
      return xQueueIsQueueEmptyFromISR(evq->q);
  }
  
  static inline void
  ble_npl_event_init(struct ble_npl_event *ev, ble_npl_event_fn *fn,
                     void *arg)
  {
      memset(ev, 0, sizeof(*ev));
      ev->fn = fn;
      ev->arg = arg;
  }
  
  static inline bool
  ble_npl_event_is_queued(struct ble_npl_event *ev)
  {
      return ev->queued;
  }
  
  static inline void *
  ble_npl_event_get_arg(struct ble_npl_event *ev)
  {
      return ev->arg;
  }
  
  static inline void
  ble_npl_event_set_arg(struct ble_npl_event *ev, void *arg)
  {
      ev->arg = arg;
  }
  
  static inline ble_npl_error_t
  ble_npl_mutex_init(struct ble_npl_mutex *mu)
  {
      return npl_freertos_mutex_init(mu);
  }
  
  static inline ble_npl_error_t
  ble_npl_mutex_pend(struct ble_npl_mutex *mu, ble_npl_time_t timeout)
  {
      return npl_freertos_mutex_pend(mu, timeout);
  }
  
  static inline ble_npl_error_t
  ble_npl_mutex_release(struct ble_npl_mutex *mu)
  {
      return npl_freertos_mutex_release(mu);
  }
  
  static inline ble_npl_error_t
  ble_npl_sem_init(struct ble_npl_sem *sem, uint16_t tokens)
  {
      return npl_freertos_sem_init(sem, tokens);
  }
  
  static inline ble_npl_error_t
  ble_npl_sem_pend(struct ble_npl_sem *sem, ble_npl_time_t timeout)
  {
      return npl_freertos_sem_pend(sem, timeout);
  }
  
  static inline ble_npl_error_t
  ble_npl_sem_release(struct ble_npl_sem *sem)
  {
      return npl_freertos_sem_release(sem);
  }
  
  static inline uint16_t
  ble_npl_sem_get_count(struct ble_npl_sem *sem)
  {
      return uxSemaphoreGetCount(sem->handle);
  }
  
  static inline void
  ble_npl_callout_init(struct ble_npl_callout *co, struct ble_npl_eventq *evq,
                       ble_npl_event_fn *ev_cb, void *ev_arg)
  {
      npl_freertos_callout_init(co, evq, ev_cb, ev_arg);
  }
  
  static inline ble_npl_error_t
  ble_npl_callout_reset(struct ble_npl_callout *co, ble_npl_time_t ticks)
  {
      return npl_freertos_callout_reset(co, ticks);
  }
  
  static inline void
  ble_npl_callout_stop(struct ble_npl_callout *co)
  {
      xTimerStop(co->handle, portMAX_DELAY);
  }
  
  static inline bool
  ble_npl_callout_is_active(struct ble_npl_callout *co)
  {
      return xTimerIsTimerActive(co->handle) == pdTRUE;
  }
  
  static inline ble_npl_time_t
  ble_npl_callout_get_ticks(struct ble_npl_callout *co)
  {
      return xTimerGetExpiryTime(co->handle);
  }
  
  static inline uint32_t
  ble_npl_callout_remaining_ticks(struct ble_npl_callout *co,
                                  ble_npl_time_t time)
  {
      return npl_freertos_callout_remaining_ticks(co, time);
  }
  
  static inline void
  ble_npl_callout_set_arg(struct ble_npl_callout *co, void *arg)
  {
      co->ev.arg = arg;
  }
  
  static inline uint32_t
  ble_npl_time_get(void)
  {
      return xTaskGetTickCountFromISR();
  }
  
  static inline ble_npl_error_t
  ble_npl_time_ms_to_ticks(uint32_t ms, ble_npl_time_t *out_ticks)
  {
      return npl_freertos_time_ms_to_ticks(ms, out_ticks);
  }
  
  static inline ble_npl_error_t
  ble_npl_time_ticks_to_ms(ble_npl_time_t ticks, uint32_t *out_ms)
  {
      return ble_npl_time_ticks_to_ms(ticks, out_ms);
  }
  
  static inline ble_npl_time_t
  ble_npl_time_ms_to_ticks32(uint32_t ms)
  {
      return ms * configTICK_RATE_HZ / 1000;
  }
  
  static inline uint32_t
  ble_npl_time_ticks_to_ms32(ble_npl_time_t ticks)
  {
      return ticks * 1000 / configTICK_RATE_HZ;
  }
  
  static inline void
  ble_npl_time_delay(ble_npl_time_t ticks)
  {
      vTaskDelay(ticks);
  }
  
  #if NIMBLE_CFG_CONTROLLER
  static inline void
  ble_npl_hw_set_isr(int irqn, void (*addr)(void))
  {
      npl_freertos_hw_set_isr(irqn, addr);
  }
  #endif
  
  static inline uint32_t
  ble_npl_hw_enter_critical(void)
  {
      vPortEnterCritical();
      return 0;
  }
  
  static inline void
  ble_npl_hw_exit_critical(uint32_t ctx)
  {
      vPortExitCritical();
  
  }
  
  #ifdef __cplusplus
  }
  #endif
  
  #endif  /* _NPL_H_ */
  