Home
last modified time | relevance | path

Searched refs:strmout (Results 1 – 9 of 9) sorted by relevance

/f-stack/freebsd/netinet/
H A Dsctp_input.c338 if (asoc->strmout) { in sctp_process_init()
340 outs = &asoc->strmout[i]; in sctp_process_init()
367 if (asoc->strmout) { in sctp_process_init()
369 asoc->strmout[i].state = SCTP_STREAM_OPEN; in sctp_process_init()
1864 stcb->asoc.strmout[i].chunks_on_queues = 0; in sctp_process_cookie_existing()
1867 asoc->strmout[i].abandoned_sent[j] = 0; in sctp_process_cookie_existing()
1868 asoc->strmout[i].abandoned_unsent[j] = 0; in sctp_process_cookie_existing()
1871 asoc->strmout[i].abandoned_sent[0] = 0; in sctp_process_cookie_existing()
1872 asoc->strmout[i].abandoned_unsent[0] = 0; in sctp_process_cookie_existing()
1874 stcb->asoc.strmout[i].next_mid_ordered = 0; in sctp_process_cookie_existing()
[all …]
H A Dsctp_output.c3625 stcb->asoc.strmout = tmp_str; in sctp_process_cmsgs_for_init()
3645 stcb->asoc.strmout[i].sid = i; in sctp_process_cmsgs_for_init()
12141 oldstream = stcb->asoc.strmout; in sctp_send_str_reset_req()
12146 if (stcb->asoc.strmout == NULL) { in sctp_send_str_reset_req()
12149 stcb->asoc.strmout = oldstream; in sctp_send_str_reset_req()
12162 TAILQ_INIT(&stcb->asoc.strmout[i].outqueue); in sctp_send_str_reset_req()
12182 stcb->asoc.strmout[i].sid = i; in sctp_send_str_reset_req()
12194 stcb->asoc.strmout[i].chunks_on_queues = 0; in sctp_send_str_reset_req()
12204 stcb->asoc.strmout[i].next_mid_ordered = 0; in sctp_send_str_reset_req()
12206 stcb->asoc.strmout[i].sid = i; in sctp_send_str_reset_req()
[all …]
H A Dsctp_timer.c452 if (asoc->strmout[chk->rec.data.sid].chunks_on_queues > 0) { in sctp_recover_sent_list()
453 asoc->strmout[chk->rec.data.sid].chunks_on_queues--; in sctp_recover_sent_list()
456 if ((asoc->strmout[chk->rec.data.sid].chunks_on_queues == 0) && in sctp_recover_sent_list()
457 (asoc->strmout[chk->rec.data.sid].state == SCTP_STREAM_RESET_PENDING) && in sctp_recover_sent_list()
458 TAILQ_EMPTY(&asoc->strmout[chk->rec.data.sid].outqueue)) { in sctp_recover_sent_list()
1378 if (!TAILQ_EMPTY(&stcb->asoc.strmout[i].outqueue)) { in sctp_audit_stream_queues_for_size()
1379 TAILQ_FOREACH(sp, &stcb->asoc.strmout[i].outqueue, next) { in sctp_audit_stream_queues_for_size()
H A Dsctputil.c1280 if (asoc->strmout == NULL) { in sctp_init_asoc()
1294 TAILQ_INIT(&asoc->strmout[i].outqueue); in sctp_init_asoc()
1296 asoc->strmout[i].chunks_on_queues = 0; in sctp_init_asoc()
1299 asoc->strmout[i].abandoned_sent[j] = 0; in sctp_init_asoc()
1303 asoc->strmout[i].abandoned_sent[0] = 0; in sctp_init_asoc()
1306 asoc->strmout[i].next_mid_ordered = 0; in sctp_init_asoc()
1308 asoc->strmout[i].sid = i; in sctp_init_asoc()
1319 SCTP_FREE(asoc->strmout, SCTP_M_STRMO); in sctp_init_asoc()
1327 SCTP_FREE(asoc->strmout, SCTP_M_STRMO); in sctp_init_asoc()
4297 outs = &asoc->strmout[i]; in sctp_report_all_outbound()
[all …]
H A Dsctp_ss_functions.c70 &stcb->asoc.strmout[i], in sctp_ss_default_init()
790 sp = TAILQ_FIRST(&stcb->asoc.strmout[i].outqueue); in sctp_ss_fcfs_init()
798 sctp_ss_fcfs_add(stcb, &stcb->asoc, &stcb->asoc.strmout[i], sp, 1); in sctp_ss_fcfs_init()
911 strq = &asoc->strmout[sp->sid]; in sctp_ss_fcfs_select()
H A Dsctp_indata.c3133 if (stcb->asoc.strmout[tp1->rec.data.sid].chunks_on_queues > 0) { in sctp_process_segment_range()
3134 stcb->asoc.strmout[tp1->rec.data.sid].chunks_on_queues--; in sctp_process_segment_range()
3142 TAILQ_EMPTY(&stcb->asoc.strmout[tp1->rec.data.sid].outqueue)) { in sctp_process_segment_range()
4101 if (asoc->strmout[tp1->rec.data.sid].chunks_on_queues > 0) { in sctp_express_handle_sack()
4102 asoc->strmout[tp1->rec.data.sid].chunks_on_queues--; in sctp_express_handle_sack()
4109 if ((asoc->strmout[tp1->rec.data.sid].chunks_on_queues == 0) && in sctp_express_handle_sack()
4111 TAILQ_EMPTY(&asoc->strmout[tp1->rec.data.sid].outqueue)) { in sctp_express_handle_sack()
4775 if (asoc->strmout[tp1->rec.data.sid].chunks_on_queues > 0) { in sctp_handle_sack()
4776 asoc->strmout[tp1->rec.data.sid].chunks_on_queues--; in sctp_handle_sack()
4783 if ((asoc->strmout[tp1->rec.data.sid].chunks_on_queues == 0) && in sctp_handle_sack()
[all …]
H A Dsctp_pcb.c4350 if (asoc->strmout) { in sctp_aloc_assoc()
4351 SCTP_FREE(asoc->strmout, SCTP_M_STRMO); in sctp_aloc_assoc()
4352 asoc->strmout = NULL; in sctp_aloc_assoc()
4924 outs = &asoc->strmout[i]; in sctp_free_assoc()
4985 if (asoc->strmout[chk->rec.data.sid].chunks_on_queues > 0) { in sctp_free_assoc()
4986 asoc->strmout[chk->rec.data.sid].chunks_on_queues--; in sctp_free_assoc()
5018 asoc->strmout[chk->rec.data.sid].chunks_on_queues--; in sctp_free_assoc()
5046 if (stcb->asoc.strmout[i].chunks_on_queues > 0) { in sctp_free_assoc()
5088 if (asoc->strmout) { in sctp_free_assoc()
5089 SCTP_FREE(asoc->strmout, SCTP_M_STRMO); in sctp_free_assoc()
[all …]
H A Dsctp_usrreq.c3629 sprstat->sprstat_abandoned_unsent = stcb->asoc.strmout[sid].abandoned_unsent[0];
3630 sprstat->sprstat_abandoned_sent = stcb->asoc.strmout[sid].abandoned_sent[0];
3633 sprstat->sprstat_abandoned_sent = stcb->asoc.strmout[sid].abandoned_sent[policy];
3639 sprstat->sprstat_abandoned_unsent = stcb->asoc.strmout[sid].abandoned_unsent[0];
3640 sprstat->sprstat_abandoned_sent = stcb->asoc.strmout[sid].abandoned_sent[0];
4120 &stcb->asoc.strmout[av->stream_id],
4703 if (stcb->asoc.strmout[strm].state == SCTP_STREAM_OPEN) {
4704 stcb->asoc.strmout[strm].state = SCTP_STREAM_RESET_PENDING;
4711 if (stcb->asoc.strmout[i].state == SCTP_STREAM_OPEN) {
4712 stcb->asoc.strmout[i].state = SCTP_STREAM_RESET_PENDING;
[all …]
H A Dsctp_structs.h853 struct sctp_stream_out *strmout; member