Home
last modified time | relevance | path

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

/NextBSD/sys/netinet/
HDsctp_output.c3634 SCTP_FREE(stcb->asoc.strmout, SCTP_M_STRMO); in sctp_process_cmsgs_for_init()
3635 stcb->asoc.strmout = tmp_str; in sctp_process_cmsgs_for_init()
3641 TAILQ_INIT(&stcb->asoc.strmout[i].outqueue); in sctp_process_cmsgs_for_init()
3642 stcb->asoc.strmout[i].chunks_on_queues = 0; in sctp_process_cmsgs_for_init()
3643 stcb->asoc.strmout[i].next_sequence_send = 0; in sctp_process_cmsgs_for_init()
3646 stcb->asoc.strmout[i].abandoned_sent[j] = 0; in sctp_process_cmsgs_for_init()
3647 stcb->asoc.strmout[i].abandoned_unsent[j] = 0; in sctp_process_cmsgs_for_init()
3650 stcb->asoc.strmout[i].abandoned_sent[0] = 0; in sctp_process_cmsgs_for_init()
3651 stcb->asoc.strmout[i].abandoned_unsent[0] = 0; in sctp_process_cmsgs_for_init()
3653 stcb->asoc.strmout[i].stream_no = i; in sctp_process_cmsgs_for_init()
[all …]
HDsctp_timer.c441 if (asoc->strmout[chk->rec.data.stream_number].chunks_on_queues > 0) { in sctp_recover_sent_list()
442 asoc->strmout[chk->rec.data.stream_number].chunks_on_queues--; in sctp_recover_sent_list()
445 if ((asoc->strmout[chk->rec.data.stream_number].chunks_on_queues == 0) && in sctp_recover_sent_list()
446 (asoc->strmout[chk->rec.data.stream_number].state == SCTP_STREAM_RESET_PENDING) && in sctp_recover_sent_list()
447 TAILQ_EMPTY(&asoc->strmout[chk->rec.data.stream_number].outqueue)) { in sctp_recover_sent_list()
1357 if (!TAILQ_EMPTY(&stcb->asoc.strmout[i].outqueue)) { in sctp_audit_stream_queues_for_size()
1358 TAILQ_FOREACH(sp, &stcb->asoc.strmout[i].outqueue, next) { in sctp_audit_stream_queues_for_size()
HDsctp_input.c241 sp = TAILQ_FIRST(&stcb->asoc.strmout[i].outqueue); in sctp_is_there_unsent_data()
262 TAILQ_REMOVE(&stcb->asoc.strmout[i].outqueue, sp, next); in sctp_is_there_unsent_data()
320 if (asoc->strmout[chk->rec.data.stream_number].chunks_on_queues > 0) { in sctp_process_init()
321 asoc->strmout[chk->rec.data.stream_number].chunks_on_queues--; in sctp_process_init()
340 if (asoc->strmout) { in sctp_process_init()
342 outs = &asoc->strmout[i]; in sctp_process_init()
369 asoc->strmout[i].state = SCTP_STREAM_OPEN; in sctp_process_init()
1942 stcb->asoc.strmout[i].chunks_on_queues = 0; in sctp_process_cookie_existing()
1945 asoc->strmout[i].abandoned_sent[j] = 0; in sctp_process_cookie_existing()
1946 asoc->strmout[i].abandoned_unsent[j] = 0; in sctp_process_cookie_existing()
[all …]
HDsctp_ss_functions.c63 &stcb->asoc.strmout[i], in sctp_ss_default_init()
699 sp = TAILQ_FIRST(&stcb->asoc.strmout[i].outqueue); in sctp_ss_fcfs_init()
707 sctp_ss_fcfs_add(stcb, &stcb->asoc, &stcb->asoc.strmout[i], sp, holds_lock); in sctp_ss_fcfs_init()
799 strq = &asoc->strmout[sp->stream]; in sctp_ss_fcfs_select()
HDsctputil.c1104 SCTP_MALLOC(asoc->strmout, struct sctp_stream_out *, in sctp_init_asoc()
1107 if (asoc->strmout == NULL) { in sctp_init_asoc()
1121 asoc->strmout[i].next_sequence_send = 0x0; in sctp_init_asoc()
1122 TAILQ_INIT(&asoc->strmout[i].outqueue); in sctp_init_asoc()
1123 asoc->strmout[i].chunks_on_queues = 0; in sctp_init_asoc()
1126 asoc->strmout[i].abandoned_sent[j] = 0; in sctp_init_asoc()
1127 asoc->strmout[i].abandoned_unsent[j] = 0; in sctp_init_asoc()
1130 asoc->strmout[i].abandoned_sent[0] = 0; in sctp_init_asoc()
1131 asoc->strmout[i].abandoned_unsent[0] = 0; in sctp_init_asoc()
1133 asoc->strmout[i].stream_no = i; in sctp_init_asoc()
[all …]
HDsctp_indata.c2759 if (stcb->asoc.strmout[tp1->rec.data.stream_number].chunks_on_queues > 0) { in sctp_process_segment_range()
2760 stcb->asoc.strmout[tp1->rec.data.stream_number].chunks_on_queues--; in sctp_process_segment_range()
2766 if ((stcb->asoc.strmout[tp1->rec.data.stream_number].chunks_on_queues == 0) && in sctp_process_segment_range()
2767 (stcb->asoc.strmout[tp1->rec.data.stream_number].state == SCTP_STREAM_RESET_PENDING) && in sctp_process_segment_range()
2768 TAILQ_EMPTY(&stcb->asoc.strmout[tp1->rec.data.stream_number].outqueue)) { in sctp_process_segment_range()
3736 if (asoc->strmout[tp1->rec.data.stream_number].chunks_on_queues > 0) { in sctp_express_handle_sack()
3737 asoc->strmout[tp1->rec.data.stream_number].chunks_on_queues--; in sctp_express_handle_sack()
3744 if ((asoc->strmout[tp1->rec.data.stream_number].chunks_on_queues == 0) && in sctp_express_handle_sack()
3745 (asoc->strmout[tp1->rec.data.stream_number].state == SCTP_STREAM_RESET_PENDING) && in sctp_express_handle_sack()
3746 TAILQ_EMPTY(&asoc->strmout[tp1->rec.data.stream_number].outqueue)) { in sctp_express_handle_sack()
[all …]
HDsctp_pcb.c4358 if (asoc->strmout) { in sctp_aloc_assoc()
4359 SCTP_FREE(asoc->strmout, SCTP_M_STRMO); in sctp_aloc_assoc()
4360 asoc->strmout = NULL; in sctp_aloc_assoc()
4919 outs = &asoc->strmout[i]; in sctp_free_assoc()
4979 if (asoc->strmout[chk->rec.data.stream_number].chunks_on_queues > 0) { in sctp_free_assoc()
4980 asoc->strmout[chk->rec.data.stream_number].chunks_on_queues--; in sctp_free_assoc()
5011 if (asoc->strmout[chk->rec.data.stream_number].chunks_on_queues > 0) { in sctp_free_assoc()
5012 asoc->strmout[chk->rec.data.stream_number].chunks_on_queues--; in sctp_free_assoc()
5040 if (stcb->asoc.strmout[i].chunks_on_queues > 0) { in sctp_free_assoc()
5041 panic("%u chunks left for stream %u.", stcb->asoc.strmout[i].chunks_on_queues, i); in sctp_free_assoc()
[all …]
HDsctp_usrreq.c1838 … (stcb->asoc.ss_functions.sctp_ss_get_value(stcb, &stcb->asoc, &stcb->asoc.strmout[av->stream_id],
3648 sprstat->sprstat_abandoned_unsent = stcb->asoc.strmout[sid].abandoned_unsent[0];
3649 sprstat->sprstat_abandoned_sent = stcb->asoc.strmout[sid].abandoned_sent[0];
3651 sprstat->sprstat_abandoned_unsent = stcb->asoc.strmout[sid].abandoned_unsent[policy];
3652 sprstat->sprstat_abandoned_sent = stcb->asoc.strmout[sid].abandoned_sent[policy];
3658 sprstat->sprstat_abandoned_unsent = stcb->asoc.strmout[sid].abandoned_unsent[0];
3659 sprstat->sprstat_abandoned_sent = stcb->asoc.strmout[sid].abandoned_sent[0];
4064 … (stcb->asoc.ss_functions.sctp_ss_set_value(stcb, &stcb->asoc, &stcb->asoc.strmout[av->stream_id],
4078 &stcb->asoc.strmout[av->stream_id],
4636 if (stcb->asoc.strmout[strm].state == SCTP_STREAM_OPEN) {
[all …]
HDsctp_structs.h847 struct sctp_stream_out *strmout; member