sys/netinet/sctp_cc_functions.c

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