Home
last modified time | relevance | path

Searched refs:inqueue (Results 1 – 5 of 5) sorted by relevance

/freebsd-13.1/sbin/ggate/ggated/
H A Dggated.c102 static TAILQ_HEAD(, ggd_request) inqueue = TAILQ_HEAD_INITIALIZER(inqueue);
693 TAILQ_INSERT_TAIL(&inqueue, req, r_next); in recv_thread()
718 while ((req = TAILQ_FIRST(&inqueue)) == NULL) { in disk_thread()
722 TAILQ_REMOVE(&inqueue, req, r_next); in disk_thread()
/freebsd-13.1/sys/netinet/
H A Dsctp_indata.c355 q = &strm->inqueue; in sctp_place_control_in_stream()
522 TAILQ_INSERT_HEAD(&strm->inqueue, control, next_instrm); in sctp_queue_data_to_stream()
573 TAILQ_REMOVE(&strm->inqueue, control, next_instrm); in sctp_queue_data_to_stream()
1133 control = TAILQ_FIRST(&strm->inqueue); in sctp_deliver_reasm_check()
1163 TAILQ_REMOVE(&strm->inqueue, control, next_instrm); in sctp_deliver_reasm_check()
1219 TAILQ_REMOVE(&strm->inqueue, control, next_instrm); in sctp_deliver_reasm_check()
1333 TAILQ_REMOVE(&strm->inqueue, control, next_instrm); in sctp_add_chk_to_control()
1670 TAILQ_FOREACH(control, &strm->inqueue, next_instrm) { in sctp_find_reasm_entry()
2119 TAILQ_EMPTY(&asoc->strmin[sid].inqueue)))) { in sctp_process_a_data_chunk()
5443 TAILQ_REMOVE(&strm->inqueue, control, next_instrm); in sctp_flush_reassm_for_str_seq()
[all …]
H A Dsctp_input.c350 sctp_clean_up_stream(stcb, &asoc->strmin[i].inqueue); in sctp_process_init()
370 TAILQ_INIT(&asoc->strmin[i].inqueue); in sctp_process_init()
871 TAILQ_REMOVE(&strm->inqueue, asoc->control_pdapi, next_instrm); in sctp_handle_shutdown()
3846 TAILQ_INIT(&stcb->asoc.strmin[i].inqueue); in sctp_handle_str_reset_add_strm()
3853 TAILQ_FOREACH_SAFE(ctl, &oldstrm[i].inqueue, next_instrm, nctl) { in sctp_handle_str_reset_add_strm()
3854 TAILQ_REMOVE(&oldstrm[i].inqueue, ctl, next_instrm); in sctp_handle_str_reset_add_strm()
3855 TAILQ_INSERT_TAIL(&stcb->asoc.strmin[i].inqueue, ctl, next_instrm); in sctp_handle_str_reset_add_strm()
3864 TAILQ_INIT(&stcb->asoc.strmin[i].inqueue); in sctp_handle_str_reset_add_strm()
H A Dsctp_structs.h542 struct sctp_readhead inqueue; member
H A Dsctp_pcb.c5115 sctp_clean_up_stream(stcb, &asoc->strmin[i].inqueue); in sctp_free_assoc()
6780 TAILQ_FOREACH_SAFE(control, &asoc->strmin[strmat].inqueue, next_instrm, ncontrol) { in sctp_drain_mbufs()
6807 TAILQ_REMOVE(&asoc->strmin[strmat].inqueue, control, next_instrm); in sctp_drain_mbufs()