Home
last modified time | relevance | path

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

/third_party/gstreamer/gstplugins_bad/ext/sctp/usrsctp/usrsctplib/netinet/
Dsctp_indata.c537 strm = &asoc->strmin[control->sinfo_stream]; in sctp_queue_data_to_stream()
1411 strm = &asoc->strmin[control->sinfo_stream]; in sctp_queue_data_for_reasm()
1898 control = sctp_find_reasm_entry(&asoc->strmin[sid], mid, ordered, asoc->idata_supported); in sctp_process_a_data_chunk()
2037 SCTP_MID_GE(asoc->idata_supported, asoc->strmin[sid].last_mid_delivered, mid)) { in sctp_process_a_data_chunk()
2040 mid, asoc->strmin[sid].last_mid_delivered); in sctp_process_a_data_chunk()
2044 asoc->strmin[sid].last_mid_delivered, in sctp_process_a_data_chunk()
2050 (uint16_t)asoc->strmin[sid].last_mid_delivered, in sctp_process_a_data_chunk()
2153 (SCTP_MID_EQ(asoc->idata_supported, asoc->strmin[sid].last_mid_delivered + 1, mid) && in sctp_process_a_data_chunk()
2154 TAILQ_EMPTY(&asoc->strmin[sid].inqueue)))) { in sctp_process_a_data_chunk()
2176 asoc->strmin[sid].last_mid_delivered++; in sctp_process_a_data_chunk()
[all …]
Dsctp_input.c411 if (asoc->strmin != NULL) { in sctp_process_init()
414 sctp_clean_up_stream(stcb, &asoc->strmin[i].inqueue); in sctp_process_init()
415 sctp_clean_up_stream(stcb, &asoc->strmin[i].uno_inqueue); in sctp_process_init()
417 SCTP_FREE(asoc->strmin, SCTP_M_STRMI); in sctp_process_init()
424 SCTP_MALLOC(asoc->strmin, struct sctp_stream_in *, asoc->streamincnt * in sctp_process_init()
426 if (asoc->strmin == NULL) { in sctp_process_init()
432 asoc->strmin[i].sid = i; in sctp_process_init()
433 asoc->strmin[i].last_mid_delivered = 0xffffffff; in sctp_process_init()
434 TAILQ_INIT(&asoc->strmin[i].inqueue); in sctp_process_init()
435 TAILQ_INIT(&asoc->strmin[i].uno_inqueue); in sctp_process_init()
[all …]
Dsctp_pcb.c5864 if (asoc->strmin) {
5866 sctp_clean_up_stream(stcb, &asoc->strmin[i].inqueue);
5867 sctp_clean_up_stream(stcb, &asoc->strmin[i].uno_inqueue);
5869 SCTP_FREE(asoc->strmin, SCTP_M_STRMI);
5870 asoc->strmin = NULL;
7810 TAILQ_FOREACH_SAFE(control, &asoc->strmin[strmat].inqueue, next_instrm, ncontrol) {
7837 TAILQ_REMOVE(&asoc->strmin[strmat].inqueue, control, next_instrm);
7870 TAILQ_FOREACH_SAFE(control, &asoc->strmin[strmat].uno_inqueue, next_instrm, ncontrol) {
7897 TAILQ_REMOVE(&asoc->strmin[strmat].uno_inqueue, control, next_instrm);
Dsctp_structs.h910 struct sctp_stream_in *strmin; member
Dsctputil.c6378 (ctl->stcb->asoc.strmin[ctl->sinfo_stream].delivery_started == 0)))
6394 (ctl->stcb->asoc.strmin[ctl->sinfo_stream].delivery_started == 0)))) {
6470 stcb->asoc.strmin[control->sinfo_stream].delivery_started = 1;
6671 control->stcb->asoc.strmin[control->sinfo_stream].delivery_started = 0;
6926 control->stcb->asoc.strmin[control->sinfo_stream].delivery_started = 0;
6931 control->stcb->asoc.strmin[control->sinfo_stream].delivery_started = 0;
6979 control->stcb->asoc.strmin[control->sinfo_stream].delivery_started = 0;