Home
last modified time | relevance | path

Searched refs:_q (Results 1 – 3 of 3) sorted by relevance

/mOS-networking-stack/core/src/
H A Dtcp_rb_frag_queue.c39 struct fragment_ctx * volatile * _q; member
69 rb_fragq->_q = (struct fragment_ctx **) in CreateRBFragQueue()
71 if (!rb_fragq->_q) { in CreateRBFragQueue()
88 if (rb_fragq->_q) { in DestroyRBFragQueue()
89 free((void *)rb_fragq->_q); in DestroyRBFragQueue()
90 rb_fragq->_q = NULL; in DestroyRBFragQueue()
104 rb_fragq->_q[t] = frag; in RBFragEnqueue()
105 RBFragMemoryBarrier(rb_fragq->_q[t], rb_fragq->_tail); in RBFragEnqueue()
121 struct fragment_ctx *frag = rb_fragq->_q[h]; in RBFragDequeue()
122 RBFragMemoryBarrier(rb_fragq->_q[h], rb_fragq->_head); in RBFragDequeue()
H A Dtcp_sb_queue.c39 struct tcp_send_buffer * volatile * _q; member
69 sq->_q = (struct tcp_send_buffer **) in CreateSBQueue()
71 if (!sq->_q) { in CreateSBQueue()
88 if (sq->_q) { in DestroySBQueue()
89 free((void *)sq->_q); in DestroySBQueue()
90 sq->_q = NULL; in DestroySBQueue()
104 sq->_q[t] = buf; in SBEnqueue()
105 SBMemoryBarrier(sq->_q[t], sq->_tail); in SBEnqueue()
121 struct tcp_send_buffer *buf = sq->_q[h]; in SBDequeue()
122 SBMemoryBarrier(sq->_q[h], sq->_head); in SBDequeue()
H A Dtcp_stream_queue.c41 struct tcp_stream * volatile * _q; member
154 sq->_q = (tcp_stream **)calloc(capacity + 1, sizeof(tcp_stream *)); in CreateStreamQueue()
155 if (!sq->_q) { in CreateStreamQueue()
172 if (sq->_q) { in DestroyStreamQueue()
173 free((void *)sq->_q); in DestroyStreamQueue()
174 sq->_q = NULL; in DestroyStreamQueue()
188 sq->_q[t] = stream; in StreamEnqueue()
189 StreamMemoryBarrier(sq->_q[t], sq->_tail); in StreamEnqueue()
205 tcp_stream *stream = sq->_q[h]; in StreamDequeue()
206 StreamMemoryBarrier(sq->_q[h], sq->_head); in StreamDequeue()