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()
388 q->sched->unsched_all(&asoc->stream); in sctp_prsctp_prune_unsent()
399 asoc->sent_cnt_removable--; in sctp_prsctp_prune_unsent()
400 asoc->abandoned_unsent[SCTP_PR_INDEX(PRIO)]++; in sctp_prsctp_prune_unsent()
401 if (chk->sinfo.sinfo_stream < asoc->stream.outcnt) { in sctp_prsctp_prune_unsent()
403 SCTP_SO(&asoc->stream, chk->sinfo.sinfo_stream); in sctp_prsctp_prune_unsent()
414 q->sched->sched_all(&asoc->stream); in sctp_prsctp_prune_unsent()
420 void sctp_prsctp_prune(struct sctp_association *asoc, in sctp_prsctp_prune() argument
425 if (!asoc->peer.prsctp_capable || !asoc->sent_cnt_removable) in sctp_prsctp_prune()
428 msg_len = sctp_prsctp_prune_sent(asoc, sinfo, in sctp_prsctp_prune()
429 &asoc->outqueue.retransmit, in sctp_prsctp_prune()
434 list_for_each_entry(transport, &asoc->peer.transport_addr_list, in sctp_prsctp_prune()
436 msg_len = sctp_prsctp_prune_sent(asoc, sinfo, in sctp_prsctp_prune()
443 sctp_prsctp_prune_unsent(asoc, sinfo, msg_len); in sctp_prsctp_prune()
474 q->asoc->peer.rwnd += sctp_data_size(chunk); in sctp_retransmit_mark()
494 q->asoc->peer.rwnd += sctp_data_size(chunk); in sctp_retransmit_mark()
537 struct net *net = q->asoc->base.net; in sctp_retransmit()
546 if (transport == transport->asoc->peer.retran_path) in sctp_retransmit()
547 sctp_assoc_update_retran_path(transport->asoc); in sctp_retransmit()
548 transport->asoc->rtx_data_chunks += in sctp_retransmit()
549 transport->asoc->unack_data; in sctp_retransmit()
561 transport->asoc->init_retries++; in sctp_retransmit()
574 q->asoc->stream.si->generate_ftsn(q, q->asoc->ctsn_ack_point); in sctp_retransmit()
719 q->asoc->stats.rtxchunks++; in __sctp_outq_flush_rtx()
764 const struct sctp_association *asoc = transport->asoc; in sctp_packet_singleton() local
765 const __u16 sport = asoc->base.bind_addr.port; in sctp_packet_singleton()
766 const __u16 dport = asoc->peer.port; in sctp_packet_singleton()
767 const __u32 vtag = asoc->peer.i.init_tag; in sctp_packet_singleton()
783 struct sctp_association *asoc; member
810 new_transport = sctp_assoc_lookup_paddr(ctx->asoc, in sctp_outq_select_transport()
818 new_transport = ctx->asoc->peer.active_path; in sctp_outq_select_transport()
843 new_transport = ctx->asoc->peer.active_path; in sctp_outq_select_transport()
860 ctx->asoc->peer.i.init_tag, in sctp_outq_select_transport()
861 ctx->asoc->peer.ecn_capable); in sctp_outq_select_transport()
884 if (ctx->asoc->src_out_of_asoc_ok && in sctp_outq_flush_ctrl()
907 ctx->asoc->base.sk->sk_err = -error; in sctp_outq_flush_ctrl()
914 ctx->packet->vtag = ctx->asoc->c.my_vtag; in sctp_outq_flush_ctrl()
948 ctx->asoc->stats.octrlchunks++; in sctp_outq_flush_ctrl()
959 if (chunk == ctx->asoc->strreset_chunk) in sctp_outq_flush_ctrl()
977 if (ctx->asoc->peer.retran_path->state == SCTP_UNCONFIRMED) in sctp_outq_flush_rtx()
980 if (ctx->transport != ctx->asoc->peer.retran_path) { in sctp_outq_flush_rtx()
982 ctx->transport = ctx->asoc->peer.retran_path; in sctp_outq_flush_rtx()
989 sctp_packet_config(ctx->packet, ctx->asoc->peer.i.init_tag, in sctp_outq_flush_rtx()
990 ctx->asoc->peer.ecn_capable); in sctp_outq_flush_rtx()
996 ctx->asoc->base.sk->sk_err = -error; in sctp_outq_flush_rtx()
1025 switch (ctx->asoc->state) { in sctp_outq_flush_data()
1067 __u8 stream_state = SCTP_SO(&ctx->asoc->stream, sid)->state; in sctp_outq_flush_data()
1110 if (ctx->asoc->state == SCTP_STATE_SHUTDOWN_PENDING) in sctp_outq_flush_data()
1113 ctx->asoc->stats.ouodchunks++; in sctp_outq_flush_data()
1115 ctx->asoc->stats.oodchunks++; in sctp_outq_flush_data()
1149 ctx->q->asoc->base.sk->sk_err = -error; in sctp_outq_flush_transports()
1172 .asoc = q->asoc, in sctp_outq_flush()
1188 if (q->asoc->src_out_of_asoc_ok) in sctp_outq_flush()
1224 struct sctp_association *asoc = q->asoc; in sctp_outq_sack() local
1234 struct sctp_transport *primary = asoc->peer.primary_path; in sctp_outq_sack()
1240 transport_list = &asoc->peer.transport_addr_list; in sctp_outq_sack()
1245 trace_sctp_probe_path(transport, asoc); in sctp_outq_sack()
1250 asoc->stats.gapcnt += gap_ack_blocks; in sctp_outq_sack()
1293 if (TSN_lt(asoc->highest_sacked, highest_tsn)) in sctp_outq_sack()
1294 asoc->highest_sacked = highest_tsn; in sctp_outq_sack()
1322 if (TSN_lt(asoc->ctsn_ack_point, sack_ctsn)) { in sctp_outq_sack()
1323 asoc->ctsn_ack_point = sack_ctsn; in sctp_outq_sack()
1329 if (asoc->fast_recovery && accum_moved) in sctp_outq_sack()
1338 sctp_sack_update_unack_data(asoc, sack); in sctp_outq_sack()
1340 ctsn = asoc->ctsn_ack_point; in sctp_outq_sack()
1349 if (asoc->peer.prsctp_capable && in sctp_outq_sack()
1351 asoc->sent_cnt_removable--; in sctp_outq_sack()
1362 asoc->peer.zero_window_announced = !sack_a_rwnd; in sctp_outq_sack()
1370 asoc->peer.rwnd = sack_a_rwnd; in sctp_outq_sack()
1372 asoc->stream.si->generate_ftsn(q, sack_ctsn); in sctp_outq_sack()
1376 "advertised peer ack point:0x%x\n", __func__, asoc, ctsn, in sctp_outq_sack()
1377 asoc->adv_peer_ack_point); in sctp_outq_sack()
1492 q->asoc->peer.primary_path->cacc. in sctp_check_transmitted()
1576 struct sctp_association *asoc = transport->asoc; in sctp_check_transmitted() local
1594 transport->asoc->overall_error_count = 0; in sctp_check_transmitted()
1603 if (asoc->state == SCTP_STATE_SHUTDOWN_PENDING && in sctp_check_transmitted()
1604 del_timer(&asoc->timers in sctp_check_transmitted()
1606 sctp_association_put(asoc); in sctp_check_transmitted()
1615 transport->asoc, in sctp_check_transmitted()
1643 if (!q->asoc->peer.rwnd && in sctp_check_transmitted()
1645 (sack_ctsn+2 == q->asoc->next_tsn) && in sctp_check_transmitted()
1646 q->asoc->state < SCTP_STATE_SHUTDOWN_PENDING) { in sctp_check_transmitted()
1650 q->asoc->overall_error_count = 0; in sctp_check_transmitted()
1689 struct sctp_association *asoc = q->asoc; in sctp_mark_missing() local
1690 struct sctp_transport *primary = asoc->peer.primary_path; in sctp_mark_missing()
1795 struct sctp_association *asoc = q->asoc; in sctp_generate_fwdtsn() local
1804 if (!asoc->peer.prsctp_capable) in sctp_generate_fwdtsn()
1813 if (TSN_lt(asoc->adv_peer_ack_point, ctsn)) in sctp_generate_fwdtsn()
1814 asoc->adv_peer_ack_point = ctsn; in sctp_generate_fwdtsn()
1849 if (TSN_lte(tsn, asoc->adv_peer_ack_point+1)) { in sctp_generate_fwdtsn()
1850 asoc->adv_peer_ack_point = tsn; in sctp_generate_fwdtsn()
1888 if (asoc->adv_peer_ack_point > ctsn) in sctp_generate_fwdtsn()
1889 ftsn_chunk = sctp_make_fwdtsn(asoc, asoc->adv_peer_ack_point, in sctp_generate_fwdtsn()
1894 SCTP_INC_STATS(asoc->base.net, SCTP_MIB_OUTCTRLCHUNKS); in sctp_generate_fwdtsn()