Home
last modified time | relevance | path

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

/external/chromium_org/third_party/usrsctp/usrsctplib/netinet/
Dsctp_ss_functions.c69 &stcb->asoc.strmout[i], in sctp_ss_default_init()
701 sp = TAILQ_FIRST(&stcb->asoc.strmout[i].outqueue); in sctp_ss_fcfs_init()
709 sctp_ss_fcfs_add(stcb, &stcb->asoc, &stcb->asoc.strmout[i], sp, holds_lock); in sctp_ss_fcfs_init()
801 strq = &asoc->strmout[sp->stream]; in sctp_ss_fcfs_select()
Dsctp_timer.c428 if (asoc->strmout[chk->rec.data.stream_number].chunks_on_queues > 0) { in sctp_recover_sent_list()
429 asoc->strmout[chk->rec.data.stream_number].chunks_on_queues--; in sctp_recover_sent_list()
1349 if (!TAILQ_EMPTY(&stcb->asoc.strmout[i].outqueue)) {
1350 TAILQ_FOREACH(sp, &stcb->asoc.strmout[i].outqueue, next) {
Dsctp_output.c3545 SCTP_FREE(stcb->asoc.strmout, SCTP_M_STRMO);
3546 stcb->asoc.strmout = tmp_str;
3552 TAILQ_INIT(&stcb->asoc.strmout[i].outqueue);
3553 stcb->asoc.strmout[i].chunks_on_queues = 0;
3554 stcb->asoc.strmout[i].next_sequence_send = 0;
3555 stcb->asoc.strmout[i].stream_no = i;
3556 stcb->asoc.strmout[i].last_msg_incomplete = 0;
3557 stcb->asoc.ss_functions.sctp_ss_init_stream(&stcb->asoc.strmout[i], NULL);
6558 strm = &stcb->asoc.strmout[srcv->sinfo_stream];
7997 TAILQ_FOREACH(sp, &stcb->asoc.strmout[i].outqueue, next) {
[all …]
Dsctputil.c1116 SCTP_MALLOC(asoc->strmout, struct sctp_stream_out *, in sctp_init_asoc()
1119 if (asoc->strmout == NULL) { in sctp_init_asoc()
1133 asoc->strmout[i].next_sequence_send = 0x0; in sctp_init_asoc()
1134 TAILQ_INIT(&asoc->strmout[i].outqueue); in sctp_init_asoc()
1135 asoc->strmout[i].chunks_on_queues = 0; in sctp_init_asoc()
1136 asoc->strmout[i].stream_no = i; in sctp_init_asoc()
1137 asoc->strmout[i].last_msg_incomplete = 0; in sctp_init_asoc()
1138 asoc->ss_functions.sctp_ss_init_stream(&asoc->strmout[i], NULL); in sctp_init_asoc()
1147 SCTP_FREE(asoc->strmout, SCTP_M_STRMO); in sctp_init_asoc()
1155 SCTP_FREE(asoc->strmout, SCTP_M_STRMO); in sctp_init_asoc()
[all …]
Dsctp_input.c262 sp = TAILQ_FIRST(&stcb->asoc.strmout[i].outqueue); in sctp_is_there_unsent_data()
282 TAILQ_REMOVE(&stcb->asoc.strmout[i].outqueue, sp, next); in sctp_is_there_unsent_data()
341 if (asoc->strmout[chk->rec.data.stream_number].chunks_on_queues > 0) { in sctp_process_init()
342 asoc->strmout[chk->rec.data.stream_number].chunks_on_queues--; in sctp_process_init()
361 if (asoc->strmout) { in sctp_process_init()
363 outs = &asoc->strmout[i]; in sctp_process_init()
1983 stcb->asoc.strmout[i].chunks_on_queues = 0; in sctp_process_cookie_existing()
1984 stcb->asoc.strmout[i].stream_no = i; in sctp_process_cookie_existing()
1985 stcb->asoc.strmout[i].next_sequence_send = 0; in sctp_process_cookie_existing()
1986 stcb->asoc.strmout[i].last_msg_incomplete = 0; in sctp_process_cookie_existing()
[all …]
Dsctp_pcb.c5037 if (asoc->strmout) {
5038 SCTP_FREE(asoc->strmout, SCTP_M_STRMO);
5039 asoc->strmout = NULL;
5609 outs = &asoc->strmout[i];
5669 if (asoc->strmout[chk->rec.data.stream_number].chunks_on_queues > 0) {
5670 asoc->strmout[chk->rec.data.stream_number].chunks_on_queues--;
5701 if (asoc->strmout[chk->rec.data.stream_number].chunks_on_queues > 0) {
5702 asoc->strmout[chk->rec.data.stream_number].chunks_on_queues--;
5730 if (stcb->asoc.strmout[i].chunks_on_queues > 0) {
5731 panic("%u chunks left for stream %u.", stcb->asoc.strmout[i].chunks_on_queues, i);
[all …]
Dsctp_indata.c2785 if (stcb->asoc.strmout[tp1->rec.data.stream_number].chunks_on_queues > 0) { in sctp_process_segment_range()
2786 stcb->asoc.strmout[tp1->rec.data.stream_number].chunks_on_queues--; in sctp_process_segment_range()
3743 if (asoc->strmout[tp1->rec.data.stream_number].chunks_on_queues > 0) {
3744 asoc->strmout[tp1->rec.data.stream_number].chunks_on_queues--;
4485 if (asoc->strmout[tp1->rec.data.stream_number].chunks_on_queues > 0) {
4486 asoc->strmout[tp1->rec.data.stream_number].chunks_on_queues--;
Dsctp_structs.h881 struct sctp_stream_out *strmout; member
Dsctp_usrreq.c2445 …if (stcb->asoc.ss_functions.sctp_ss_get_value(stcb, &stcb->asoc, &stcb->asoc.strmout[av->stream_id…
4363 …if (stcb->asoc.ss_functions.sctp_ss_set_value(stcb, &stcb->asoc, &stcb->asoc.strmout[av->stream_id…
4376 &stcb->asoc.strmout[av->stream_id],