Searched refs:stream_queue_t (Results 1 – 4 of 4) sorted by relevance
122 NextIndex(stream_queue_t sq, index_type i) in NextIndex()128 PrevIndex(stream_queue_t sq, index_type i) in PrevIndex()134 StreamQueueIsEmpty(stream_queue_t sq) in StreamQueueIsEmpty()145 stream_queue_t 148 stream_queue_t sq; in CreateStreamQueue()150 sq = (stream_queue_t)calloc(1, sizeof(struct stream_queue)); in CreateStreamQueue()167 DestroyStreamQueue(stream_queue_t sq) in DestroyStreamQueue()181 StreamEnqueue(stream_queue_t sq, tcp_stream *stream) in StreamEnqueue()199 StreamDequeue(stream_queue_t sq) in StreamDequeue()
37 typedef struct stream_queue* stream_queue_t; typedef62 stream_queue_t 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);
247 stream_queue_t connectq; /* streams need to connect */248 stream_queue_t sendq; /* streams need to send data */249 stream_queue_t ackq; /* streams need to send ack */251 stream_queue_t closeq; /* streams need to close */253 stream_queue_t resetq; /* streams need to reset */256 stream_queue_t destroyq; /* streams need to be destroyed */
32 stream_queue_t acceptq;