123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221 |
- #include <string.h>
- #include "app_error.h"
- #include "app_scheduler.h"
- #include "ser_config.h"
- #include "ser_conn_handlers.h"
- #include "ser_conn_event_encoder.h"
- #include "ser_conn_pkt_decoder.h"
- #include "ser_conn_dtm_cmd_decoder.h"
- #include "nrf_sdh.h"
- #ifdef BLE_STACK_SUPPORT_REQD
- #include "conn_ble_gap_sec_keys.h"
- #include "conn_ble_user_mem.h"
- #include "conn_ble_l2cap_sdu_pool.h"
- #endif
- static ser_hal_transport_evt_rx_pkt_received_params_t m_rx_pkt_received_params;
- static bool m_rx_pkt_to_process = false;
- static ser_conn_on_no_mem_t m_on_no_mem_handler;
- void ser_conn_on_no_mem_handler_set(ser_conn_on_no_mem_t handler)
- {
- m_on_no_mem_handler = handler;
- }
- void ser_conn_on_no_mem_handler(void)
- {
- if (m_on_no_mem_handler)
- {
- m_on_no_mem_handler();
- }
- }
- void ser_conn_hal_transport_event_handle(ser_hal_transport_evt_t event)
- {
- switch (event.evt_type)
- {
- case SER_HAL_TRANSP_EVT_TX_PKT_SENT:
- {
-
- app_sched_resume();
-
- ser_conn_is_ready_to_enter_dtm();
- break;
- }
- case SER_HAL_TRANSP_EVT_RX_PKT_RECEIVING:
- {
-
- app_sched_pause();
- break;
- }
- case SER_HAL_TRANSP_EVT_RX_PKT_RECEIVED:
- {
-
- memcpy(&m_rx_pkt_received_params, &event.evt_params.rx_pkt_received,
- sizeof (ser_hal_transport_evt_rx_pkt_received_params_t));
- m_rx_pkt_to_process = true;
- break;
- }
- case SER_HAL_TRANSP_EVT_RX_PKT_DROPPED:
- {
- APP_ERROR_CHECK(SER_WARNING_CODE);
- break;
- }
- case SER_HAL_TRANSP_EVT_PHY_ERROR:
- {
- APP_ERROR_CHECK(NRF_ERROR_FORBIDDEN);
- break;
- }
- default:
- {
-
- break;
- }
- }
- }
- uint32_t ser_conn_rx_process(void)
- {
- uint32_t err_code = NRF_SUCCESS;
- if (m_rx_pkt_to_process)
- {
-
- m_rx_pkt_to_process = false;
- err_code = ser_conn_received_pkt_process(&m_rx_pkt_received_params);
- }
- return err_code;
- }
- #ifdef BLE_STACK_SUPPORT_REQD
- void ser_conn_reset(void)
- {
- conn_ble_gap_sec_keys_init();
- conn_ble_user_mem_init();
- #ifndef S112
- conn_ble_l2cap_sdu_pool_init();
- #endif
- }
- NRF_SDH_BLE_OBSERVER(m_ble_observer, 0, ser_conn_ble_event_handle, NULL);
- void ser_conn_ble_event_handle(ble_evt_t const * p_ble_evt, void * p_context)
- {
- uint32_t err_code = NRF_SUCCESS;
-
- err_code = app_sched_event_put(p_ble_evt, p_ble_evt->header.evt_len,
- ser_conn_ble_event_encoder);
- APP_ERROR_CHECK(err_code);
- uint16_t free_space = app_sched_queue_space_get();
-
- if (free_space < (SER_CONN_SCHED_QUEUE_SIZE / 4))
- {
- nrf_sdh_suspend();
- }
- }
- #endif
- #ifdef ANT_STACK_SUPPORT_REQD
- NRF_SDH_ANT_OBSERVER(m_ant_observer, 0, ser_conn_ant_event_handle, NULL);
- void ser_conn_ant_event_handle(ant_evt_t * p_ant_evt, void * p_context)
- {
- uint32_t err_code = NRF_SUCCESS;
-
- err_code = app_sched_event_put(p_ant_evt, sizeof (ant_evt_t),
- ser_conn_ant_event_encoder);
- APP_ERROR_CHECK(err_code);
- uint16_t free_space = app_sched_queue_space_get();
- if (!free_space)
- {
-
- nrf_sdh_suspend();
- }
- }
- #endif
|