Searched refs:outqueue (Results 1 – 12 of 12) sorted by relevance
| /NextBSD/sys/netinet/ |
| HD | sctp_ss_functions.c | 107 if (!TAILQ_EMPTY(&strq->outqueue) && in sctp_ss_default_add() 141 if (TAILQ_EMPTY(&strq->outqueue) && in sctp_ss_default_remove() 196 if (TAILQ_FIRST(&strq->outqueue) && in sctp_ss_default_select() 197 TAILQ_FIRST(&strq->outqueue)->net != NULL && in sctp_ss_default_select() 198 TAILQ_FIRST(&strq->outqueue)->net != net) { in sctp_ss_default_select() 257 if (!TAILQ_EMPTY(&strq->outqueue) && in sctp_ss_rr_add() 321 if (TAILQ_FIRST(&strq->outqueue) && in sctp_ss_rrp_packet_done() 322 TAILQ_FIRST(&strq->outqueue)->net != NULL && in sctp_ss_rrp_packet_done() 323 TAILQ_FIRST(&strq->outqueue)->net != net) { in sctp_ss_rrp_packet_done() 390 if (!TAILQ_EMPTY(&strq->outqueue) && in sctp_ss_prio_add() [all …]
|
| HD | sctp_timer.c | 447 TAILQ_EMPTY(&asoc->strmout[chk->rec.data.stream_number].outqueue)) { in sctp_recover_sent_list() 1357 if (!TAILQ_EMPTY(&stcb->asoc.strmout[i].outqueue)) { in sctp_audit_stream_queues_for_size() 1358 TAILQ_FOREACH(sp, &stcb->asoc.strmout[i].outqueue, next) { in sctp_audit_stream_queues_for_size()
|
| HD | sctp_output.c | 3641 TAILQ_INIT(&stcb->asoc.strmout[i].outqueue); in sctp_process_cmsgs_for_init() 6354 TAILQ_INSERT_TAIL(&strm->outqueue, sp, next); in sctp_msg_append() 6676 sp = TAILQ_LAST(&asoc->locked_on_sending->outqueue, sctp_streamhead); in sctp_sendall_iterator() 7127 sp = TAILQ_FIRST(&strq->outqueue); in sctp_move_to_outqueue() 7134 sp = TAILQ_FIRST(&strq->outqueue); in sctp_move_to_outqueue() 7172 TAILQ_REMOVE(&strq->outqueue, sp, next); in sctp_move_to_outqueue() 7175 TAILQ_EMPTY(&strq->outqueue)) { in sctp_move_to_outqueue() 7572 TAILQ_REMOVE(&strq->outqueue, sp, next); in sctp_move_to_outqueue() 7575 TAILQ_EMPTY(&strq->outqueue)) { in sctp_move_to_outqueue() 7721 TAILQ_FOREACH(sp, &stcb->asoc.strmout[i].outqueue, next) { in sctp_move_chunks_from_net() [all …]
|
| HD | sctp_structs.h | 597 struct sctp_streamhead outqueue; member
|
| HD | sctp_indata.c | 2768 TAILQ_EMPTY(&stcb->asoc.strmout[tp1->rec.data.stream_number].outqueue)) { in sctp_process_segment_range() 3746 TAILQ_EMPTY(&asoc->strmout[tp1->rec.data.stream_number].outqueue)) { in sctp_express_handle_sack() 3972 sp = TAILQ_LAST(&((asoc->locked_on_sending)->outqueue), in sctp_express_handle_sack() 4477 TAILQ_EMPTY(&asoc->strmout[tp1->rec.data.stream_number].outqueue)) { in sctp_handle_sack() 4691 sp = TAILQ_LAST(&((asoc->locked_on_sending)->outqueue), in sctp_handle_sack()
|
| HD | sctp_input.c | 241 sp = TAILQ_FIRST(&stcb->asoc.strmout[i].outqueue); in sctp_is_there_unsent_data() 262 TAILQ_REMOVE(&stcb->asoc.strmout[i].outqueue, sp, next); in sctp_is_there_unsent_data() 343 TAILQ_FOREACH_SAFE(sp, &outs->outqueue, next, nsp) { in sctp_process_init() 344 TAILQ_REMOVE(&outs->outqueue, sp, next); in sctp_process_init()
|
| HD | sctputil.c | 1122 TAILQ_INIT(&asoc->strmout[i].outqueue); in sctp_init_asoc() 3868 TAILQ_FOREACH_SAFE(sp, &outs->outqueue, next, nsp) { in sctp_report_all_outbound() 3870 TAILQ_REMOVE(&outs->outqueue, sp, next); in sctp_report_all_outbound() 4923 sp = TAILQ_FIRST(&strq->outqueue); in sctp_release_pr_sctp_chunk()
|
| HD | sctp_pcb.c | 3453 sp = TAILQ_LAST(&((asoc->asoc.locked_on_sending)->outqueue), in sctp_inpcb_free() 4921 TAILQ_FOREACH_SAFE(sp, &outs->outqueue, next, nsp) { in sctp_free_assoc() 4922 TAILQ_REMOVE(&outs->outqueue, sp, next); in sctp_free_assoc()
|
| HD | sctp_usrreq.c | 811 sp = TAILQ_LAST(&asoc->locked_on_sending->outqueue, sctp_streamhead); in sctp_disconnect() 1003 sp = TAILQ_LAST(&asoc->locked_on_sending->outqueue, sctp_streamhead); in sctp_shutdown() 4785 if (!TAILQ_EMPTY(&stcb->asoc.strmout[i].outqueue)) {
|
| /NextBSD/sbin/ggate/ggated/ |
| HD | ggated.c | 98 static TAILQ_HEAD(, ggd_request) outqueue = TAILQ_HEAD_INITIALIZER(outqueue); 753 TAILQ_INSERT_TAIL(&outqueue, req, r_next); in disk_thread() 781 while ((req = TAILQ_FIRST(&outqueue)) == NULL) { in send_thread() 786 TAILQ_REMOVE(&outqueue, req, r_next); in send_thread()
|
| /NextBSD/lib/liblzma/ |
| HD | Makefile | 74 outqueue.c
|
| /NextBSD/contrib/xz/ |
| HD | ChangeLog | 2793 src/liblzma/common/outqueue.c | 4 ++-- 2794 src/liblzma/common/outqueue.h | 5 +++-- 3419 src/liblzma/common/outqueue.c | 4 ++++ 3948 src/liblzma/common/outqueue.c | 180 ++++++ 3949 src/liblzma/common/outqueue.h | 155 +++++
|