Lines Matching refs:block_time_ms

130     int32_t (*_semphr_take)(void *semphr, uint32_t block_time_ms);
138 int32_t (* _queue_send)(void *queue, void *item, uint32_t block_time_ms);
140 int32_t (* _queue_recv)(void *queue, void *item, uint32_t block_time_ms);
263 static int32_t semphr_take_wrapper(void *semphr, uint32_t block_time_ms);
272 static int32_t queue_send_hlevel_wrapper(void *queue, void *item, uint32_t block_time_ms);
274 static int32_t queue_recv_hlevel_wrapper(void *queue, void *item, uint32_t block_time_ms);
279 static int32_t queue_send_wrapper(void *queue, void *item, uint32_t block_time_ms);
281 static int32_t queue_recv_wrapper(void *queue, void *item, uint32_t block_time_ms);
629 static int32_t semphr_take_wrapper(void *semphr, uint32_t block_time_ms) in semphr_take_wrapper() argument
634 if (block_time_ms == OSI_FUNCS_TIME_BLOCKING) { in semphr_take_wrapper()
637 …ret = xSemaphoreTake(((hli_queue_handle_t)handle)->downstream, block_time_ms / portTICK_PERIOD_MS); in semphr_take_wrapper()
640 if (block_time_ms == OSI_FUNCS_TIME_BLOCKING) { in semphr_take_wrapper()
643 ret = xSemaphoreTake(handle, block_time_ms / portTICK_PERIOD_MS); in semphr_take_wrapper()
745 static int32_t queue_send_hlevel_wrapper(void *queue, void *item, uint32_t block_time_ms) in queue_send_hlevel_wrapper() argument
748 if (block_time_ms == OSI_FUNCS_TIME_BLOCKING) { in queue_send_hlevel_wrapper()
751 …return (int32_t)xQueueSend(((hli_queue_handle_t)handle)->downstream, item, block_time_ms / portTIC… in queue_send_hlevel_wrapper()
774 static int32_t queue_recv_hlevel_wrapper(void *queue, void *item, uint32_t block_time_ms) in queue_recv_hlevel_wrapper() argument
778 if (block_time_ms == OSI_FUNCS_TIME_BLOCKING) { in queue_recv_hlevel_wrapper()
781 …ret = xQueueReceive(((hli_queue_handle_t)handle)->downstream, item, block_time_ms / portTICK_PERIO… in queue_recv_hlevel_wrapper()
796 static int32_t queue_send_wrapper(void *queue, void *item, uint32_t block_time_ms) in queue_send_wrapper() argument
798 if (block_time_ms == OSI_FUNCS_TIME_BLOCKING) { in queue_send_wrapper()
801 …return (int32_t)xQueueSend(((btdm_queue_item_t*)queue)->handle, item, block_time_ms / portTICK_PER… in queue_send_wrapper()
810 static int32_t queue_recv_wrapper(void *queue, void *item, uint32_t block_time_ms) in queue_recv_wrapper() argument
813 if (block_time_ms == OSI_FUNCS_TIME_BLOCKING) { in queue_recv_wrapper()
816 …ret = xQueueReceive(((btdm_queue_item_t*)queue)->handle, item, block_time_ms / portTICK_PERIOD_MS); in queue_recv_wrapper()