Home
last modified time | relevance | path

Searched refs:outqueue (Results 1 – 12 of 12) sorted by relevance

/src/sys/netinet/
H A Dsctp_ss_functions.c115 if (!TAILQ_EMPTY(&strq->outqueue) && !strq->ss_params.scheduled) { in sctp_ss_default_add()
142 if (TAILQ_EMPTY(&strq->outqueue) && strq->ss_params.scheduled) { in sctp_ss_default_remove()
205 if (TAILQ_FIRST(&strq->outqueue) && in sctp_ss_default_select()
206 TAILQ_FIRST(&strq->outqueue)->net != NULL && in sctp_ss_default_select()
207 TAILQ_FIRST(&strq->outqueue)->net != net) { in sctp_ss_default_select()
234 sp = TAILQ_FIRST(&strq->outqueue); in sctp_ss_default_scheduled()
291 sp = TAILQ_FIRST(&strq->outqueue); in sctp_ss_default_is_user_msgs_incomplete()
311 if (!TAILQ_EMPTY(&strq->outqueue) && !strq->ss_params.scheduled) { in sctp_ss_rr_add()
379 if (TAILQ_FIRST(&strq->outqueue) && in sctp_ss_rrp_packet_done()
380 TAILQ_FIRST(&strq->outqueue)->net != NULL && in sctp_ss_rrp_packet_done()
[all …]
H A Dsctp_timer.c451 TAILQ_EMPTY(&asoc->strmout[chk->rec.data.sid].outqueue)) { in sctp_recover_sent_list()
1372 if (!TAILQ_EMPTY(&stcb->asoc.strmout[i].outqueue)) { in sctp_audit_stream_queues_for_size()
1373 TAILQ_FOREACH(sp, &stcb->asoc.strmout[i].outqueue, next) { in sctp_audit_stream_queues_for_size()
H A Dsctp_output.c3627 TAILQ_INIT(&stcb->asoc.strmout[i].outqueue); in sctp_process_cmsgs_for_init()
6485 TAILQ_INSERT_TAIL(&strm->outqueue, sp, next); in sctp_msg_append()
7251 sp = TAILQ_FIRST(&strq->outqueue); in sctp_move_to_outqueue()
7253 sp = TAILQ_FIRST(&strq->outqueue); in sctp_move_to_outqueue()
7284 TAILQ_REMOVE(&strq->outqueue, sp, next); in sctp_move_to_outqueue()
7288 TAILQ_EMPTY(&strq->outqueue)) { in sctp_move_to_outqueue()
7671 TAILQ_REMOVE(&strq->outqueue, sp, next); in sctp_move_to_outqueue()
7675 TAILQ_EMPTY(&strq->outqueue)) { in sctp_move_to_outqueue()
7796 TAILQ_FOREACH(sp, &stcb->asoc.strmout[i].outqueue, next) { in sctp_move_chunks_from_net()
11769 TAILQ_EMPTY(&stcb->asoc.strmout[i].outqueue)) { in sctp_add_stream_reset_out()
[all …]
H A Dsctp_structs.h628 struct sctp_streamhead outqueue; member
H A Dsctp_input.c192 sp = TAILQ_FIRST(&stcb->asoc.strmout[i].outqueue); in sctp_is_there_unsent_data()
213 TAILQ_REMOVE(&stcb->asoc.strmout[i].outqueue, sp, next); in sctp_is_there_unsent_data()
224 if (!TAILQ_EMPTY(&stcb->asoc.strmout[i].outqueue)) { in sctp_is_there_unsent_data()
300 TAILQ_FOREACH_SAFE(sp, &outs->outqueue, next, nsp) { in sctp_process_init()
302 TAILQ_REMOVE(&outs->outqueue, sp, next); in sctp_process_init()
H A Dsctp_indata.c3130 TAILQ_EMPTY(&stcb->asoc.strmout[tp1->rec.data.sid].outqueue)) { in sctp_process_segment_range()
4097 TAILQ_EMPTY(&asoc->strmout[tp1->rec.data.sid].outqueue)) { in sctp_express_handle_sack()
4771 TAILQ_EMPTY(&asoc->strmout[tp1->rec.data.sid].outqueue)) { in sctp_handle_sack()
H A Dsctputil.c1300 TAILQ_INIT(&asoc->strmout[i].outqueue); in sctp_init_asoc()
4334 TAILQ_FOREACH_SAFE(sp, &outs->outqueue, next, nsp) { in sctp_report_all_outbound()
4336 TAILQ_REMOVE(&outs->outqueue, sp, next); in sctp_report_all_outbound()
5192 sp = TAILQ_FIRST(&strq->outqueue); in sctp_release_pr_sctp_chunk()
H A Dsctp_pcb.c4804 TAILQ_FOREACH_SAFE(sp, &outs->outqueue, next, nsp) { in sctp_free_assoc()
4806 TAILQ_REMOVE(&outs->outqueue, sp, next); in sctp_free_assoc()
H A Dsctp_usrreq.c4853 if (!TAILQ_EMPTY(&stcb->asoc.strmout[i].outqueue)) {
/src/sbin/ggate/ggated/
H A Dggated.c108 static TAILQ_HEAD(, ggd_request) outqueue = TAILQ_HEAD_INITIALIZER(outqueue);
839 TAILQ_INSERT_TAIL(&outqueue, req, r_next); in disk_thread()
867 while ((req = TAILQ_FIRST(&outqueue)) == NULL) { in send_thread()
872 TAILQ_REMOVE(&outqueue, req, r_next); in send_thread()
/src/lib/liblzma/
H A DMakefile81 outqueue.c
/src/contrib/xz/
H A DChangeLog1230 src/liblzma/common/outqueue.h | 1 +
8032 liblzma: outqueue: add header guard
8036 src/liblzma/common/outqueue.h | 5 +++++
10778 src/liblzma/common/outqueue.c | 2 ++
10779 src/liblzma/common/outqueue.h | 2 ++
11089 src/liblzma/common/outqueue.c | 3 -
11090 src/liblzma/common/outqueue.h | 3 -