Searched refs:queueNode (Results 1 – 7 of 7) sorted by relevance
325 …ret = SocketSend(socket, queueNode->frame + queueNode->sendLen, queueNode->length - queueNode->sen… in SendControlFrame()326 if (ret > 0 && ret == (int32_t)(queueNode->length - queueNode->sendLen)) { in SendControlFrame()327 queueNode->sendLen = 0; in SendControlFrame()329 queueNode->sendLen = queueNode->sendLen + (uint32_t)ret; in SendControlFrame()341 ret = SocketSend(session->socket[socketIndex], queueNode->frame, queueNode->length); in SendControlFrame()372 if (queueNode == NULL) { in SendOutboundFrame()388 DestroyQueueNode(queueNode); in SendOutboundFrame()389 queueNode = NULL; in SendOutboundFrame()394 *preQueueNode = queueNode; in SendOutboundFrame()397 DestroyQueueNode(queueNode); in SendOutboundFrame()[all …]
58 QueueNode *queueNode = NULL; in CreateQueueNode() local65 if (queueNode == NULL) { in CreateQueueNode()71 free(queueNode); in CreateQueueNode()74 queueNode->length = length; in CreateQueueNode()75 queueNode->sendLen = 0; in CreateQueueNode()89 return queueNode; in CreateQueueNode()94 if (queueNode != NULL) { in DestroyQueueNode()95 free(queueNode->frame); in DestroyQueueNode()96 free(queueNode); in DestroyQueueNode()915 if (queueNode == NULL) { in DFileWriteHandle()[all …]
86 SendBrQueueNode *queueNode = (SendBrQueueNode *)msg; in ConnBrEnqueueNonBlock() local87 int32_t priority = GetPriority(queueNode->flag); in ConnBrEnqueueNonBlock()93 if (queueNode->pid == 0 && queueNode->isInner) { in ConnBrEnqueueNonBlock()107 if (item->pid == queueNode->pid) { in ConnBrEnqueueNonBlock()113 ConnectionQueue *newQueue = CreateBrQueue(queueNode->pid); in ConnBrEnqueueNonBlock()
719 SendBrQueueNode queueNode; variable728 queueNode.pid = 0;729 queueNode.isInner = 1;734 queueNode.pid = 1;735 queueNode.isInner = 1;739 queueNode.flag = CONN_LOW;740 queueNode.pid = 1;741 queueNode.isInner = 1;752 SendBrQueueNode queueNode; variable758 queueNode.pid = 1;[all …]
269 SendQueueNode queueNode; variable270 queueNode.flag = CONN_HIGH;271 queueNode.pid = 0;272 ret = ConnBleEnqueueNonBlock(&queueNode);279 queueNode.flag = CONN_LOW;280 queueNode.pid = 1;281 ret = ConnBleEnqueueNonBlock(&queueNode);
84 SendQueueNode *queueNode = (SendQueueNode *)msg; in ConnBleEnqueueNonBlock() local85 int32_t priority = GetPriority(queueNode->flag); in ConnBleEnqueueNonBlock()92 if (queueNode->pid == 0) { in ConnBleEnqueueNonBlock()104 if (item->pid == queueNode->pid) { in ConnBleEnqueueNonBlock()110 ConnectionQueue *newQueue = CreateBleQueue(queueNode->pid); in ConnBleEnqueueNonBlock()
174 void DestroyQueueNode(QueueNode *queueNode);