Searched refs:g_innerQueue (Results 1 – 2 of 2) sorted by relevance
| /ohos5.0/foundation/communication/dsoftbus/core/connection/ble/src/ |
| H A D | softbus_conn_ble_send_queue.c | 31 static ConnectionQueue *g_innerQueue = NULL; variable
93 …ret = WaitQueueLength(g_innerQueue->queue[priority], GetQueueLimit(priority), WAIT_QUEUE_BUFFER_PE… in ConnBleEnqueueNonBlock()
96 ret = QueueMultiProducerEnqueue(g_innerQueue->queue[priority], msg); in ConnBleEnqueueNonBlock()
148 if (GetMsg(g_innerQueue, msg, &isFull, MIDDLE_PRIORITY) == SOFTBUS_OK) { in ConnBleDequeueBlock()
164 if (GetMsg(g_innerQueue, msg, &isFull, LOW_PRIORITY) == SOFTBUS_OK) { in ConnBleDequeueBlock()
205 g_innerQueue = CreateBleQueue(0); in ConnBleInitSendQueue()
206 if (g_innerQueue == NULL) { in ConnBleInitSendQueue()
221 DestroyBleQueue(g_innerQueue); in ConnBleDeinitSendQueue()
222 g_innerQueue = NULL; in ConnBleDeinitSendQueue()
|
| /ohos5.0/foundation/communication/dsoftbus/core/connection/br/src/ |
| H A D | softbus_conn_br_send_queue.c | 30 static ConnectionQueue *g_innerQueue = NULL; variable
94 …ret = WaitQueueLength(g_innerQueue->queue[priority], GetQueueLimit(priority), WAIT_QUEUE_BUFFER_PE… in ConnBrEnqueueNonBlock()
97 ret = QueueMultiProducerEnqueue(g_innerQueue->queue[priority], msg); in ConnBrEnqueueNonBlock()
154 if (GetMsg(g_innerQueue, msg, &isFull, MIDDLE_PRIORITY) == SOFTBUS_OK) { in ConnBrDequeueBlock()
170 if (GetMsg(g_innerQueue, msg, &isFull, LOW_PRIORITY) == SOFTBUS_OK) { in ConnBrDequeueBlock()
209 g_innerQueue = CreateBrQueue(0); in ConnBrInnerQueueInit()
210 if (g_innerQueue == NULL) { in ConnBrInnerQueueInit()
225 DestroyBrQueue(g_innerQueue); in ConnBrInnerQueueDeinit()
226 g_innerQueue = NULL; in ConnBrInnerQueueDeinit()
|