74 sctp_set_initial_cc_param(struct sctp_tcb *stcb, struct sctp_nets *net)  in sctp_set_initial_cc_param()  argument
79 	assoc = &stcb->asoc;  in sctp_set_initial_cc_param()
93 	if ((stcb->asoc.sctp_cmt_on_off == SCTP_CMT_RPV1) ||  in sctp_set_initial_cc_param()
94 	    (stcb->asoc.sctp_cmt_on_off == SCTP_CMT_RPV2)) {  in sctp_set_initial_cc_param()
104 	    stcb->asoc.my_vtag, ((stcb->sctp_ep->sctp_lport << 16) | (stcb->rport)), net,  in sctp_set_initial_cc_param()
108 		sctp_log_cwnd(stcb, net, 0, SCTP_CWND_INITIALIZATION);  in sctp_set_initial_cc_param()
113 sctp_cwnd_update_after_fr(struct sctp_tcb *stcb,  in sctp_cwnd_update_after_fr()  argument
202 				    stcb->asoc.my_vtag, ((stcb->sctp_ep->sctp_lport << 16) | (stcb->rport)), net,  in sctp_cwnd_update_after_fr()
205 					sctp_log_cwnd(stcb, net, (net->cwnd - old_cwnd),  in sctp_cwnd_update_after_fr()
234 				    stcb->sctp_ep, stcb, net,  in sctp_cwnd_update_after_fr()
237 				    stcb->sctp_ep, stcb, net);  in sctp_cwnd_update_after_fr()
255 cc_bw_same(struct sctp_tcb *stcb, struct sctp_nets *net, uint64_t nbw,  in cc_bw_same()  argument
390 cc_bw_decrease(struct sctp_tcb *stcb, struct sctp_nets *net, uint64_t nbw, uint64_t rtt_offset,  in cc_bw_decrease()  argument
449 				sctp_enforce_cwnd_limit(&stcb->asoc, net);  in cc_bw_decrease()
481 				sctp_enforce_cwnd_limit(&stcb->asoc, net);  in cc_bw_decrease()
513 			sctp_enforce_cwnd_limit(&stcb->asoc, net);  in cc_bw_decrease()
531 cc_bw_increase(struct sctp_tcb *stcb, struct sctp_nets *net, uint64_t nbw, uint64_t vtag)  in cc_bw_increase()  argument
574 cc_bw_limit(struct sctp_tcb *stcb, struct sctp_nets *net, uint64_t nbw)  in cc_bw_limit()  argument
622 	rtt = stcb->asoc.my_vtag;  in cc_bw_limit()
623 	vtag = (rtt << 32) | (((uint32_t)(stcb->sctp_ep->sctp_lport)) << 16) | (stcb->rport);  in cc_bw_limit()
666 		ret = cc_bw_increase(stcb, net, nbw, vtag);  in cc_bw_limit()
671 		ret = cc_bw_decrease(stcb, net, nbw, rtt_offset, vtag, inst_ind);  in cc_bw_limit()
678 	ret = cc_bw_same(stcb, net, nbw, rtt_offset, vtag, inst_ind);  in cc_bw_limit()
685 sctp_cwnd_update_after_sack_common(struct sctp_tcb *stcb,  in sctp_cwnd_update_after_sack_common()  argument
703 	if ((stcb->asoc.sctp_cmt_on_off == SCTP_CMT_RPV1) ||  in sctp_cwnd_update_after_sack_common()
704 	    (stcb->asoc.sctp_cmt_on_off == SCTP_CMT_RPV2) ||  in sctp_cwnd_update_after_sack_common()
705 	    (stcb->asoc.sctp_cmt_on_off == SCTP_CMT_MPTCP)) {  in sctp_cwnd_update_after_sack_common()
707 		TAILQ_FOREACH(net, &stcb->asoc.nets, sctp_next) {  in sctp_cwnd_update_after_sack_common()
754 				sctp_log_cwnd(stcb, net, 0, SCTP_CWND_LOG_FROM_SACK);  in sctp_cwnd_update_after_sack_common()
798 				if (cc_bw_limit(stcb, net, nbw)) {  in sctp_cwnd_update_after_sack_common()
808 				    (((uint32_t)(stcb->sctp_ep->sctp_lport)) << 16) |  in sctp_cwnd_update_after_sack_common()
809 				    (stcb->rport);  in sctp_cwnd_update_after_sack_common()
907 						sctp_log_cwnd(stcb, net, incr,  in sctp_cwnd_update_after_sack_common()
911 					    stcb->asoc.my_vtag,  in sctp_cwnd_update_after_sack_common()
912 					    ((stcb->sctp_ep->sctp_lport << 16) | (stcb->rport)),  in sctp_cwnd_update_after_sack_common()
917 						sctp_log_cwnd(stcb, net, net->net_ack,  in sctp_cwnd_update_after_sack_common()
974 					    stcb->asoc.my_vtag,  in sctp_cwnd_update_after_sack_common()
975 					    ((stcb->sctp_ep->sctp_lport << 16) | (stcb->rport)),  in sctp_cwnd_update_after_sack_common()
979 						sctp_log_cwnd(stcb, net, net->mtu,  in sctp_cwnd_update_after_sack_common()
984 						sctp_log_cwnd(stcb, net, net->net_ack,  in sctp_cwnd_update_after_sack_common()
991 				sctp_log_cwnd(stcb, net, net->mtu,  in sctp_cwnd_update_after_sack_common()
999 sctp_cwnd_update_exit_pf_common(struct sctp_tcb *stcb, struct sctp_nets *net)  in sctp_cwnd_update_exit_pf_common()  argument
1006 	    stcb->asoc.my_vtag, ((stcb->sctp_ep->sctp_lport << 16) | (stcb->rport)), net,  in sctp_cwnd_update_exit_pf_common()
1013 sctp_cwnd_update_after_timeout(struct sctp_tcb *stcb, struct sctp_nets *net)  in sctp_cwnd_update_after_timeout()  argument
1022 	if ((stcb->asoc.sctp_cmt_on_off == SCTP_CMT_RPV1) ||  in sctp_cwnd_update_after_timeout()
1023 	    (stcb->asoc.sctp_cmt_on_off == SCTP_CMT_RPV2)) {  in sctp_cwnd_update_after_timeout()
1028 		TAILQ_FOREACH(lnet, &stcb->asoc.nets, sctp_next) {  in sctp_cwnd_update_after_timeout()
1043 		if (stcb->asoc.sctp_cmt_on_off == SCTP_CMT_RPV1) {  in sctp_cwnd_update_after_timeout()
1076 	    stcb->asoc.my_vtag,  in sctp_cwnd_update_after_timeout()
1077 	    ((stcb->sctp_ep->sctp_lport << 16) | (stcb->rport)),  in sctp_cwnd_update_after_timeout()
1081 		sctp_log_cwnd(stcb, net, net->cwnd - old_cwnd, SCTP_CWND_LOG_FROM_RTX);  in sctp_cwnd_update_after_timeout()
1086 sctp_cwnd_update_after_ecn_echo_common(struct sctp_tcb *stcb, struct sctp_nets *net,  in sctp_cwnd_update_after_ecn_echo_common()  argument
1108 				sctp_log_cwnd(stcb, net, (net->cwnd - old_cwnd), SCTP_CWND_LOG_FROM_SAT);  in sctp_cwnd_update_after_ecn_echo_common()
1118 				sctp_log_cwnd(stcb, net, (net->cwnd - old_cwnd), SCTP_CWND_LOG_FROM_SAT);  in sctp_cwnd_update_after_ecn_echo_common()
1136 			    stcb->asoc.my_vtag,  in sctp_cwnd_update_after_ecn_echo_common()
1137 			    ((stcb->sctp_ep->sctp_lport << 16) | (stcb->rport)),  in sctp_cwnd_update_after_ecn_echo_common()
1141 				sctp_log_cwnd(stcb, net, (net->cwnd - old_cwnd), SCTP_CWND_LOG_FROM_SAT);  in sctp_cwnd_update_after_ecn_echo_common()
1149 sctp_cwnd_update_after_packet_dropped(struct sctp_tcb *stcb,  in sctp_cwnd_update_after_packet_dropped()  argument
1191 		if (stcb->asoc.seen_a_sack_this_pkt) {  in sctp_cwnd_update_after_packet_dropped()
1237 		if ((stcb->asoc.max_burst > 0) &&  in sctp_cwnd_update_after_packet_dropped()
1238 		    (stcb->asoc.max_burst * net->mtu < incr)) {  in sctp_cwnd_update_after_packet_dropped()
1239 			incr = stcb->asoc.max_burst * net->mtu;  in sctp_cwnd_update_after_packet_dropped()
1251 	sctp_enforce_cwnd_limit(&stcb->asoc, net);  in sctp_cwnd_update_after_packet_dropped()
1255 		    stcb->asoc.my_vtag,  in sctp_cwnd_update_after_packet_dropped()
1256 		    ((stcb->sctp_ep->sctp_lport << 16) | (stcb->rport)),  in sctp_cwnd_update_after_packet_dropped()
1260 			sctp_log_cwnd(stcb, net, (net->cwnd - old_cwnd),  in sctp_cwnd_update_after_packet_dropped()
1267 sctp_cwnd_update_after_output(struct sctp_tcb *stcb,  in sctp_cwnd_update_after_output()  argument
1276 		sctp_enforce_cwnd_limit(&stcb->asoc, net);  in sctp_cwnd_update_after_output()
1278 		    stcb->asoc.my_vtag,  in sctp_cwnd_update_after_output()
1279 		    ((stcb->sctp_ep->sctp_lport << 16) | (stcb->rport)),  in sctp_cwnd_update_after_output()
1283 			sctp_log_cwnd(stcb, net, (net->cwnd - old_cwnd), SCTP_CWND_LOG_FROM_BRST);  in sctp_cwnd_update_after_output()
1289 sctp_cwnd_update_after_sack(struct sctp_tcb *stcb,  in sctp_cwnd_update_after_sack()  argument
1294 	sctp_cwnd_update_after_sack_common(stcb, asoc, accum_moved, reneged_all, will_exit, 0);  in sctp_cwnd_update_after_sack()
1298 sctp_cwnd_update_after_ecn_echo(struct sctp_tcb *stcb, struct sctp_nets *net,  in sctp_cwnd_update_after_ecn_echo()  argument
1302 	sctp_cwnd_update_after_ecn_echo_common(stcb, net, in_window, num_pkt_lost, 0);  in sctp_cwnd_update_after_ecn_echo()
1311 sctp_cwnd_update_rtcc_after_ecn_echo(struct sctp_tcb *stcb, struct sctp_nets *net,  in sctp_cwnd_update_rtcc_after_ecn_echo()  argument
1314 	sctp_cwnd_update_after_ecn_echo_common(stcb, net, in_window, num_pkt_lost, 1);  in sctp_cwnd_update_rtcc_after_ecn_echo()
1325 sctp_cwnd_prepare_rtcc_net_for_sack(struct sctp_tcb *stcb SCTP_UNUSED,  in sctp_cwnd_prepare_rtcc_net_for_sack()
1339 sctp_cwnd_new_rtcc_transmission_begins(struct sctp_tcb *stcb,  in sctp_cwnd_new_rtcc_transmission_begins()  argument
1346 		vtag = (net->rtt << 32) | (((uint32_t)(stcb->sctp_ep->sctp_lport)) << 16) |  in sctp_cwnd_new_rtcc_transmission_begins()
1347 		    (stcb->rport);  in sctp_cwnd_new_rtcc_transmission_begins()
1386 				if ((stcb->asoc.max_burst > 0) && (cwnd_in_mtu > stcb->asoc.max_burst))  in sctp_cwnd_new_rtcc_transmission_begins()
1387 					cwnd_in_mtu = stcb->asoc.max_burst;  in sctp_cwnd_new_rtcc_transmission_begins()
1402 sctp_set_rtcc_initial_cc_param(struct sctp_tcb *stcb,  in sctp_set_rtcc_initial_cc_param()  argument
1407 	sctp_set_initial_cc_param(stcb, net);  in sctp_set_rtcc_initial_cc_param()
1408 	stcb->asoc.use_precise_time = 1;  in sctp_set_rtcc_initial_cc_param()
1412 	    (((uint32_t)(stcb->sctp_ep->sctp_lport)) << 16) |  in sctp_set_rtcc_initial_cc_param()
1413 	    (stcb->rport);  in sctp_set_rtcc_initial_cc_param()
1437 sctp_cwnd_rtcc_socket_option(struct sctp_tcb *stcb, int setorget,  in sctp_cwnd_rtcc_socket_option()  argument
1449 			TAILQ_FOREACH(net, &stcb->asoc.nets, sctp_next) {  in sctp_cwnd_rtcc_socket_option()
1457 			TAILQ_FOREACH(net, &stcb->asoc.nets, sctp_next) {  in sctp_cwnd_rtcc_socket_option()
1461 			TAILQ_FOREACH(net, &stcb->asoc.nets, sctp_next) {  in sctp_cwnd_rtcc_socket_option()
1470 			net = TAILQ_FIRST(&stcb->asoc.nets);  in sctp_cwnd_rtcc_socket_option()
1476 			net = TAILQ_FIRST(&stcb->asoc.nets);  in sctp_cwnd_rtcc_socket_option()
1482 			net = TAILQ_FIRST(&stcb->asoc.nets);  in sctp_cwnd_rtcc_socket_option()
1495 sctp_cwnd_update_rtcc_packet_transmitted(struct sctp_tcb *stcb SCTP_UNUSED,  in sctp_cwnd_update_rtcc_packet_transmitted()
1505 sctp_cwnd_update_rtcc_after_sack(struct sctp_tcb *stcb,  in sctp_cwnd_update_rtcc_after_sack()  argument
1510 	sctp_cwnd_update_after_sack_common(stcb, asoc, accum_moved, reneged_all, will_exit, 1);  in sctp_cwnd_update_rtcc_after_sack()
1514 sctp_rtt_rtcc_calculated(struct sctp_tcb *stcb SCTP_UNUSED,  in sctp_rtt_rtcc_calculated()
1608 sctp_hs_cwnd_increase(struct sctp_tcb *stcb, struct sctp_nets *net)  in sctp_hs_cwnd_increase()  argument
1634 	sctp_enforce_cwnd_limit(&stcb->asoc, net);  in sctp_hs_cwnd_increase()
1636 		sctp_log_cwnd(stcb, net, (net->cwnd - old_cwnd), SCTP_CWND_LOG_FROM_SS);  in sctp_hs_cwnd_increase()
1641 sctp_hs_cwnd_decrease(struct sctp_tcb *stcb, struct sctp_nets *net)  in sctp_hs_cwnd_decrease()  argument
1675 	sctp_enforce_cwnd_limit(&stcb->asoc, net);  in sctp_hs_cwnd_decrease()
1677 		sctp_log_cwnd(stcb, net, (net->cwnd - old_cwnd), SCTP_CWND_LOG_FROM_FR);  in sctp_hs_cwnd_decrease()
1682 sctp_hs_cwnd_update_after_fr(struct sctp_tcb *stcb,  in sctp_hs_cwnd_update_after_fr()  argument
1704 				sctp_hs_cwnd_decrease(stcb, net);  in sctp_hs_cwnd_update_after_fr()
1732 				    stcb->sctp_ep, stcb, net,  in sctp_hs_cwnd_update_after_fr()
1735 				    stcb->sctp_ep, stcb, net);  in sctp_hs_cwnd_update_after_fr()
1748 sctp_hs_cwnd_update_after_sack(struct sctp_tcb *stcb,  in sctp_hs_cwnd_update_after_sack()  argument
1772 				sctp_log_cwnd(stcb, net, 0, SCTP_CWND_LOG_FROM_SACK);  in sctp_hs_cwnd_update_after_sack()
1807 					sctp_hs_cwnd_increase(stcb, net);  in sctp_hs_cwnd_update_after_sack()
1810 						sctp_log_cwnd(stcb, net, net->net_ack,  in sctp_hs_cwnd_update_after_sack()
1823 						sctp_log_cwnd(stcb, net, net->mtu,  in sctp_hs_cwnd_update_after_sack()
1828 						sctp_log_cwnd(stcb, net, net->net_ack,  in sctp_hs_cwnd_update_after_sack()
1835 				sctp_log_cwnd(stcb, net, net->mtu,  in sctp_hs_cwnd_update_after_sack()
1883 htcp_cwnd_undo(struct sctp_tcb *stcb, struct sctp_nets *net)  in htcp_cwnd_undo()  argument
2039 htcp_cong_avoid(struct sctp_tcb *stcb, struct sctp_nets *net)  in htcp_cong_avoid()  argument
2052 					sctp_log_cwnd(stcb, net, net->mtu,  in htcp_cong_avoid()
2059 					sctp_log_cwnd(stcb, net, net->net_ack,  in htcp_cong_avoid()
2063 			sctp_enforce_cwnd_limit(&stcb->asoc, net);  in htcp_cong_avoid()
2066 				sctp_log_cwnd(stcb, net, net->net_ack,  in htcp_cong_avoid()
2085 			sctp_enforce_cwnd_limit(&stcb->asoc, net);  in htcp_cong_avoid()
2088 				sctp_log_cwnd(stcb, net, net->mtu,  in htcp_cong_avoid()
2094 				sctp_log_cwnd(stcb, net, net->net_ack,  in htcp_cong_avoid()
2106 htcp_min_cwnd(struct sctp_tcb *stcb, struct sctp_nets *net)  in htcp_min_cwnd()  argument
2123 sctp_htcp_set_initial_cc_param(struct sctp_tcb *stcb, struct sctp_nets *net)  in sctp_htcp_set_initial_cc_param()  argument
2130 	net->ssthresh = stcb->asoc.peers_rwnd;  in sctp_htcp_set_initial_cc_param()
2131 	sctp_enforce_cwnd_limit(&stcb->asoc, net);  in sctp_htcp_set_initial_cc_param()
2135 		sctp_log_cwnd(stcb, net, 0, SCTP_CWND_INITIALIZATION);  in sctp_htcp_set_initial_cc_param()
2140 sctp_htcp_cwnd_update_after_sack(struct sctp_tcb *stcb,  in sctp_htcp_cwnd_update_after_sack()  argument
2164 				sctp_log_cwnd(stcb, net, 0, SCTP_CWND_LOG_FROM_SACK);  in sctp_htcp_cwnd_update_after_sack()
2195 			htcp_cong_avoid(stcb, net);  in sctp_htcp_cwnd_update_after_sack()
2199 				sctp_log_cwnd(stcb, net, net->mtu,  in sctp_htcp_cwnd_update_after_sack()
2207 sctp_htcp_cwnd_update_after_fr(struct sctp_tcb *stcb,  in sctp_htcp_cwnd_update_after_fr()  argument
2236 					sctp_log_cwnd(stcb, net, (net->cwnd - old_cwnd),  in sctp_htcp_cwnd_update_after_fr()
2265 				    stcb->sctp_ep, stcb, net,  in sctp_htcp_cwnd_update_after_fr()
2268 				    stcb->sctp_ep, stcb, net);  in sctp_htcp_cwnd_update_after_fr()
2281 sctp_htcp_cwnd_update_after_timeout(struct sctp_tcb *stcb,  in sctp_htcp_cwnd_update_after_timeout()  argument
2292 		sctp_log_cwnd(stcb, net, net->cwnd - old_cwnd, SCTP_CWND_LOG_FROM_RTX);  in sctp_htcp_cwnd_update_after_timeout()
2297 sctp_htcp_cwnd_update_after_ecn_echo(struct sctp_tcb *stcb,  in sctp_htcp_cwnd_update_after_ecn_echo()  argument
2315 		sctp_enforce_cwnd_limit(&stcb->asoc, net);  in sctp_htcp_cwnd_update_after_ecn_echo()
2317 			sctp_log_cwnd(stcb, net, (net->cwnd - old_cwnd), SCTP_CWND_LOG_FROM_SAT);  in sctp_htcp_cwnd_update_after_ecn_echo()