| /foundation/graphic/graphic_3d/lume/metaobject/include/meta/api/ |
| H A D | event_handler.h | 147 auto queue = GetTaskQueueRegistry().GetTaskQueue(queueId); Subscribe() local
[all...] |
| H A D | future.h | 95 IFuture::Ptr Then(const IFutureContinuation::Ptr& func, const BASE_NS::shared_ptr<ITaskQueue>& queue) in Then() argument
100 auto Then(Func func, const BASE_NS::shared_ptr<ITaskQueue>& queue) in Then() argument
105 auto Then(Func func, const BASE_NS::shared_ptr<ITaskQueue>& queue, int = 0) in Then() argument
120 queue)); in Then() variable
|
| H A D | deferred_callback.h | 104 auto MakeDeferred(Func func, const ITaskQueue::Ptr& queue) in MakeDeferred() argument
|
| /foundation/graphic/graphic_3d/lume/metaobject/include/meta/api/property/ |
| H A D | property_event_handler.h | 44 bool Subscribe(const IProperty::ConstPtr& property, const CallableTypePtr& onInvoked, const ITaskQueue::Ptr& queue) in Subscribe() argument
|
| /foundation/graphic/graphic_3d/lume/LumeEngine/src/threading/ |
| H A D | task_queue.cpp | 32 TaskQueue::ExecuteAsyncTask::ExecuteAsyncTask(TaskQueue& queue) : queue_(queue) {} in ExecuteAsyncTask() argument
|
| /foundation/multimedia/av_codec/test/unittest/filter_test/ |
| H A D | audio_sink_filter_unit_test.h | 45 void OnLinkedResult(const sptr<AVBufferQueueProducer>& queue, std::shared_ptr<Meta>& meta)
in OnLinkedResult() argument
|
| /foundation/systemabilitymgr/samgr_lite/samgr/adapter/posix/ |
| H A D | lock_free_queue.c | 31 register LockFreeQueue *queue = (LockFreeQueue *)SAMGR_Malloc(sizeof(LockFreeQueue) + total);
in LFQUE_Create() local
42 BOOL LFQUE_IsFull(LockFreeQueue *queue)
in LFQUE_IsFull() argument
51 LFQUE_IsEmpty(LockFreeQueue *queue) LFQUE_IsEmpty() argument
56 LFQUE_Push(LockFreeQueue *queue, const void *element, uint8 pri) LFQUE_Push() argument
88 LFQUE_Pop(LockFreeQueue *queue, void *element, uint8 *pri) LFQUE_Pop() argument
[all...] |
| /foundation/communication/dsoftbus/tests/core/common/queue/ |
| H A D | queue_test.cpp | 54 LockFreeQueue queue; in HWTEST_F() local
86 LockFreeQueue queue; in HWTEST_F() local
102 LockFreeQueue *queue = CreateQueue(INVALID_NUM); in HWTEST_F() local
118 LockFreeQueue *queue = CreateQueue(IS_POWER_OF_2_NUM); HWTEST_F() local
[all...] |
| /foundation/distributeddatamgr/data_object/frameworks/jskitsimpl/src/common/ |
| H A D | uv_queue.cpp | 33 auto queue = entry->uvQueue_.lock(); in ExecUvWork() local
|
| /kernel/linux/common_modules/newip/third_party/linux-5.10/net/newip/ |
| H A D | ninet_connection_sock.c | 40 struct request_sock_queue *queue = &icsk->icsk_accept_queue; in ninet_reqsk_timer_handler() local
|
| /kernel/linux/linux-5.10/drivers/staging/rtl8712/ |
| H A D | osdep_service.h | 34 struct list_head queue; member
|
| /kernel/linux/linux-5.10/net/sctp/ |
| H A D | inqueue.c | 32 void sctp_inq_init(struct sctp_inq *queue) in sctp_inq_init() argument
42 void sctp_inq_free(struct sctp_inq *queue) in sctp_inq_free() argument
84 sctp_inq_peek(struct sctp_inq *queue) sctp_inq_peek() argument
107 sctp_inq_pop(struct sctp_inq *queue) sctp_inq_pop() argument
[all...] |
| /kernel/linux/linux-5.10/include/media/ |
| H A D | dvb_ringbuffer.h | 48 wait_queue_head_t queue; member
|
| /kernel/linux/linux-5.10/drivers/gpu/drm/i915/gt/ |
| H A D | intel_reset_types.h | 56 wait_queue_head_t queue; member
|
| /kernel/linux/linux-5.10/drivers/media/usb/uvc/ |
| H A D | uvc_isight.c | 34 static int isight_decode(struct uvc_video_queue *queue, struct uvc_buffer *buf, in isight_decode() argument
|
| /kernel/linux/linux-5.10/include/drm/ |
| H A D | spsc_queue.h | 48 static inline void spsc_queue_init(struct spsc_queue *queue) in spsc_queue_init() argument
55 static inline struct spsc_node *spsc_queue_peek(struct spsc_queue *queue) in spsc_queue_peek() argument
60 static inline int spsc_queue_count(struct spsc_queue *queue) in spsc_queue_count() argument
65 spsc_queue_push(struct spsc_queue *queue, struct spsc_node *node) spsc_queue_push() argument
89 spsc_queue_pop(struct spsc_queue *queue) spsc_queue_pop() argument
[all...] |
| /kernel/linux/linux-5.10/drivers/staging/octeon/ |
| H A D | octeon-ethernet.h | 53 int queue; member
|
| /kernel/linux/linux-5.10/include/linux/ |
| H A D | bsg.h | 21 struct request_queue *queue; member
|
| /kernel/linux/linux-6.6/drivers/net/ethernet/hisilicon/hns3/hns3_common/ |
| H A D | hclge_comm_tqp_stats.c | 107 struct hnae3_queue *queue; in hclge_comm_reset_tqp_stats() local
|
| /kernel/linux/linux-6.6/drivers/media/usb/uvc/ |
| H A D | uvc_isight.c | 35 static int isight_decode(struct uvc_video_queue *queue, struct uvc_buffer *buf, in isight_decode() argument
|
| /kernel/linux/linux-6.6/drivers/net/ethernet/microchip/lan966x/ |
| H A D | lan966x_tbf.c | 10 u32 queue = 0; in lan966x_tbf_add() local
60 u32 queue = 0; in lan966x_tbf_del() local
|
| /kernel/linux/linux-6.6/include/media/ |
| H A D | dvb_ringbuffer.h | 48 wait_queue_head_t queue; member
|
| /kernel/linux/linux-6.6/include/drm/ |
| H A D | spsc_queue.h | 48 static inline void spsc_queue_init(struct spsc_queue *queue) in spsc_queue_init() argument
55 static inline struct spsc_node *spsc_queue_peek(struct spsc_queue *queue) in spsc_queue_peek() argument
60 static inline int spsc_queue_count(struct spsc_queue *queue) in spsc_queue_count() argument
65 spsc_queue_push(struct spsc_queue *queue, struct spsc_node *node) spsc_queue_push() argument
89 spsc_queue_pop(struct spsc_queue *queue) spsc_queue_pop() argument
[all...] |
| /kernel/linux/linux-6.6/drivers/staging/octeon/ |
| H A D | octeon-ethernet.h | 53 int queue; member
|
| /kernel/linux/linux-6.6/drivers/staging/rtl8712/ |
| H A D | osdep_service.h | 34 struct list_head queue; member
|