Home
last modified time | relevance | path

Searched defs:queue (Results 1 – 17 of 17) sorted by relevance

/drivers/hdf_core/framework/utils/src/
Dhdf_blocking_queue.c11 void HdfBlockingQueueInit(struct HdfBlockingQueue *queue) in HdfBlockingQueueInit()
18 void HdfBlockingQueueDestroy(struct HdfBlockingQueue *queue) in HdfBlockingQueueDestroy()
25 void HdfBlockingQueueFlush(struct HdfBlockingQueue *queue) in HdfBlockingQueueFlush()
33 void *HdfBlockingQueueTake(struct HdfBlockingQueue *queue) in HdfBlockingQueueTake()
43 void *HdfBlockingQueueGet(struct HdfBlockingQueue *queue) in HdfBlockingQueueGet()
58 void *HdfBlockingQueueFind(const struct HdfBlockingQueue *queue, long matchKey, SListComparer compa… in HdfBlockingQueueFind()
79 void HdfBlockingQueueRemove(struct HdfBlockingQueue *queue, const void *data) in HdfBlockingQueueRemove()
101 void *HdfBlockingQueuePoll(struct HdfBlockingQueue *queue, long timeout) in HdfBlockingQueuePoll()
111 int HdfBlockingQueueOffer(struct HdfBlockingQueue *queue, void *val, long timeout) in HdfBlockingQueueOffer()
Dhdf_task_queue.c18 static int32_t HdfCreateThread(struct HdfTaskQueue *queue) in HdfCreateThread()
33 struct HdfTaskQueue *queue = NULL; in HdfTaskQueueCreate() local
77 static void HdfQueueStopThread(struct HdfTaskQueue *queue) in HdfQueueStopThread()
94 void HdfTaskQueueDestroy(struct HdfTaskQueue *queue) in HdfTaskQueueDestroy()
103 static void HdfQueueStartThread(struct HdfTaskQueue *queue) in HdfQueueStartThread()
119 void HdfTaskEnqueue(struct HdfTaskQueue *queue, struct HdfTaskType *task) in HdfTaskEnqueue()
152 static struct HdfTaskType *HdfTaskDequeue(struct HdfTaskQueue *queue) in HdfTaskDequeue()
168 struct HdfTaskQueue *queue = (struct HdfTaskQueue *)data; in HdfThreadTasker() local
Dosal_msg_queue.c13 void OsalMessageQueueInit(struct HdfMessageQueue *queue) in OsalMessageQueueInit()
22 void OsalMessageQueueDestroy(struct HdfMessageQueue *queue) in OsalMessageQueueDestroy()
32 struct HdfMessageQueue *queue, struct HdfMessage *message, long delayed) in HdfMessageQueueEnqueue()
57 struct HdfMessage* HdfMessageQueueNext(struct HdfMessageQueue *queue) in HdfMessageQueueNext()
79 void HdfMessageQueueFlush(struct HdfMessageQueue *queue) in HdfMessageQueueFlush()
/drivers/hdf_core/framework/support/platform/src/fwk/
Dplatform_queue.c21 static void PlatformQueueDoDestroy(struct PlatformQueue *queue) in PlatformQueueDoDestroy()
29 static int32_t PlatformQueueNextMsg(struct PlatformQueue *queue, struct PlatformMsg **msg) in PlatformQueueNextMsg()
50 struct PlatformQueue *queue = (struct PlatformQueue *)data; in PlatformQueueWorker() local
77 struct PlatformQueue *queue = NULL; in PlatformQueueCreate() local
98 int32_t PlatformQueueStart(struct PlatformQueue *queue) in PlatformQueueStart()
129 void PlatformQueueDestroy(struct PlatformQueue *queue) in PlatformQueueDestroy()
147 int32_t PlatformQueueAddMsg(struct PlatformQueue *queue, struct PlatformMsg *msg) in PlatformQueueAddMsg()
169 int32_t PlatformQueueGetMsg(struct PlatformQueue *queue, struct PlatformMsg **msg, uint32_t tms) in PlatformQueueGetMsg()
/drivers/hdf_core/adapter/khdf/liteos/model/network/wifi/platform/src/
Dhdf_wlan_queue.c37 HdfWlanQueue queue; member
43 HdfWlanQueueImpl *queue = (HdfWlanQueueImpl *)OsalMemCalloc(sizeof(HdfWlanQueueImpl)); in CreateQueue() local
56 void DestroyQueue(HdfWlanQueue *queue) in DestroyQueue()
69 void *PopQueue(HdfWlanQueue *queue) in PopQueue()
86 int32_t PushQueue(HdfWlanQueue *queue, void *context) in PushQueue()
/drivers/hdf_core/framework/model/network/wifi/platform/src/
Dhdf_wlan_priority_queue.c66 void DestroyPriorityQueue(PriorityQueue *queue) in DestroyPriorityQueue()
92 int32_t PushPriorityQueue(PriorityQueue *queue, const uint8_t priority, void *context) in PushPriorityQueue()
118 static void *PopQueueByPri(PriorityQueueImpl *queue) in PopQueueByPri()
131 void *PopPriorityQueue(PriorityQueue *queue, uint32_t waitInMS) in PopPriorityQueue()
/drivers/hdf_core/adapter/khdf/linux/osal/src/
Dosal_workqueue.c32 int32_t HdfWorkQueueInit(HdfWorkQueue *queue, char *name) in HdfWorkQueueInit()
145 void HdfWorkQueueDestroy(HdfWorkQueue *queue) in HdfWorkQueueDestroy()
158 bool HdfAddWork(HdfWorkQueue *queue, HdfWork *work) in HdfAddWork()
169 bool HdfAddDelayedWork(HdfWorkQueue *queue, HdfWork *work, uint32_t ms) in HdfAddDelayedWork()
/drivers/hdf_core/adapter/khdf/liteos/osal/src/
Dosal_workqueue.c44 int32_t HdfWorkQueueInit(HdfWorkQueue *queue, char *name) in HdfWorkQueueInit()
151 void HdfWorkQueueDestroy(HdfWorkQueue *queue) in HdfWorkQueueDestroy()
163 bool HdfAddWork(HdfWorkQueue *queue, HdfWork *work) in HdfAddWork()
173 bool HdfAddDelayedWork(HdfWorkQueue *queue, HdfWork *work, uint32_t ms) in HdfAddDelayedWork()
/drivers/hdf_core/framework/test/unittest/model/network/wifi/unittest/message/
Dhdf_queue_test.c31 PriorityQueue *queue = CreatePriorityQueue(TEST_QUEUE_SIZE, NO_PRIORITY); in MessageQueueTest001() local
80 PriorityQueue *queue = NULL; in MessageQueueTest002() local
137 PriorityQueue *queue = NULL; in MessageQueueTest003() local
/drivers/hdf_core/adapter/khdf/linux/model/network/wifi/platform/src/
Dhdf_wlan_queue.c59 void DestroyQueue(HdfWlanQueue *queue) in DestroyQueue()
74 void *PopQueue(HdfWlanQueue *queue) in PopQueue()
101 int32_t PushQueue(HdfWlanQueue *queue, void *context) in PushQueue()
/drivers/hdf_core/framework/support/platform/include/can/
Dcan_mail.h21 struct PlatformQueue *queue; member
/drivers/hdf_core/framework/test/unittest/platform/common/
Dplatform_queue_test.c25 static int32_t PlatformQueueTestHandle(struct PlatformQueue *queue, struct PlatformMsg *msg) in PlatformQueueTestHandle()
/drivers/hdf_core/framework/support/platform/src/hdmi/
Dhdmi_event.c197 int32_t HdmiEventMsgHandleDefault(struct PlatformQueue *queue, struct PlatformMsg *msg) in HdmiEventMsgHandleDefault()
/drivers/hdf_core/adapter/khdf/linux/network/src/
Dnet_device_adapter.c247 static struct netdev_queue *NetDevGetTxQueue(struct NetDeviceImpl *impl, unsigned int queue) in NetDevGetTxQueue()
/drivers/peripheral/usb/gadget/function/ecm/
Dcdcecm.c119 struct DListHead *queue = &port->readQueue; in UsbEcmRxPush() local
/drivers/hdf_core/framework/model/storage/src/mmc/
Dmmc_core.c159 static int32_t MmcMsgHandleDefault(struct PlatformQueue *queue, struct PlatformMsg *msg) in MmcMsgHandleDefault()
/drivers/peripheral/usb/gadget/function/acm/
Dcdcacm.c119 struct DListHead *queue = &port->readQueue; in UsbSerialRxPush() local