Home
last modified time | relevance | path

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

/freebsd/sys/netinet/
H A Dsctp_indata.c507 strm = &asoc->strmin[control->sinfo_stream]; in sctp_queue_data_to_stream()
1364 strm = &asoc->strmin[control->sinfo_stream]; in sctp_queue_data_for_reasm()
1860 control = sctp_find_reasm_entry(&asoc->strmin[sid], mid, ordered, asoc->idata_supported); in sctp_process_a_data_chunk()
1988 SCTP_MID_GE(asoc->idata_supported, asoc->strmin[sid].last_mid_delivered, mid)) { in sctp_process_a_data_chunk()
1991 mid, asoc->strmin[sid].last_mid_delivered); in sctp_process_a_data_chunk()
1995 asoc->strmin[sid].last_mid_delivered, in sctp_process_a_data_chunk()
2001 (uint16_t)asoc->strmin[sid].last_mid_delivered, in sctp_process_a_data_chunk()
2106 (SCTP_MID_EQ(asoc->idata_supported, asoc->strmin[sid].last_mid_delivered + 1, mid) && in sctp_process_a_data_chunk()
2107 TAILQ_EMPTY(&asoc->strmin[sid].inqueue)))) { in sctp_process_a_data_chunk()
2129 asoc->strmin[sid].last_mid_delivered++; in sctp_process_a_data_chunk()
[all …]
H A Dsctp_input.c344 if (asoc->strmin != NULL) { in sctp_process_init()
347 sctp_clean_up_stream(stcb, &asoc->strmin[i].inqueue); in sctp_process_init()
348 sctp_clean_up_stream(stcb, &asoc->strmin[i].uno_inqueue); in sctp_process_init()
350 SCTP_FREE(asoc->strmin, SCTP_M_STRMI); in sctp_process_init()
357 SCTP_MALLOC(asoc->strmin, struct sctp_stream_in *, asoc->streamincnt * in sctp_process_init()
359 if (asoc->strmin == NULL) { in sctp_process_init()
365 asoc->strmin[i].sid = i; in sctp_process_init()
366 asoc->strmin[i].last_mid_delivered = 0xffffffff; in sctp_process_init()
367 TAILQ_INIT(&asoc->strmin[i].inqueue); in sctp_process_init()
368 TAILQ_INIT(&asoc->strmin[i].uno_inqueue); in sctp_process_init()
[all …]
H A Dsctp_pcb.c4957 if (asoc->strmin) { in sctp_free_assoc()
4959 sctp_clean_up_stream(stcb, &asoc->strmin[i].inqueue); in sctp_free_assoc()
4960 sctp_clean_up_stream(stcb, &asoc->strmin[i].uno_inqueue); in sctp_free_assoc()
4962 SCTP_FREE(asoc->strmin, SCTP_M_STRMI); in sctp_free_assoc()
4963 asoc->strmin = NULL; in sctp_free_assoc()
6649 TAILQ_FOREACH_SAFE(control, &asoc->strmin[strmat].inqueue, next_instrm, ncontrol) { in sctp_drain_mbufs()
6676 TAILQ_REMOVE(&asoc->strmin[strmat].inqueue, control, next_instrm); in sctp_drain_mbufs()
6709 TAILQ_FOREACH_SAFE(control, &asoc->strmin[strmat].uno_inqueue, next_instrm, ncontrol) { in sctp_drain_mbufs()
6736 TAILQ_REMOVE(&asoc->strmin[strmat].uno_inqueue, control, next_instrm); in sctp_drain_mbufs()
H A Dsctp_structs.h853 struct sctp_stream_in *strmin; member
H A Dsctputil.c5796 (ctl->stcb->asoc.strmin[ctl->sinfo_stream].delivery_started == 0))) in sctp_sorecvmsg()
5812 (ctl->stcb->asoc.strmin[ctl->sinfo_stream].delivery_started == 0)))) { in sctp_sorecvmsg()
5889 stcb->asoc.strmin[control->sinfo_stream].delivery_started = 1; in sctp_sorecvmsg()
6071 control->stcb->asoc.strmin[control->sinfo_stream].delivery_started = 0; in sctp_sorecvmsg()
6300 control->stcb->asoc.strmin[control->sinfo_stream].delivery_started = 0; in sctp_sorecvmsg()
6305 control->stcb->asoc.strmin[control->sinfo_stream].delivery_started = 0; in sctp_sorecvmsg()
6357 control->stcb->asoc.strmin[control->sinfo_stream].delivery_started = 0; in sctp_sorecvmsg()