| /device/soc/esp/esp32/components/bt/common/osi/ |
| D | fixed_queue.c | 71 void fixed_queue_free(fixed_queue_t *queue, fixed_queue_free_cb free_cb) in fixed_queue_free()
94 bool fixed_queue_is_empty(fixed_queue_t *queue) in fixed_queue_is_empty()
109 size_t fixed_queue_length(fixed_queue_t *queue) in fixed_queue_length()
123 size_t fixed_queue_capacity(fixed_queue_t *queue) in fixed_queue_capacity()
130 bool fixed_queue_enqueue(fixed_queue_t *queue, void *data, uint32_t timeout) in fixed_queue_enqueue()
151 void *fixed_queue_dequeue(fixed_queue_t *queue, uint32_t timeout) in fixed_queue_dequeue()
171 void *fixed_queue_try_peek_first(fixed_queue_t *queue) in fixed_queue_try_peek_first()
186 void *fixed_queue_try_peek_last(fixed_queue_t *queue) in fixed_queue_try_peek_last()
201 void *fixed_queue_try_remove_from_queue(fixed_queue_t *queue, void *data) in fixed_queue_try_remove_from_queue()
225 list_t *fixed_queue_get_list(fixed_queue_t *queue) in fixed_queue_get_list()
[all …]
|
| /device/soc/rockchip/common/kernel/drivers/gpu/arm/bifrost/debug/backend/ |
| D | mali_kbase_debug_ktrace_csf.h | 66 #define KBASE_KTRACE_RBUF_ADD_CSF(kbdev, code, group, queue, flags, info_val) \ argument
70 #define KBASE_KTRACE_RBUF_ADD_CSF_KCPU(kbdev, code, queue, info_val1, \ argument
76 #define KBASE_KTRACE_RBUF_ADD_CSF(kbdev, code, group, queue, flags, info_val) \ argument
87 #define KBASE_KTRACE_RBUF_ADD_CSF_KCPU(kbdev, code, queue, info_val1, info_val2) \ argument
106 #define KBASE_KTRACE_FTRACE_ADD_CSF(kbdev, code, group, queue, info_val) \ argument
109 #define KBASE_KTRACE_FTRACE_ADD_KCPU(code, queue, info_val1, info_val2) \ argument
114 #define KBASE_KTRACE_FTRACE_ADD_CSF(kbdev, code, group, queue, info_val) \ argument
124 #define KBASE_KTRACE_FTRACE_ADD_KCPU(code, queue, info_val1, info_val2) \ argument
178 #define KBASE_KTRACE_ADD_CSF_GRP_Q(kbdev, code, group, queue, info_val) \ argument
191 #define KBASE_KTRACE_ADD_CSF_KCPU(kbdev, code, queue, info_val1, info_val2) \ argument
|
| /device/soc/rockchip/rk3568/hardware/omx_il/osal/ |
| D | Rockchip_OSAL_Queue.c | 40 ROCKCHIP_QUEUE *queue = (ROCKCHIP_QUEUE *)queueHandle; in Rockchip_OSAL_QueueCreate() local
84 ROCKCHIP_QUEUE *queue = (ROCKCHIP_QUEUE *)queueHandle; in Rockchip_OSAL_QueueTerminate() local
108 ROCKCHIP_QUEUE *queue = (ROCKCHIP_QUEUE *)queueHandle; in Rockchip_OSAL_Queue() local
130 ROCKCHIP_QUEUE *queue = (ROCKCHIP_QUEUE *)queueHandle; in Rockchip_OSAL_Dequeue() local
153 ROCKCHIP_QUEUE *queue = (ROCKCHIP_QUEUE *)queueHandle; in Rockchip_OSAL_GetElemNum() local
166 ROCKCHIP_QUEUE *queue = (ROCKCHIP_QUEUE *)queueHandle; in Rockchip_OSAL_SetElemNum() local
179 ROCKCHIP_QUEUE *queue = (ROCKCHIP_QUEUE *)queueHandle; in Rockchip_OSAL_ResetQueue() local
|
| /device/board/isoftstone/zhiyuan/kernel/driver/drivers/net/wireless/xr829/wlan/ |
| D | queue.c | 21 static inline void __xradio_queue_lock(struct xradio_queue *queue) in __xradio_queue_lock()
32 static inline void __xradio_queue_unlock(struct xradio_queue *queue) in __xradio_queue_unlock()
99 static void __xradio_queue_gc(struct xradio_queue *queue, in __xradio_queue_gc()
159 struct xradio_queue *queue = from_timer(queue, t, gc); in xradio_queue_gc() local
215 int xradio_queue_init(struct xradio_queue *queue, in xradio_queue_init()
261 int xradio_queue_clear(struct xradio_queue *queue, int if_id) in xradio_queue_clear()
364 void xradio_queue_deinit(struct xradio_queue *queue) in xradio_queue_deinit()
381 struct xradio_queue *queue, in xradio_queue_get_num_queued()
407 int xradio_queue_put(struct xradio_queue *queue, struct sk_buff *skb, in xradio_queue_put()
494 int xradio_queue_get(struct xradio_queue *queue, in xradio_queue_get()
[all …]
|
| /device/board/isoftstone/zhiyuan/kernel/driver/drivers/net/wireless/bcmdhd/ |
| D | dhd_flowring.h | 114 #define DHD_FLOW_QUEUE_LEN(queue) ((int)(queue)->len) argument
115 #define DHD_FLOW_QUEUE_MAX(queue) ((int)(queue)->max) argument
116 #define DHD_FLOW_QUEUE_THRESHOLD(queue) ((int)(queue)->threshold) argument
117 #define DHD_FLOW_QUEUE_L2THRESHOLD(queue) ((int)(queue)->l2threshold) argument
118 #define DHD_FLOW_QUEUE_EMPTY(queue) ((queue)->len == 0) argument
119 #define DHD_FLOW_QUEUE_FAILURES(queue) ((queue)->failures) argument
121 #define DHD_FLOW_QUEUE_AVAIL(queue) ((int)((queue)->max - (queue)->len)) argument
122 #define DHD_FLOW_QUEUE_FULL(queue) ((queue)->len >= (queue)->max) argument
124 #define DHD_FLOW_QUEUE_OVFL(queue, budget) \ argument
127 #define DHD_FLOW_QUEUE_SET_MAX(queue, budget) \ argument
[all …]
|
| D | dhd_flowring.c | 78 dhd_flow_queue_throttle(flow_queue_t *queue) in dhd_flow_queue_throttle()
84 dhd_flow_queue_overflow(flow_queue_t *queue, void *pkt) in dhd_flow_queue_overflow()
118 dhd_flow_queue_reinit(dhd_pub_t *dhdp, flow_queue_t *queue, int max) in dhd_flow_queue_reinit()
138 dhd_flow_queue_init(dhd_pub_t *dhdp, flow_queue_t *queue, int max) in dhd_flow_queue_init()
148 dhd_flow_queue_register(flow_queue_t *queue, flow_queue_cb_t cb) in dhd_flow_queue_register()
159 dhd_flow_queue_enqueue(dhd_pub_t *dhdp, flow_queue_t *queue, void *pkt) in dhd_flow_queue_enqueue()
193 dhd_flow_queue_dequeue(dhd_pub_t *dhdp, flow_queue_t *queue) in dhd_flow_queue_dequeue()
224 dhd_flow_queue_reinsert(dhd_pub_t *dhdp, flow_queue_t *queue, void *pkt) in dhd_flow_queue_reinsert()
245 flow_queue_t * queue; in dhd_flow_ring_config_thresholds() local
|
| /device/board/kaihong/khdvk_3566b/wifi/bcmdhd_hdf/bcmdhd/ |
| D | dhd_flowring.h | 135 #define DHD_FLOW_QUEUE_LEN(queue) ((int)(queue)->len) argument
136 #define DHD_FLOW_QUEUE_MAX(queue) ((int)(queue)->max) argument
137 #define DHD_FLOW_QUEUE_THRESHOLD(queue) ((int)(queue)->threshold) argument
138 #define DHD_FLOW_QUEUE_L2THRESHOLD(queue) ((int)(queue)->l2threshold) argument
139 #define DHD_FLOW_QUEUE_EMPTY(queue) ((queue)->len == 0) argument
140 #define DHD_FLOW_QUEUE_FAILURES(queue) ((queue)->failures) argument
142 #define DHD_FLOW_QUEUE_AVAIL(queue) ((int)((queue)->max - (queue)->len)) argument
143 #define DHD_FLOW_QUEUE_FULL(queue) ((queue)->len >= (queue)->max) argument
145 #define DHD_FLOW_QUEUE_OVFL(queue, budget) (((queue)->len) > budget) argument
147 #define DHD_FLOW_QUEUE_SET_MAX(queue, budget) ((queue)->max) = ((budget)-1) argument
[all …]
|
| D | dhd_flowring.c | 75 static INLINE int dhd_flow_queue_throttle(flow_queue_t *queue) in dhd_flow_queue_throttle()
80 int BCMFASTPATH dhd_flow_queue_overflow(flow_queue_t *queue, void *pkt) in dhd_flow_queue_overflow()
118 void dhd_flow_queue_reinit(dhd_pub_t *dhdp, flow_queue_t *queue, int max) in dhd_flow_queue_reinit()
137 void dhd_flow_queue_init(dhd_pub_t *dhdp, flow_queue_t *queue, int max) in dhd_flow_queue_init()
146 void dhd_flow_queue_register(flow_queue_t *queue, flow_queue_cb_t cb) in dhd_flow_queue_register()
156 int BCMFASTPATH dhd_flow_queue_enqueue(dhd_pub_t *dhdp, flow_queue_t *queue, in dhd_flow_queue_enqueue()
190 void *BCMFASTPATH dhd_flow_queue_dequeue(dhd_pub_t *dhdp, flow_queue_t *queue) in dhd_flow_queue_dequeue()
221 void BCMFASTPATH dhd_flow_queue_reinsert(dhd_pub_t *dhdp, flow_queue_t *queue, in dhd_flow_queue_reinsert()
243 flow_queue_t *queue = NULL; in dhd_flow_ring_config_thresholds() local
|
| /device/soc/rockchip/common/kernel/drivers/net/wireless/rockchip_wlan/rkwifi/bcmdhd_wifi6/ |
| D | dhd_flowring.h | 127 #define DHD_FLOW_QUEUE_LEN(queue) ((int)(queue)->len) argument
128 #define DHD_FLOW_QUEUE_MAX(queue) ((int)(queue)->max) argument
129 #define DHD_FLOW_QUEUE_THRESHOLD(queue) ((int)(queue)->threshold) argument
130 #define DHD_FLOW_QUEUE_L2THRESHOLD(queue) ((int)(queue)->l2threshold) argument
131 #define DHD_FLOW_QUEUE_EMPTY(queue) ((queue)->len == 0) argument
132 #define DHD_FLOW_QUEUE_FAILURES(queue) ((queue)->failures) argument
134 #define DHD_FLOW_QUEUE_AVAIL(queue) ((int)((queue)->max - (queue)->len)) argument
135 #define DHD_FLOW_QUEUE_FULL(queue) ((queue)->len >= (queue)->max) argument
137 #define DHD_FLOW_QUEUE_OVFL(queue, budget) \ argument
140 #define DHD_FLOW_QUEUE_SET_MAX(queue, budget) \ argument
[all …]
|
| D | dhd_flowring.c | 75 dhd_flow_queue_throttle(flow_queue_t *queue) in dhd_flow_queue_throttle()
81 dhd_flow_queue_overflow(flow_queue_t *queue, void *pkt) in dhd_flow_queue_overflow()
121 dhd_flow_queue_reinit(dhd_pub_t *dhdp, flow_queue_t *queue, int max) in dhd_flow_queue_reinit()
141 dhd_flow_queue_init(dhd_pub_t *dhdp, flow_queue_t *queue, int max) in dhd_flow_queue_init()
151 dhd_flow_queue_register(flow_queue_t *queue, flow_queue_cb_t cb) in dhd_flow_queue_register()
162 dhd_flow_queue_enqueue(dhd_pub_t *dhdp, flow_queue_t *queue, void *pkt) in dhd_flow_queue_enqueue()
196 dhd_flow_queue_dequeue(dhd_pub_t *dhdp, flow_queue_t *queue) in dhd_flow_queue_dequeue()
227 dhd_flow_queue_reinsert(dhd_pub_t *dhdp, flow_queue_t *queue, void *pkt) in dhd_flow_queue_reinsert()
248 flow_queue_t * queue = NULL; in dhd_flow_ring_config_thresholds() local
|
| /device/soc/rockchip/common/kernel/drivers/gpu/arm/bifrost/csf/ |
| D | mali_kbase_csf_kcpu.c | 162 struct kbase_kcpu_command_queue *queue, in kbase_jit_add_to_pending_alloc_list()
201 struct kbase_kcpu_command_queue *queue, in kbase_kcpu_jit_allocate_process()
400 struct kbase_kcpu_command_queue *queue, in kbase_kcpu_jit_allocate_finish()
443 static int kbase_kcpu_jit_free_process(struct kbase_kcpu_command_queue *queue, in kbase_kcpu_jit_free_process()
698 static void cleanup_cqs_wait(struct kbase_kcpu_command_queue *queue, in cleanup_cqs_wait()
718 struct kbase_kcpu_command_queue *queue, in kbase_kcpu_cqs_wait_process()
785 static int kbase_kcpu_cqs_wait_prepare(struct kbase_kcpu_command_queue *queue, in kbase_kcpu_cqs_wait_prepare()
841 struct kbase_kcpu_command_queue *queue, in kbase_kcpu_cqs_set_process()
917 static void cleanup_cqs_wait_operation(struct kbase_kcpu_command_queue *queue, in cleanup_cqs_wait_operation()
937 struct kbase_kcpu_command_queue *queue, in kbase_kcpu_cqs_wait_operation_process()
[all …]
|
| D | mali_kbase_csf.c | 56 struct kbase_queue *queue) in put_user_pages_mmap_handle()
82 struct kbase_queue *queue) in get_user_pages_mmap_handle()
130 static void init_user_io_pages(struct kbase_queue *queue) in init_user_io_pages()
215 struct kbase_queue *queue) in kernel_unmap_user_io_pages()
230 struct kbase_queue *queue) in kernel_map_user_io_pages()
301 struct kbase_queue *queue) in kbase_csf_free_command_stream_user_pages()
322 struct kbase_queue *queue) in kbase_csf_alloc_command_stream_user_pages()
418 struct kbase_queue *queue; in find_queue() local
430 static void get_queue(struct kbase_queue *queue) in get_queue()
435 static void release_queue(struct kbase_queue *queue) in release_queue()
[all …]
|
| /device/board/isoftstone/yangfan/kernel/src/driv/net/rockchip_wlan/rkwifi/bcmdhd/ |
| D | dhd_flowring.h | 169 #define DHD_FLOW_QUEUE_LEN(queue) ((int)(queue)->len) argument
170 #define DHD_FLOW_QUEUE_MAX(queue) ((int)(queue)->max) argument
171 #define DHD_FLOW_QUEUE_THRESHOLD(queue) ((int)(queue)->threshold) argument
172 #define DHD_FLOW_QUEUE_L2THRESHOLD(queue) ((int)(queue)->l2threshold) argument
173 #define DHD_FLOW_QUEUE_EMPTY(queue) ((queue)->len == 0) argument
174 #define DHD_FLOW_QUEUE_FAILURES(queue) ((queue)->failures) argument
176 #define DHD_FLOW_QUEUE_AVAIL(queue) ((int)((queue)->max - (queue)->len)) argument
177 #define DHD_FLOW_QUEUE_FULL(queue) ((queue)->len >= (queue)->max) argument
179 #define DHD_FLOW_QUEUE_OVFL(queue, budget) \ argument
182 #define DHD_FLOW_QUEUE_SET_MAX(queue, budget) \ argument
[all …]
|
| /device/soc/hisilicon/common/platform/wifi/hi3881v100/driver/oal/ |
| D | oal_queue.h | 83 static inline hi_void oal_queue_set(oal_queue_stru *queue, hi_u32 *pul_buf, hi_u8 max_elements) in oal_queue_set()
99 static inline hi_void oal_queue_destroy(oal_queue_stru *queue) in oal_queue_destroy()
121 static inline hi_u32 oal_queue_enqueue(oal_queue_stru *queue, hi_void *element) in oal_queue_enqueue()
143 static inline hi_void *oal_queue_dequeue(oal_queue_stru *queue) in oal_queue_dequeue()
162 static inline hi_u8 oal_queue_get_length(const oal_queue_stru *queue) in oal_queue_get_length()
|
| /device/soc/rockchip/common/kernel/drivers/gpu/arm/mali400/mali/linux/ |
| D | mali_osk_wait_queue.c | 43 void _mali_osk_wait_queue_wait_event(_mali_osk_wait_queue_t *queue, mali_bool(*condition)(void *), … in _mali_osk_wait_queue_wait_event()
50 void _mali_osk_wait_queue_wait_event_timeout(_mali_osk_wait_queue_t *queue, mali_bool(*condition)(v… in _mali_osk_wait_queue_wait_event_timeout()
57 void _mali_osk_wait_queue_wake_up(_mali_osk_wait_queue_t *queue) in _mali_osk_wait_queue_wake_up()
71 void _mali_osk_wait_queue_term(_mali_osk_wait_queue_t *queue) in _mali_osk_wait_queue_term()
|
| D | mali_osk_notification.c | 94 void _mali_osk_notification_queue_term(_mali_osk_notification_queue_t *queue) in _mali_osk_notification_queue_term()
106 void _mali_osk_notification_queue_send(_mali_osk_notification_queue_t *queue, _mali_osk_notificatio… in _mali_osk_notification_queue_send()
136 _mali_osk_errcode_t _mali_osk_notification_queue_dequeue(_mali_osk_notification_queue_t *queue, _ma… in _mali_osk_notification_queue_dequeue()
167 _mali_osk_errcode_t _mali_osk_notification_queue_receive(_mali_osk_notification_queue_t *queue, _ma… in _mali_osk_notification_queue_receive()
|
| /device/soc/rockchip/common/vendor/drivers/gpu/arm/mali400/mali/linux/ |
| D | mali_osk_wait_queue.c | 43 void _mali_osk_wait_queue_wait_event(_mali_osk_wait_queue_t *queue, mali_bool (*condition)(void *),… in _mali_osk_wait_queue_wait_event()
50 void _mali_osk_wait_queue_wait_event_timeout(_mali_osk_wait_queue_t *queue, mali_bool (*condition)(… in _mali_osk_wait_queue_wait_event_timeout()
58 void _mali_osk_wait_queue_wake_up(_mali_osk_wait_queue_t *queue) in _mali_osk_wait_queue_wake_up()
74 void _mali_osk_wait_queue_term(_mali_osk_wait_queue_t *queue) in _mali_osk_wait_queue_term()
|
| D | mali_osk_notification.c | 97 void _mali_osk_notification_queue_term(_mali_osk_notification_queue_t *queue) in _mali_osk_notification_queue_term()
109 void mali_osk_notification_queue_send(_mali_osk_notification_queue_t *queue, _mali_osk_notification… in mali_osk_notification_queue_send()
139 mali_osk_errcode_t _mali_osk_notification_queue_dequeue(_mali_osk_notification_queue_t *queue, in _mali_osk_notification_queue_dequeue()
171 mali_osk_errcode_t _mali_osk_notification_queue_receive(_mali_osk_notification_queue_t *queue, in _mali_osk_notification_queue_receive()
|
| /device/soc/rockchip/common/vendor/drivers/gpu/arm/bifrost/debug/backend/ |
| D | mali_kbase_debug_ktrace_csf.h | 46 #define KBASE_KTRACE_RBUF_ADD_CSF(kbdev, code, group, queue, flags, info_val) … argument
51 #define KBASE_KTRACE_RBUF_ADD_CSF(kbdev, code, group, queue, flags, info_val) … argument
72 #define KBASE_KTRACE_FTRACE_ADD_CSF(kbdev, code, group, queue, info_val) … argument
77 #define KBASE_KTRACE_FTRACE_ADD_CSF(kbdev, code, group, queue, info_val) … argument
131 #define KBASE_KTRACE_ADD_CSF_GRP_Q(kbdev, code, group, queue, info_val) … argument
|
| /device/soc/beken/bk7235/liteos_m/bk_sdk_armino/middleware/driver/port/ |
| D | os_port.c | 126 __bk_weak bk_err_t rtos_init_queue(beken_queue_t* queue, const char* name, uint32_t message_size, u… in rtos_init_queue()
131 __bk_weak bk_err_t rtos_push_to_queue(beken_queue_t* queue, void* message, uint32_t timeout_ms) in rtos_push_to_queue()
136 __bk_weak bk_err_t rtos_push_to_queue_front(beken_queue_t* queue, void* message, uint32_t timeout_m… in rtos_push_to_queue_front()
141 __bk_weak bk_err_t rtos_pop_from_queue(beken_queue_t *queue, void *message, uint32_t timeout_ms) in rtos_pop_from_queue()
146 __bk_weak bk_err_t rtos_deinit_queue(beken_queue_t *queue) in rtos_deinit_queue()
151 __bk_weak bool rtos_is_queue_empty(beken_queue_t *queue) in rtos_is_queue_empty()
156 __bk_weak bool rtos_is_queue_full(beken_queue_t *queue) in rtos_is_queue_full()
|
| /device/board/isoftstone/yangfan/kernel/src/driv/net/rockchip_wlan/rkwifi/bcmdhd/include/ |
| D | osl_ext.h | 702 #define OSL_EXT_QUEUE_DECL(queue) argument
735 #define osl_ext_queue_create(name, queue_buffer, queue_size, queue) \ argument
737 #define osl_ext_queue_delete(queue) (OSL_EXT_SUCCESS) argument
738 #define osl_ext_queue_send(queue, data) (OSL_EXT_SUCCESS) argument
739 #define osl_ext_queue_send_synchronous(queue, data) (OSL_EXT_SUCCESS) argument
740 #define osl_ext_queue_receive(queue, timeout_msec, data) \ argument
742 #define osl_ext_queue_count(queue, count) (OSL_EXT_SUCCESS) argument
|
| /device/board/kaihong/khdvk_3566b/wifi/bcmdhd_hdf/bcmdhd/include/ |
| D | osl_ext.h | 713 #define OSL_EXT_QUEUE_DECL(queue) argument
747 #define osl_ext_queue_create(name, queue_buffer, queue_size, queue) \ argument
749 #define osl_ext_queue_delete(queue) (OSL_EXT_SUCCESS) argument
750 #define osl_ext_queue_send(queue, data) (OSL_EXT_SUCCESS) argument
751 #define osl_ext_queue_send_synchronous(queue, data) (OSL_EXT_SUCCESS) argument
752 #define osl_ext_queue_receive(queue, timeout_msec, data) (OSL_EXT_SUCCESS) argument
753 #define osl_ext_queue_count(queue, count) (OSL_EXT_SUCCESS) argument
|
| /device/board/isoftstone/zhiyuan/kernel/driver/drivers/net/wireless/bcmdhd/include/ |
| D | osl_ext.h | 638 #define OSL_EXT_QUEUE_DECL(queue) argument
671 #define osl_ext_queue_create(name, queue_buffer, queue_size, queue) \ argument
673 #define osl_ext_queue_delete(queue) (OSL_EXT_SUCCESS) argument
674 #define osl_ext_queue_send(queue, data) (OSL_EXT_SUCCESS) argument
675 #define osl_ext_queue_send_synchronous(queue, data) (OSL_EXT_SUCCESS) argument
676 #define osl_ext_queue_receive(queue, timeout_msec, data) \ argument
678 #define osl_ext_queue_count(queue, count) (OSL_EXT_SUCCESS) argument
|
| /device/soc/rockchip/common/kernel/drivers/net/wireless/rockchip_wlan/rkwifi/bcmdhd_wifi6/include/ |
| D | osl_ext.h | 709 #define OSL_EXT_QUEUE_DECL(queue) argument
742 #define osl_ext_queue_create(name, queue_buffer, queue_size, queue) \ argument
744 #define osl_ext_queue_delete(queue) (OSL_EXT_SUCCESS) argument
745 #define osl_ext_queue_send(queue, data) (OSL_EXT_SUCCESS) argument
746 #define osl_ext_queue_send_synchronous(queue, data) (OSL_EXT_SUCCESS) argument
747 #define osl_ext_queue_receive(queue, timeout_msec, data) \ argument
749 #define osl_ext_queue_count(queue, count) (OSL_EXT_SUCCESS) argument
|
| /device/soc/rockchip/rk3588/kernel/drivers/video/rockchip/mpp/ |
| D | mpp_common.c | 94 mpp_taskqueue_push_pending(struct mpp_taskqueue *queue, in mpp_taskqueue_push_pending()
109 mpp_taskqueue_pop_pending(struct mpp_taskqueue *queue, in mpp_taskqueue_pop_pending()
124 mpp_taskqueue_get_pending_task(struct mpp_taskqueue *queue) in mpp_taskqueue_get_pending_task()
138 mpp_taskqueue_is_running(struct mpp_taskqueue *queue) in mpp_taskqueue_is_running()
151 mpp_taskqueue_pending_to_run(struct mpp_taskqueue *queue, in mpp_taskqueue_pending_to_run()
167 mpp_taskqueue_get_running_task(struct mpp_taskqueue *queue) in mpp_taskqueue_get_running_task()
182 mpp_taskqueue_pop_running(struct mpp_taskqueue *queue, in mpp_taskqueue_pop_running()
323 struct mpp_taskqueue *queue) in mpp_session_attach_workqueue()
333 struct mpp_taskqueue *queue; in mpp_session_detach_workqueue() local
654 struct mpp_taskqueue *queue = mpp->queue; in mpp_task_worker_default() local
[all …]
|