Lines Matching refs:stream
82 StreamInternalEnqueue(stream_queue_int *sq, struct tcp_stream *stream) in StreamInternalEnqueue() argument
91 sq->array[sq->last++] = stream; in StreamInternalEnqueue()
104 struct tcp_stream *stream = NULL; in StreamInternalDequeue() local
110 stream = sq->array[sq->first++]; in StreamInternalDequeue()
111 assert(stream != NULL); in StreamInternalDequeue()
118 return stream; in StreamInternalDequeue()
140 StreamMemoryBarrier(tcp_stream * volatile stream, volatile index_type index) in StreamMemoryBarrier() argument
142 __asm__ volatile("" : : "m" (stream), "m" (index)); in StreamMemoryBarrier()
181 StreamEnqueue(stream_queue_t sq, tcp_stream *stream) in StreamEnqueue() argument
188 sq->_q[t] = stream; in StreamEnqueue()
205 tcp_stream *stream = sq->_q[h]; in StreamDequeue() local
208 assert(stream); in StreamDequeue()
209 return stream; in StreamDequeue()