Searched refs:ConnectionQueue (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 | 31 static ConnectionQueue *g_innerQueue = NULL;
35 static ConnectionQueue *CreateBleQueue(int32_t pid) in CreateBleQueue()
37 ConnectionQueue *queue = (ConnectionQueue *)SoftBusCalloc(sizeof(ConnectionQueue)); in CreateBleQueue()
58 static void DestroyBleQueue(ConnectionQueue *queue) in DestroyBleQueue()
102 ConnectionQueue *item = NULL; in ConnBleEnqueueNonBlock()
103 LIST_FOR_EACH_ENTRY(item, &g_bleQueueList, ConnectionQueue, node) { in ConnBleEnqueueNonBlock()
110 ConnectionQueue *newQueue = CreateBleQueue(queueNode->pid); in ConnBleEnqueueNonBlock()
137 ConnectionQueue *item = NULL; in ConnBleDequeueBlock()
138 ConnectionQueue *next = NULL; in ConnBleDequeueBlock()
152 LIST_FOR_EACH_ENTRY_SAFE(item, next, &g_bleQueueList, ConnectionQueue, node) { in ConnBleDequeueBlock()
|
| /ohos5.0/foundation/communication/dsoftbus/core/connection/br/src/ |
| H A D | softbus_conn_br_send_queue.c | 30 static ConnectionQueue *g_innerQueue = NULL;
35 static ConnectionQueue *CreateBrQueue(int32_t pid) in CreateBrQueue()
37 ConnectionQueue *queue = (ConnectionQueue *)SoftBusCalloc(sizeof(ConnectionQueue)); in CreateBrQueue()
58 static void DestroyBrQueue(ConnectionQueue *queue) in DestroyBrQueue()
105 ConnectionQueue *item = NULL; in ConnBrEnqueueNonBlock()
106 LIST_FOR_EACH_ENTRY(item, &g_brQueueList, ConnectionQueue, node) { in ConnBrEnqueueNonBlock()
113 ConnectionQueue *newQueue = CreateBrQueue(queueNode->pid); in ConnBrEnqueueNonBlock()
143 ConnectionQueue *item = NULL; in ConnBrDequeueBlock()
144 ConnectionQueue *next = NULL; in ConnBrDequeueBlock()
158 LIST_FOR_EACH_ENTRY_SAFE(item, next, &g_brQueueList, ConnectionQueue, node) { in ConnBrDequeueBlock()
|
| /ohos5.0/foundation/communication/dsoftbus/core/connection/common/include/ |
| H A D | softbus_conn_common.h | 56 } ConnectionQueue; typedef
80 int32_t GetMsg(ConnectionQueue *queue, void **msg, bool *isFull, QueuePriority leastPriority);
|
| /ohos5.0/foundation/communication/dsoftbus/core/connection/common/src/ |
| H A D | softbus_conn_common.c | 196 int32_t GetMsg(ConnectionQueue *queue, void **msg, bool *isFull, QueuePriority leastPriority) in GetMsg()
|