Searched refs:sq (Results 1 – 4 of 4) sorted by relevance
61 sq->first = sq->last = 0; in CreateInternalStreamQueue()84 if (sq->count >= sq->size) { in StreamInternalEnqueue()91 sq->array[sq->last++] = stream; in StreamInternalEnqueue()93 if (sq->last >= sq->size) { in StreamInternalEnqueue()96 assert (sq->count <= sq->size); in StreamInternalEnqueue()110 stream = sq->array[sq->first++]; in StreamInternalDequeue()112 if (sq->first >= sq->size) { in StreamInternalDequeue()136 return (sq->_head == sq->_tail); in StreamQueueIsEmpty()161 sq->_head = sq->_tail = 0; in CreateStreamQueue()189 StreamMemoryBarrier(sq->_q[t], sq->_tail); in StreamEnqueue()[all …]
63 sb_queue_t sq; in CreateSBQueue() local66 if (!sq) in CreateSBQueue()72 free(sq); in CreateSBQueue()77 sq->_head = sq->_tail = 0; in CreateSBQueue()79 return sq; in CreateSBQueue()85 if (!sq) in DestroySBQueue()88 if (sq->_q) { in DestroySBQueue()93 free(sq); in DestroySBQueue()105 SBMemoryBarrier(sq->_q[t], sq->_tail); in SBEnqueue()122 SBMemoryBarrier(sq->_q[h], sq->_head); in SBDequeue()[all …]
54 DestroyInternalStreamQueue(stream_queue_int *sq);57 StreamInternalEnqueue(stream_queue_int *sq, struct tcp_stream *stream);60 StreamInternalDequeue(stream_queue_int *sq);66 DestroyStreamQueue(stream_queue_t sq);69 StreamEnqueue(stream_queue_t sq, struct tcp_stream *stream);72 StreamDequeue(stream_queue_t sq);75 StreamQueueIsEmpty(stream_queue_t sq);
13 DestroySBQueue(sb_queue_t sq);16 SBEnqueue(sb_queue_t sq, struct tcp_send_buffer *buf);19 SBDequeue(sb_queue_t sq);