Home
last modified time | relevance | path

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

/NextBSD/sys/netinet/
HDsctp_indata.c412 nxt_todel = asoc->strmin[stream_no].last_sequence_delivered + 1; in sctp_service_reassembly()
482 asoc->strmin[stream_no].last_sequence_delivered++; in sctp_service_reassembly()
513 strm = &asoc->strmin[stream_no]; in sctp_service_reassembly()
575 strm = &asoc->strmin[control->sinfo_stream]; in sctp_queue_data_to_stream()
798 asoc->strmin[chk->rec.data.stream_number].last_sequence_delivered + 1; in sctp_deliver_reasm_check()
1488 SCTP_SSN_GE(asoc->strmin[strmno].last_sequence_delivered, strmseq)) { in sctp_process_a_data_chunk()
1491 strmseq, asoc->strmin[strmno].last_sequence_delivered); in sctp_process_a_data_chunk()
1494 asoc->strmin[strmno].last_sequence_delivered, in sctp_process_a_data_chunk()
1551 ((uint16_t) (asoc->strmin[strmno].last_sequence_delivered + 1) == strmseq && in sctp_process_a_data_chunk()
1552 TAILQ_EMPTY(&asoc->strmin[strmno].inqueue)))) { in sctp_process_a_data_chunk()
[all …]
HDsctp_input.c385 if (asoc->strmin != NULL) { in sctp_process_init()
390 TAILQ_FOREACH_SAFE(ctl, &asoc->strmin[i].inqueue, next, nctl) { in sctp_process_init()
391 TAILQ_REMOVE(&asoc->strmin[i].inqueue, ctl, next); in sctp_process_init()
399 SCTP_FREE(asoc->strmin, SCTP_M_STRMI); in sctp_process_init()
406 SCTP_MALLOC(asoc->strmin, struct sctp_stream_in *, asoc->streamincnt * in sctp_process_init()
408 if (asoc->strmin == NULL) { in sctp_process_init()
414 asoc->strmin[i].stream_no = i; in sctp_process_init()
415 asoc->strmin[i].last_sequence_delivered = 0xffff; in sctp_process_init()
416 TAILQ_INIT(&asoc->strmin[i].inqueue); in sctp_process_init()
417 asoc->strmin[i].delivery_started = 0; in sctp_process_init()
[all …]
HDsctp_pcb.c5101 if (asoc->strmin) { in sctp_free_assoc()
5105 TAILQ_FOREACH_SAFE(ctl, &asoc->strmin[i].inqueue, next, nctl) { in sctp_free_assoc()
5106 TAILQ_REMOVE(&asoc->strmin[i].inqueue, ctl, next); in sctp_free_assoc()
5120 SCTP_FREE(asoc->strmin, SCTP_M_STRMI); in sctp_free_assoc()
5121 asoc->strmin = NULL; in sctp_free_assoc()
6859 TAILQ_FOREACH_SAFE(ctl, &asoc->strmin[strmat].inqueue, next, nctl) { in sctp_drain_mbufs()
6867 TAILQ_REMOVE(&asoc->strmin[strmat].inqueue, ctl, next); in sctp_drain_mbufs()
HDsctp_structs.h846 struct sctp_stream_in *strmin; member
HDsctputil.c5547 (ctl->stcb->asoc.strmin[ctl->sinfo_stream].delivery_started == 0))) in sctp_sorecvmsg()
5563 (ctl->stcb->asoc.strmin[ctl->sinfo_stream].delivery_started == 0)))) { in sctp_sorecvmsg()
5644 stcb->asoc.strmin[control->sinfo_stream].delivery_started = 1; in sctp_sorecvmsg()
5815 control->stcb->asoc.strmin[control->sinfo_stream].delivery_started = 0; in sctp_sorecvmsg()
6047 control->stcb->asoc.strmin[control->sinfo_stream].delivery_started = 0; in sctp_sorecvmsg()
6052 control->stcb->asoc.strmin[control->sinfo_stream].delivery_started = 0; in sctp_sorecvmsg()
6104 control->stcb->asoc.strmin[control->sinfo_stream].delivery_started = 0; in sctp_sorecvmsg()