Home
last modified time | relevance | path

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

/freebsd/sys/netinet/
H A Dsctp_input.c192 sp = TAILQ_FIRST(&stcb->asoc.strmout[i].outqueue); in sctp_is_there_unsent_data()
213 TAILQ_REMOVE(&stcb->asoc.strmout[i].outqueue, sp, next); in sctp_is_there_unsent_data()
214 stcb->asoc.ss_functions.sctp_ss_remove_from_stream(stcb, asoc, &asoc->strmout[i], sp); in sctp_is_there_unsent_data()
224 if (!TAILQ_EMPTY(&stcb->asoc.strmout[i].outqueue)) { in sctp_is_there_unsent_data()
277 if (asoc->strmout[chk->rec.data.sid].chunks_on_queues > 0) { in sctp_process_init()
278 asoc->strmout[chk->rec.data.sid].chunks_on_queues--; in sctp_process_init()
297 if (asoc->strmout) { in sctp_process_init()
299 outs = &asoc->strmout[i]; in sctp_process_init()
325 if (asoc->strmout) { in sctp_process_init()
327 asoc->strmout[i].state = SCTP_STREAM_OPEN; in sctp_process_init()
[all …]
H A Dsctp_output.c3620 SCTP_FREE(stcb->asoc.strmout, SCTP_M_STRMO); in sctp_process_cmsgs_for_init()
3621 stcb->asoc.strmout = tmp_str; in sctp_process_cmsgs_for_init()
3627 TAILQ_INIT(&stcb->asoc.strmout[i].outqueue); in sctp_process_cmsgs_for_init()
3628 stcb->asoc.ss_functions.sctp_ss_init_stream(stcb, &stcb->asoc.strmout[i], NULL); in sctp_process_cmsgs_for_init()
3629 stcb->asoc.strmout[i].chunks_on_queues = 0; in sctp_process_cmsgs_for_init()
3632 stcb->asoc.strmout[i].abandoned_sent[j] = 0; in sctp_process_cmsgs_for_init()
3633 stcb->asoc.strmout[i].abandoned_unsent[j] = 0; in sctp_process_cmsgs_for_init()
3636 stcb->asoc.strmout[i].abandoned_sent[0] = 0; in sctp_process_cmsgs_for_init()
3637 stcb->asoc.strmout[i].abandoned_unsent[0] = 0; in sctp_process_cmsgs_for_init()
3639 stcb->asoc.strmout[i].next_mid_ordered = 0; in sctp_process_cmsgs_for_init()
[all …]
H A Dsctp_timer.c446 if (asoc->strmout[chk->rec.data.sid].chunks_on_queues > 0) { in sctp_recover_sent_list()
447 asoc->strmout[chk->rec.data.sid].chunks_on_queues--; in sctp_recover_sent_list()
450 if ((asoc->strmout[chk->rec.data.sid].chunks_on_queues == 0) && in sctp_recover_sent_list()
451 (asoc->strmout[chk->rec.data.sid].state == SCTP_STREAM_RESET_PENDING) && in sctp_recover_sent_list()
452 TAILQ_EMPTY(&asoc->strmout[chk->rec.data.sid].outqueue)) { in sctp_recover_sent_list()
1373 if (!TAILQ_EMPTY(&stcb->asoc.strmout[i].outqueue)) { in sctp_audit_stream_queues_for_size()
1374 TAILQ_FOREACH(sp, &stcb->asoc.strmout[i].outqueue, next) { in sctp_audit_stream_queues_for_size()
H A Dsctputil.c1282 SCTP_MALLOC(asoc->strmout, struct sctp_stream_out *, in sctp_init_asoc()
1285 if (asoc->strmout == NULL) { in sctp_init_asoc()
1300 TAILQ_INIT(&asoc->strmout[i].outqueue); in sctp_init_asoc()
1301 asoc->ss_functions.sctp_ss_init_stream(stcb, &asoc->strmout[i], NULL); in sctp_init_asoc()
1302 asoc->strmout[i].chunks_on_queues = 0; in sctp_init_asoc()
1305 asoc->strmout[i].abandoned_sent[j] = 0; in sctp_init_asoc()
1306 asoc->strmout[i].abandoned_unsent[j] = 0; in sctp_init_asoc()
1309 asoc->strmout[i].abandoned_sent[0] = 0; in sctp_init_asoc()
1310 asoc->strmout[i].abandoned_unsent[0] = 0; in sctp_init_asoc()
1312 asoc->strmout[i].next_mid_ordered = 0; in sctp_init_asoc()
[all …]
H A Dsctp_ss_functions.c66 &asoc->strmout[i], in sctp_ss_default_init()
786 sp = TAILQ_FIRST(&asoc->strmout[i].outqueue); in sctp_ss_fcfs_init()
794 sctp_ss_fcfs_add(stcb, asoc, &asoc->strmout[i], sp); in sctp_ss_fcfs_init()
887 strq = &asoc->strmout[sp->sid]; in sctp_ss_fcfs_select()
H A Dsctp_indata.c3121 if (stcb->asoc.strmout[tp1->rec.data.sid].chunks_on_queues > 0) { in sctp_process_segment_range()
3122 stcb->asoc.strmout[tp1->rec.data.sid].chunks_on_queues--; in sctp_process_segment_range()
3128 if ((stcb->asoc.strmout[tp1->rec.data.sid].chunks_on_queues == 0) && in sctp_process_segment_range()
3129 (stcb->asoc.strmout[tp1->rec.data.sid].state == SCTP_STREAM_RESET_PENDING) && in sctp_process_segment_range()
3130 TAILQ_EMPTY(&stcb->asoc.strmout[tp1->rec.data.sid].outqueue)) { in sctp_process_segment_range()
4087 if (asoc->strmout[tp1->rec.data.sid].chunks_on_queues > 0) { in sctp_express_handle_sack()
4088 asoc->strmout[tp1->rec.data.sid].chunks_on_queues--; in sctp_express_handle_sack()
4095 if ((asoc->strmout[tp1->rec.data.sid].chunks_on_queues == 0) && in sctp_express_handle_sack()
4096 (asoc->strmout[tp1->rec.data.sid].state == SCTP_STREAM_RESET_PENDING) && in sctp_express_handle_sack()
4097 TAILQ_EMPTY(&asoc->strmout[tp1->rec.data.sid].outqueue)) { in sctp_express_handle_sack()
[all …]
H A Dsctp_pcb.c4217 if (asoc->strmout) { in sctp_aloc_assoc_locked()
4218 SCTP_FREE(asoc->strmout, SCTP_M_STRMO); in sctp_aloc_assoc_locked()
4219 asoc->strmout = NULL; in sctp_aloc_assoc_locked()
4788 outs = &asoc->strmout[i]; in sctp_free_assoc()
4849 if (asoc->strmout[chk->rec.data.sid].chunks_on_queues > 0) { in sctp_free_assoc()
4850 asoc->strmout[chk->rec.data.sid].chunks_on_queues--; in sctp_free_assoc()
4881 if (asoc->strmout[chk->rec.data.sid].chunks_on_queues > 0) { in sctp_free_assoc()
4882 asoc->strmout[chk->rec.data.sid].chunks_on_queues--; in sctp_free_assoc()
4910 if (stcb->asoc.strmout[i].chunks_on_queues > 0) { in sctp_free_assoc()
4911 panic("%u chunks left for stream %u.", stcb->asoc.strmout[i].chunks_on_queues, i); in sctp_free_assoc()
[all …]
H A Dsctp_usrreq.c1777 … (stcb->asoc.ss_functions.sctp_ss_get_value(stcb, &stcb->asoc, &stcb->asoc.strmout[av->stream_id],
3622 sprstat->sprstat_abandoned_unsent = stcb->asoc.strmout[sid].abandoned_unsent[0];
3623 sprstat->sprstat_abandoned_sent = stcb->asoc.strmout[sid].abandoned_sent[0];
3625 sprstat->sprstat_abandoned_unsent = stcb->asoc.strmout[sid].abandoned_unsent[policy];
3626 sprstat->sprstat_abandoned_sent = stcb->asoc.strmout[sid].abandoned_sent[policy];
3632 sprstat->sprstat_abandoned_unsent = stcb->asoc.strmout[sid].abandoned_unsent[0];
3633 sprstat->sprstat_abandoned_sent = stcb->asoc.strmout[sid].abandoned_sent[0];
4094 … (stcb->asoc.ss_functions.sctp_ss_set_value(stcb, &stcb->asoc, &stcb->asoc.strmout[av->stream_id],
4109 &stcb->asoc.strmout[av->stream_id],
4692 if (stcb->asoc.strmout[strm].state == SCTP_STREAM_OPEN) {
[all …]
H A Dsctp_structs.h854 struct sctp_stream_out *strmout; member