| /ohos5.0/foundation/systemabilitymgr/samgr_lite/samgr/adapter/posix/ |
| H A D | lock_free_queue.h | 26 typedef struct LockFreeQueue LockFreeQueue; typedef
27 struct LockFreeQueue { struct
34 LockFreeQueue *LFQUE_Create(int size, int count); argument
36 BOOL LFQUE_IsEmpty(LockFreeQueue *queue);
38 BOOL LFQUE_IsFull(LockFreeQueue *queue);
40 int LFQUE_Push(LockFreeQueue *queue, const void *element, uint8 pri);
42 int LFQUE_Pop(LockFreeQueue *queue, void *element, uint8 *pri);
|
| H A D | lock_free_queue.c | 20 LockFreeQueue *LFQUE_Create(int size, int count) in LFQUE_Create()
31 register LockFreeQueue *queue = (LockFreeQueue *)SAMGR_Malloc(sizeof(LockFreeQueue) + total); in LFQUE_Create()
42 BOOL LFQUE_IsFull(LockFreeQueue *queue) in LFQUE_IsFull()
51 BOOL LFQUE_IsEmpty(LockFreeQueue *queue) in LFQUE_IsEmpty()
56 int LFQUE_Push(LockFreeQueue *queue, const void *element, uint8 pri) in LFQUE_Push()
88 int LFQUE_Pop(LockFreeQueue *queue, void *element, uint8 *pri) in LFQUE_Pop()
|
| H A D | queue_adapter.c | 26 LockFreeQueue *queue;
|
| /ohos5.0/foundation/communication/dsoftbus/core/common/queue/ |
| H A D | softbus_queue.c | 32 int32_t QueueInit(LockFreeQueue* queue, uint32_t unitNum) in QueueInit()
43 (void)memset_s(queue, sizeof(LockFreeQueue), 0, sizeof(LockFreeQueue)); in QueueInit()
72 size = sizeof(uintptr_t) * unitNum + sizeof(LockFreeQueue); in QueueSizeCalc()
77 int32_t QueueCountGet(const LockFreeQueue* queue, uint32_t* count) in QueueCountGet()
95 LockFreeQueue* CreateQueue(uint32_t unitNum) in CreateQueue()
105 LockFreeQueue *queue = (LockFreeQueue *)SoftBusCalloc(queueSize); in CreateQueue()
|
| /ohos5.0/foundation/communication/dsoftbus/core/common/include/ |
| H A D | softbus_queue.h | 63 } LockFreeQueue; typedef
67 extern int32_t QueueCountGet(const LockFreeQueue* queue, uint32_t* count);
69 extern int32_t QueueInit(LockFreeQueue* queue, uint32_t unitNum);
71 extern LockFreeQueue* CreateQueue(uint32_t unitNum);
73 static inline int32_t QueueIsEmpty(LockFreeQueue* queue) in QueueIsEmpty()
94 static inline int32_t QueueSingleProducerEnqueue(LockFreeQueue *queue, const void *node) in QueueSingleProducerEnqueue()
143 static inline int32_t QueueMultiProducerEnqueue(LockFreeQueue* queue, const void* node) in QueueMultiProducerEnqueue()
207 static inline int32_t QueueSingleConsumerDequeue(LockFreeQueue* queue, void** node) in QueueSingleConsumerDequeue()
260 static inline int32_t QueueMultiConsumerDequeue(LockFreeQueue *queue, void **node) in QueueMultiConsumerDequeue()
|
| /ohos5.0/foundation/communication/dsoftbus/tests/core/common/queue/ |
| H A D | queue_test.cpp | 54 LockFreeQueue queue;
86 LockFreeQueue queue;
102 LockFreeQueue *queue = CreateQueue(INVALID_NUM);
118 LockFreeQueue *queue = CreateQueue(IS_POWER_OF_2_NUM);
|
| /ohos5.0/foundation/multimedia/av_codec/services/services/codec/server/post_processing/ |
| H A D | lock_free_queue.h | 51 class LockFreeQueue {
55 explicit LockFreeQueue(const std::string& name) : name_(name) {} in LockFreeQueue() function
56 ~LockFreeQueue() in ~LockFreeQueue()
61 static std::shared_ptr<LockFreeQueue<T, N>> Create(const std::string& name = "")
63 auto p = std::make_unique<LockFreeQueue<T, N>>(name);
|
| /ohos5.0/foundation/communication/dsoftbus/core/connection/common/include/ |
| H A D | softbus_conn_common.h | 55 LockFreeQueue *queue[QUEUE_NUM_PER_PID];
78 int32_t WaitQueueLength(const LockFreeQueue *lockFreeQueue, uint32_t maxLen, uint32_t diffLen, Soft…
|
| /ohos5.0/foundation/communication/dsoftbus/core/connection/ble/src/ |
| H A D | softbus_conn_ble_send_queue.c | 101 LockFreeQueue *lockFreeQueue = NULL; in ConnBleEnqueueNonBlock()
|
| /ohos5.0/foundation/communication/dsoftbus/core/connection/br/src/ |
| H A D | softbus_conn_br_send_queue.c | 104 LockFreeQueue *lockFreeQueue = NULL; in ConnBrEnqueueNonBlock()
|
| /ohos5.0/foundation/communication/dsoftbus/core/connection/common/src/ |
| H A D | softbus_conn_common.c | 174 …const LockFreeQueue *lockFreeQueue, uint32_t maxLen, uint32_t diffLen, SoftBusCond *cond, SoftBusM… in WaitQueueLength()
|
| /ohos5.0/foundation/multimedia/av_codec/services/services/codec/server/ |
| H A D | codec_server.h | 188 …using DecodedBufferInfoQueue = LockFreeQueue<std::shared_ptr<DecodedBufferInfo>, decodedBufferInfo…
|