Searched refs:strmin (Results 1 – 4 of 4) sorted by relevance
591 nxt_todel = asoc->strmin[stream_no].last_sequence_delivered + 1; in sctp_service_reassembly() 718 asoc->strmin[stream_no].last_sequence_delivered++; in sctp_service_reassembly() 741 strm = &asoc->strmin[stream_no]; in sctp_service_reassembly() 818 strm = &asoc->strmin[chk->rec.data.stream_number]; in sctp_queue_data_to_stream() 1569 asoc->strmin[chk->rec.data.stream_number].last_sequence_delivered + 1; in sctp_queue_data_for_reasm() 1835 (compare_with_wrap(asoc->strmin[strmno].last_sequence_delivered, in sctp_process_a_data_chunk() 1837 asoc->strmin[strmno].last_sequence_delivered == strmseq)) { in sctp_process_a_data_chunk() 1843 asoc->strmin[strmno].last_sequence_delivered); in sctp_process_a_data_chunk() 1894 ((asoc->strmin[strmno].last_sequence_delivered + 1) == strmseq && in sctp_process_a_data_chunk() 1895 TAILQ_EMPTY(&asoc->strmin[strmn in sctp_process_a_data_chunk() 4330 sctp_kick_prsctp_reorder_queue(struct sctp_tcb * stcb,struct sctp_stream_in * strmin) sctp_kick_prsctp_reorder_queue() argument [all...]
242 if (asoc->strmin != NULL) { in sctp_process_init()244 free(asoc->strmin, M_PCB); in sctp_process_init()246 asoc->strmin = malloc(asoc->streamincnt * sizeof(struct sctp_stream_in), in sctp_process_init()248 if (asoc->strmin == NULL) { in sctp_process_init()258 asoc->strmin[i].stream_no = i; in sctp_process_init()259 asoc->strmin[i].last_sequence_delivered = 0xffff; in sctp_process_init()266 TAILQ_INIT(&asoc->strmin[i].inqueue); in sctp_process_init()272 asoc->strmin[i].next_spoke.tqe_next = 0; in sctp_process_init()273 asoc->strmin[i].next_spoke.tqe_prev = 0; in sctp_process_init()2615 stcb->asoc.strmin[(list[i])].last_sequence_delivered = 0xffff; in sctp_reset_in_stream()[all …]
3254 if (asoc->strmin) { in sctp_free_assoc()3257 if (!TAILQ_EMPTY(&asoc->strmin[i].inqueue)) { in sctp_free_assoc()3259 chk = TAILQ_FIRST(&asoc->strmin[i].inqueue); in sctp_free_assoc()3261 TAILQ_REMOVE(&asoc->strmin[i].inqueue, in sctp_free_assoc()3272 chk = TAILQ_FIRST(&asoc->strmin[i].inqueue); in sctp_free_assoc()3276 free(asoc->strmin, M_PCB); in sctp_free_assoc()3277 asoc->strmin = NULL; in sctp_free_assoc()4534 chk = TAILQ_FIRST(&asoc->strmin[strmat].inqueue); in sctp_drain_mbufs()4555 TAILQ_REMOVE(&asoc->strmin[strmat].inqueue, in sctp_drain_mbufs()
355 struct sctp_stream_in *strmin; member