Lines Matching refs:asoc
68 oute = SCTP_SO(&q->asoc->stream, stream)->ext; in sctp_outq_head_data()
89 oute = SCTP_SO(&q->asoc->stream, stream)->ext; in sctp_outq_tail_data()
190 void sctp_outq_init(struct sctp_association *asoc, struct sctp_outq *q) in sctp_outq_init() argument
194 q->asoc = asoc; in sctp_outq_init()
200 sctp_sched_set_sched(asoc, sctp_sk(asoc->base.sk)->default_ss); in sctp_outq_init()
212 list_for_each_entry(transport, &q->asoc->peer.transport_addr_list, in __sctp_outq_teardown()
269 sctp_outq_init(q->asoc, q); in sctp_outq_teardown()
282 struct net *net = sock_net(q->asoc->base.sk); in sctp_outq_tail()
299 if (chunk->asoc->peer.prsctp_capable && in sctp_outq_tail()
301 chunk->asoc->sent_cnt_removable++; in sctp_outq_tail()
341 static int sctp_prsctp_prune_sent(struct sctp_association *asoc, in sctp_prsctp_prune_sent() argument
357 sctp_insert_list(&asoc->outqueue.abandoned, in sctp_prsctp_prune_sent()
360 streamout = SCTP_SO(&asoc->stream, chk->sinfo.sinfo_stream); in sctp_prsctp_prune_sent()
361 asoc->sent_cnt_removable--; in sctp_prsctp_prune_sent()
362 asoc->abandoned_sent[SCTP_PR_INDEX(PRIO)]++; in sctp_prsctp_prune_sent()
365 if (queue != &asoc->outqueue.retransmit && in sctp_prsctp_prune_sent()
370 asoc->outqueue.outstanding_bytes -= sctp_data_size(chk); in sctp_prsctp_prune_sent()
381 static int sctp_prsctp_prune_unsent(struct sctp_association *asoc, in sctp_prsctp_prune_unsent() argument
384 struct sctp_outq *q = &asoc->outqueue; in sctp_prsctp_prune_unsent()
387 q->sched->unsched_all(&asoc->stream); in sctp_prsctp_prune_unsent()
398 asoc->sent_cnt_removable--; in sctp_prsctp_prune_unsent()
399 asoc->abandoned_unsent[SCTP_PR_INDEX(PRIO)]++; in sctp_prsctp_prune_unsent()
400 if (chk->sinfo.sinfo_stream < asoc->stream.outcnt) { in sctp_prsctp_prune_unsent()
402 SCTP_SO(&asoc->stream, chk->sinfo.sinfo_stream); in sctp_prsctp_prune_unsent()
413 q->sched->sched_all(&asoc->stream); in sctp_prsctp_prune_unsent()
419 void sctp_prsctp_prune(struct sctp_association *asoc, in sctp_prsctp_prune() argument
424 if (!asoc->peer.prsctp_capable || !asoc->sent_cnt_removable) in sctp_prsctp_prune()
427 msg_len = sctp_prsctp_prune_sent(asoc, sinfo, in sctp_prsctp_prune()
428 &asoc->outqueue.retransmit, in sctp_prsctp_prune()
433 list_for_each_entry(transport, &asoc->peer.transport_addr_list, in sctp_prsctp_prune()
435 msg_len = sctp_prsctp_prune_sent(asoc, sinfo, in sctp_prsctp_prune()
442 sctp_prsctp_prune_unsent(asoc, sinfo, msg_len); in sctp_prsctp_prune()
473 q->asoc->peer.rwnd += sctp_data_size(chunk); in sctp_retransmit_mark()
493 q->asoc->peer.rwnd += sctp_data_size(chunk); in sctp_retransmit_mark()
536 struct net *net = sock_net(q->asoc->base.sk); in sctp_retransmit()
545 if (transport == transport->asoc->peer.retran_path) in sctp_retransmit()
546 sctp_assoc_update_retran_path(transport->asoc); in sctp_retransmit()
547 transport->asoc->rtx_data_chunks += in sctp_retransmit()
548 transport->asoc->unack_data; in sctp_retransmit()
560 transport->asoc->init_retries++; in sctp_retransmit()
573 q->asoc->stream.si->generate_ftsn(q, q->asoc->ctsn_ack_point); in sctp_retransmit()
718 q->asoc->stats.rtxchunks++; in __sctp_outq_flush_rtx()
763 const struct sctp_association *asoc = transport->asoc; in sctp_packet_singleton() local
764 const __u16 sport = asoc->base.bind_addr.port; in sctp_packet_singleton()
765 const __u16 dport = asoc->peer.port; in sctp_packet_singleton()
766 const __u32 vtag = asoc->peer.i.init_tag; in sctp_packet_singleton()
782 struct sctp_association *asoc; member
809 new_transport = sctp_assoc_lookup_paddr(ctx->asoc, in sctp_outq_select_transport()
817 new_transport = ctx->asoc->peer.active_path; in sctp_outq_select_transport()
842 new_transport = ctx->asoc->peer.active_path; in sctp_outq_select_transport()
859 ctx->asoc->peer.i.init_tag, in sctp_outq_select_transport()
860 ctx->asoc->peer.ecn_capable); in sctp_outq_select_transport()
883 if (ctx->asoc->src_out_of_asoc_ok && in sctp_outq_flush_ctrl()
906 ctx->asoc->base.sk->sk_err = -error; in sctp_outq_flush_ctrl()
913 ctx->packet->vtag = ctx->asoc->c.my_vtag; in sctp_outq_flush_ctrl()
947 ctx->asoc->stats.octrlchunks++; in sctp_outq_flush_ctrl()
958 if (chunk == ctx->asoc->strreset_chunk) in sctp_outq_flush_ctrl()
976 if (ctx->asoc->peer.retran_path->state == SCTP_UNCONFIRMED) in sctp_outq_flush_rtx()
979 if (ctx->transport != ctx->asoc->peer.retran_path) { in sctp_outq_flush_rtx()
981 ctx->transport = ctx->asoc->peer.retran_path; in sctp_outq_flush_rtx()
988 sctp_packet_config(ctx->packet, ctx->asoc->peer.i.init_tag, in sctp_outq_flush_rtx()
989 ctx->asoc->peer.ecn_capable); in sctp_outq_flush_rtx()
995 ctx->asoc->base.sk->sk_err = -error; in sctp_outq_flush_rtx()
1024 switch (ctx->asoc->state) { in sctp_outq_flush_data()
1066 __u8 stream_state = SCTP_SO(&ctx->asoc->stream, sid)->state; in sctp_outq_flush_data()
1109 if (ctx->asoc->state == SCTP_STATE_SHUTDOWN_PENDING) in sctp_outq_flush_data()
1112 ctx->asoc->stats.ouodchunks++; in sctp_outq_flush_data()
1114 ctx->asoc->stats.oodchunks++; in sctp_outq_flush_data()
1148 ctx->q->asoc->base.sk->sk_err = -error; in sctp_outq_flush_transports()
1171 .asoc = q->asoc, in sctp_outq_flush()
1187 if (q->asoc->src_out_of_asoc_ok) in sctp_outq_flush()
1223 struct sctp_association *asoc = q->asoc; in sctp_outq_sack() local
1233 struct sctp_transport *primary = asoc->peer.primary_path; in sctp_outq_sack()
1239 transport_list = &asoc->peer.transport_addr_list; in sctp_outq_sack()
1243 asoc->stats.gapcnt += gap_ack_blocks; in sctp_outq_sack()
1286 if (TSN_lt(asoc->highest_sacked, highest_tsn)) in sctp_outq_sack()
1287 asoc->highest_sacked = highest_tsn; in sctp_outq_sack()
1315 if (TSN_lt(asoc->ctsn_ack_point, sack_ctsn)) { in sctp_outq_sack()
1316 asoc->ctsn_ack_point = sack_ctsn; in sctp_outq_sack()
1322 if (asoc->fast_recovery && accum_moved) in sctp_outq_sack()
1331 sctp_sack_update_unack_data(asoc, sack); in sctp_outq_sack()
1333 ctsn = asoc->ctsn_ack_point; in sctp_outq_sack()
1342 if (asoc->peer.prsctp_capable && in sctp_outq_sack()
1344 asoc->sent_cnt_removable--; in sctp_outq_sack()
1355 asoc->peer.zero_window_announced = !sack_a_rwnd; in sctp_outq_sack()
1363 asoc->peer.rwnd = sack_a_rwnd; in sctp_outq_sack()
1365 asoc->stream.si->generate_ftsn(q, sack_ctsn); in sctp_outq_sack()
1369 "advertised peer ack point:0x%x\n", __func__, asoc, ctsn, in sctp_outq_sack()
1370 asoc->adv_peer_ack_point); in sctp_outq_sack()
1485 q->asoc->peer.primary_path->cacc. in sctp_check_transmitted()
1569 struct sctp_association *asoc = transport->asoc; in sctp_check_transmitted() local
1587 transport->asoc->overall_error_count = 0; in sctp_check_transmitted()
1596 if (asoc->state == SCTP_STATE_SHUTDOWN_PENDING && in sctp_check_transmitted()
1597 del_timer(&asoc->timers in sctp_check_transmitted()
1599 sctp_association_put(asoc); in sctp_check_transmitted()
1608 transport->asoc, in sctp_check_transmitted()
1636 if (!q->asoc->peer.rwnd && in sctp_check_transmitted()
1638 (sack_ctsn+2 == q->asoc->next_tsn) && in sctp_check_transmitted()
1639 q->asoc->state < SCTP_STATE_SHUTDOWN_PENDING) { in sctp_check_transmitted()
1643 q->asoc->overall_error_count = 0; in sctp_check_transmitted()
1682 struct sctp_association *asoc = q->asoc; in sctp_mark_missing() local
1683 struct sctp_transport *primary = asoc->peer.primary_path; in sctp_mark_missing()
1788 struct sctp_association *asoc = q->asoc; in sctp_generate_fwdtsn() local
1797 if (!asoc->peer.prsctp_capable) in sctp_generate_fwdtsn()
1806 if (TSN_lt(asoc->adv_peer_ack_point, ctsn)) in sctp_generate_fwdtsn()
1807 asoc->adv_peer_ack_point = ctsn; in sctp_generate_fwdtsn()
1842 if (TSN_lte(tsn, asoc->adv_peer_ack_point+1)) { in sctp_generate_fwdtsn()
1843 asoc->adv_peer_ack_point = tsn; in sctp_generate_fwdtsn()
1881 if (asoc->adv_peer_ack_point > ctsn) in sctp_generate_fwdtsn()
1882 ftsn_chunk = sctp_make_fwdtsn(asoc, asoc->adv_peer_ack_point, in sctp_generate_fwdtsn()
1887 SCTP_INC_STATS(sock_net(asoc->base.sk), SCTP_MIB_OUTCTRLCHUNKS); in sctp_generate_fwdtsn()