Lines Matching refs:asoc
69 oute = SCTP_SO(&q->asoc->stream, stream)->ext; in sctp_outq_head_data()
90 oute = SCTP_SO(&q->asoc->stream, stream)->ext; in sctp_outq_tail_data()
191 void sctp_outq_init(struct sctp_association *asoc, struct sctp_outq *q) in sctp_outq_init() argument
195 q->asoc = asoc; in sctp_outq_init()
201 sctp_sched_set_sched(asoc, sctp_sk(asoc->base.sk)->default_ss); in sctp_outq_init()
213 list_for_each_entry(transport, &q->asoc->peer.transport_addr_list, in __sctp_outq_teardown()
270 sctp_outq_init(q->asoc, q); in sctp_outq_teardown()
283 struct net *net = q->asoc->base.net; in sctp_outq_tail()
300 if (chunk->asoc->peer.prsctp_capable && in sctp_outq_tail()
302 chunk->asoc->sent_cnt_removable++; in sctp_outq_tail()
342 static int sctp_prsctp_prune_sent(struct sctp_association *asoc, in sctp_prsctp_prune_sent() argument
358 sctp_insert_list(&asoc->outqueue.abandoned, in sctp_prsctp_prune_sent()
361 streamout = SCTP_SO(&asoc->stream, chk->sinfo.sinfo_stream); in sctp_prsctp_prune_sent()
362 asoc->sent_cnt_removable--; in sctp_prsctp_prune_sent()
363 asoc->abandoned_sent[SCTP_PR_INDEX(PRIO)]++; in sctp_prsctp_prune_sent()
366 if (queue != &asoc->outqueue.retransmit && in sctp_prsctp_prune_sent()
371 asoc->outqueue.outstanding_bytes -= sctp_data_size(chk); in sctp_prsctp_prune_sent()
382 static int sctp_prsctp_prune_unsent(struct sctp_association *asoc, in sctp_prsctp_prune_unsent() argument
385 struct sctp_outq *q = &asoc->outqueue; in sctp_prsctp_prune_unsent()
389 q->sched->unsched_all(&asoc->stream); in sctp_prsctp_prune_unsent()
400 asoc->sent_cnt_removable--; in sctp_prsctp_prune_unsent()
401 asoc->abandoned_unsent[SCTP_PR_INDEX(PRIO)]++; in sctp_prsctp_prune_unsent()
403 sout = SCTP_SO(&asoc->stream, chk->sinfo.sinfo_stream); in sctp_prsctp_prune_unsent()
407 if (asoc->stream.out_curr == sout && in sctp_prsctp_prune_unsent()
409 asoc->stream.out_curr = NULL; in sctp_prsctp_prune_unsent()
417 q->sched->sched_all(&asoc->stream); in sctp_prsctp_prune_unsent()
423 void sctp_prsctp_prune(struct sctp_association *asoc, in sctp_prsctp_prune() argument
428 if (!asoc->peer.prsctp_capable || !asoc->sent_cnt_removable) in sctp_prsctp_prune()
431 msg_len = sctp_prsctp_prune_sent(asoc, sinfo, in sctp_prsctp_prune()
432 &asoc->outqueue.retransmit, in sctp_prsctp_prune()
437 list_for_each_entry(transport, &asoc->peer.transport_addr_list, in sctp_prsctp_prune()
439 msg_len = sctp_prsctp_prune_sent(asoc, sinfo, in sctp_prsctp_prune()
446 sctp_prsctp_prune_unsent(asoc, sinfo, msg_len); in sctp_prsctp_prune()
477 q->asoc->peer.rwnd += sctp_data_size(chunk); in sctp_retransmit_mark()
497 q->asoc->peer.rwnd += sctp_data_size(chunk); in sctp_retransmit_mark()
540 struct net *net = q->asoc->base.net; in sctp_retransmit()
549 if (transport == transport->asoc->peer.retran_path) in sctp_retransmit()
550 sctp_assoc_update_retran_path(transport->asoc); in sctp_retransmit()
551 transport->asoc->rtx_data_chunks += in sctp_retransmit()
552 transport->asoc->unack_data; in sctp_retransmit()
564 transport->asoc->init_retries++; in sctp_retransmit()
577 q->asoc->stream.si->generate_ftsn(q, q->asoc->ctsn_ack_point); in sctp_retransmit()
722 q->asoc->stats.rtxchunks++; in __sctp_outq_flush_rtx()
767 const struct sctp_association *asoc = transport->asoc; in sctp_packet_singleton() local
768 const __u16 sport = asoc->base.bind_addr.port; in sctp_packet_singleton()
769 const __u16 dport = asoc->peer.port; in sctp_packet_singleton()
770 const __u32 vtag = asoc->peer.i.init_tag; in sctp_packet_singleton()
786 struct sctp_association *asoc; member
813 new_transport = sctp_assoc_lookup_paddr(ctx->asoc, in sctp_outq_select_transport()
821 new_transport = ctx->asoc->peer.active_path; in sctp_outq_select_transport()
846 new_transport = ctx->asoc->peer.active_path; in sctp_outq_select_transport()
863 ctx->asoc->peer.i.init_tag, in sctp_outq_select_transport()
864 ctx->asoc->peer.ecn_capable); in sctp_outq_select_transport()
887 if (ctx->asoc->src_out_of_asoc_ok && in sctp_outq_flush_ctrl()
910 ctx->asoc->base.sk->sk_err = -error; in sctp_outq_flush_ctrl()
917 ctx->packet->vtag = ctx->asoc->c.my_vtag; in sctp_outq_flush_ctrl()
951 ctx->asoc->stats.octrlchunks++; in sctp_outq_flush_ctrl()
962 if (chunk == ctx->asoc->strreset_chunk) in sctp_outq_flush_ctrl()
980 if (ctx->asoc->peer.retran_path->state == SCTP_UNCONFIRMED) in sctp_outq_flush_rtx()
983 if (ctx->transport != ctx->asoc->peer.retran_path) { in sctp_outq_flush_rtx()
985 ctx->transport = ctx->asoc->peer.retran_path; in sctp_outq_flush_rtx()
992 sctp_packet_config(ctx->packet, ctx->asoc->peer.i.init_tag, in sctp_outq_flush_rtx()
993 ctx->asoc->peer.ecn_capable); in sctp_outq_flush_rtx()
999 ctx->asoc->base.sk->sk_err = -error; in sctp_outq_flush_rtx()
1028 switch (ctx->asoc->state) { in sctp_outq_flush_data()
1070 __u8 stream_state = SCTP_SO(&ctx->asoc->stream, sid)->state; in sctp_outq_flush_data()
1113 if (ctx->asoc->state == SCTP_STATE_SHUTDOWN_PENDING) in sctp_outq_flush_data()
1116 ctx->asoc->stats.ouodchunks++; in sctp_outq_flush_data()
1118 ctx->asoc->stats.oodchunks++; in sctp_outq_flush_data()
1152 ctx->q->asoc->base.sk->sk_err = -error; in sctp_outq_flush_transports()
1175 .asoc = q->asoc, in sctp_outq_flush()
1191 if (q->asoc->src_out_of_asoc_ok) in sctp_outq_flush()
1227 struct sctp_association *asoc = q->asoc; in sctp_outq_sack() local
1237 struct sctp_transport *primary = asoc->peer.primary_path; in sctp_outq_sack()
1243 transport_list = &asoc->peer.transport_addr_list; in sctp_outq_sack()
1248 trace_sctp_probe_path(transport, asoc); in sctp_outq_sack()
1253 asoc->stats.gapcnt += gap_ack_blocks; in sctp_outq_sack()
1296 if (TSN_lt(asoc->highest_sacked, highest_tsn)) in sctp_outq_sack()
1297 asoc->highest_sacked = highest_tsn; in sctp_outq_sack()
1325 if (TSN_lt(asoc->ctsn_ack_point, sack_ctsn)) { in sctp_outq_sack()
1326 asoc->ctsn_ack_point = sack_ctsn; in sctp_outq_sack()
1332 if (asoc->fast_recovery && accum_moved) in sctp_outq_sack()
1341 sctp_sack_update_unack_data(asoc, sack); in sctp_outq_sack()
1343 ctsn = asoc->ctsn_ack_point; in sctp_outq_sack()
1352 if (asoc->peer.prsctp_capable && in sctp_outq_sack()
1354 asoc->sent_cnt_removable--; in sctp_outq_sack()
1365 asoc->peer.zero_window_announced = !sack_a_rwnd; in sctp_outq_sack()
1373 asoc->peer.rwnd = sack_a_rwnd; in sctp_outq_sack()
1375 asoc->stream.si->generate_ftsn(q, sack_ctsn); in sctp_outq_sack()
1379 "advertised peer ack point:0x%x\n", __func__, asoc, ctsn, in sctp_outq_sack()
1380 asoc->adv_peer_ack_point); in sctp_outq_sack()
1495 q->asoc->peer.primary_path->cacc. in sctp_check_transmitted()
1579 struct sctp_association *asoc = transport->asoc; in sctp_check_transmitted() local
1597 transport->asoc->overall_error_count = 0; in sctp_check_transmitted()
1606 if (asoc->state == SCTP_STATE_SHUTDOWN_PENDING && in sctp_check_transmitted()
1607 del_timer(&asoc->timers in sctp_check_transmitted()
1609 sctp_association_put(asoc); in sctp_check_transmitted()
1618 transport->asoc, in sctp_check_transmitted()
1646 if (!q->asoc->peer.rwnd && in sctp_check_transmitted()
1648 (sack_ctsn+2 == q->asoc->next_tsn) && in sctp_check_transmitted()
1649 q->asoc->state < SCTP_STATE_SHUTDOWN_PENDING) { in sctp_check_transmitted()
1653 q->asoc->overall_error_count = 0; in sctp_check_transmitted()
1692 struct sctp_association *asoc = q->asoc; in sctp_mark_missing() local
1693 struct sctp_transport *primary = asoc->peer.primary_path; in sctp_mark_missing()
1798 struct sctp_association *asoc = q->asoc; in sctp_generate_fwdtsn() local
1807 if (!asoc->peer.prsctp_capable) in sctp_generate_fwdtsn()
1816 if (TSN_lt(asoc->adv_peer_ack_point, ctsn)) in sctp_generate_fwdtsn()
1817 asoc->adv_peer_ack_point = ctsn; in sctp_generate_fwdtsn()
1852 if (TSN_lte(tsn, asoc->adv_peer_ack_point+1)) { in sctp_generate_fwdtsn()
1853 asoc->adv_peer_ack_point = tsn; in sctp_generate_fwdtsn()
1891 if (asoc->adv_peer_ack_point > ctsn) in sctp_generate_fwdtsn()
1892 ftsn_chunk = sctp_make_fwdtsn(asoc, asoc->adv_peer_ack_point, in sctp_generate_fwdtsn()
1897 SCTP_INC_STATS(asoc->base.net, SCTP_MIB_OUTCTRLCHUNKS); in sctp_generate_fwdtsn()