Searched refs:lockFreeQueue (Results 1 – 4 of 4) sorted by relevance
| /ohos5.0/foundation/communication/dsoftbus/core/connection/ble/src/ |
| H A D | softbus_conn_ble_send_queue.c | 101 LockFreeQueue *lockFreeQueue = NULL; in ConnBleEnqueueNonBlock() local
105 lockFreeQueue = item->queue[priority]; in ConnBleEnqueueNonBlock()
109 if (lockFreeQueue == NULL) { in ConnBleEnqueueNonBlock()
116 lockFreeQueue = newQueue->queue[priority]; in ConnBleEnqueueNonBlock()
119 …lockFreeQueue, GetQueueLimit(priority), WAIT_QUEUE_BUFFER_PERIOD_LEN, &g_sendWaitCond, &g_bleQueue… in ConnBleEnqueueNonBlock()
124 ret = QueueMultiProducerEnqueue(lockFreeQueue, msg); 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() local
108 lockFreeQueue = item->queue[priority]; in ConnBrEnqueueNonBlock()
112 if (lockFreeQueue == NULL) { in ConnBrEnqueueNonBlock()
119 lockFreeQueue = newQueue->queue[priority]; in ConnBrEnqueueNonBlock()
122 …lockFreeQueue, GetQueueLimit(priority), WAIT_QUEUE_BUFFER_PERIOD_LEN, &g_sendWaitCond, &g_brQueueL… in ConnBrEnqueueNonBlock()
127 if (QueueMultiProducerEnqueue(lockFreeQueue, msg) != 0) { 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() argument
179 if (QueueCountGet(lockFreeQueue, &queueCount) != 0) { in WaitQueueLength()
|
| /ohos5.0/foundation/communication/dsoftbus/core/connection/common/include/ |
| H A D | softbus_conn_common.h | 78 int32_t WaitQueueLength(const LockFreeQueue *lockFreeQueue, uint32_t maxLen, uint32_t diffLen, Soft…
|