234 flow_divert_pcb_insert(struct flow_divert_pcb *fd_cb, uint32_t ctl_unit)  in flow_divert_pcb_insert()  argument
243 	if (ctl_unit == 0 || ctl_unit >= GROUP_COUNT_MAX) {  in flow_divert_pcb_insert()
256 	group = g_flow_divert_groups[ctl_unit];  in flow_divert_pcb_insert()
258 …il_pcb, "Group for control unit %u is NULL, flow divert cannot be used for this socket", ctl_unit);  in flow_divert_pcb_insert()
354 …FDLOG(LOG_INFO, fd_cb, "Removing from group %d, ref count = %d", group->ctl_unit, fd_cb->ref_count…  in flow_divert_pcb_remove()
518 flow_divert_packet_verify_hmac(mbuf_t packet, uint32_t ctl_unit)  in flow_divert_packet_verify_hmac()  argument
530 		group = g_flow_divert_groups[ctl_unit];  in flow_divert_packet_verify_hmac()
1155 		error = ctl_enqueuembuf(g_flow_divert_kctl_ref, fd_cb->group->ctl_unit, packet, CTL_DATA_EOR);  in flow_divert_send_packet()
1888 flow_divert_derive_kernel_control_unit(uint32_t ctl_unit, uint32_t *aggregate_unit, bool *is_aggreg…  in flow_divert_derive_kernel_control_unit()  argument
1903 			return ctl_unit;  in flow_divert_derive_kernel_control_unit()
1906 		return ctl_unit;  in flow_divert_derive_kernel_control_unit()
2263 	uint32_t                                        ctl_unit                        = 0;  in flow_divert_handle_connect_result()  local
2290 …divert_packet_get_tlv(packet, offset, FLOW_DIVERT_TLV_CTL_UNIT, sizeof(ctl_unit), &ctl_unit, NULL);  in flow_divert_handle_connect_result()
2316 	ctl_unit                = ntohl(ctl_unit);  in flow_divert_handle_connect_result()
2320 	if (connect_error == 0 && ctl_unit > 0) {  in flow_divert_handle_connect_result()
2321 		if (ctl_unit >= GROUP_COUNT_MAX) {  in flow_divert_handle_connect_result()
2322 			FDLOG(LOG_ERR, fd_cb, "Connect result contains an invalid control unit: %u", ctl_unit);  in flow_divert_handle_connect_result()
2328 			grp = g_flow_divert_groups[ctl_unit];  in flow_divert_handle_connect_result()
2432 …panic("group with unit %u already contains a connection with hash %u", grp->ctl_unit, fd_cb->hash);  in flow_divert_handle_connect_result()
3043 …r an unknown pcb: %u", flow_divert_packet_type2str(hdr.packet_type), group->ctl_unit, hdr.conn_id);  in flow_divert_input()
3809 flow_divert_pcb_init_internal(struct socket *so, uint32_t ctl_unit, uint32_t aggregate_unit)  in flow_divert_pcb_init_internal()  argument
3815 	uint32_t group_unit = flow_divert_derive_kernel_control_unit(ctl_unit, &agg_unit, &is_aggregate);  in flow_divert_pcb_init_internal()
3830 		fd_cb->policy_control_unit = ctl_unit;  in flow_divert_pcb_init_internal()
3865 	uint32_t ctl_unit = necp_socket_get_flow_divert_control_unit(inp, &aggregate_units);  in flow_divert_pcb_init()  local
3866 	return flow_divert_pcb_init_internal(so, ctl_unit, aggregate_units);  in flow_divert_pcb_init()
3872 	uint32_t ctl_unit = 0;  in flow_divert_token_set()  local
3930 …vert_packet_get_tlv(token, 0, FLOW_DIVERT_TLV_CTL_UNIT, sizeof(ctl_unit), (void *)&ctl_unit, NULL);  in flow_divert_token_set()
3943 	ctl_unit = ntohl(ctl_unit);  in flow_divert_token_set()
3946 	if (ctl_unit > 0 && ctl_unit < GROUP_COUNT_MAX) {  in flow_divert_token_set()
3948 		hmac_error = flow_divert_packet_verify_hmac(token, (key_unit != 0 ? key_unit : ctl_unit));  in flow_divert_token_set()
3958 	error = flow_divert_pcb_init_internal(so, ctl_unit, aggregate_unit);  in flow_divert_token_set()
3993 	uint32_t                                        ctl_unit;  in flow_divert_token_get()  local
4018 	ctl_unit = htonl(fd_cb->group->ctl_unit);  in flow_divert_token_get()
4020 …error = flow_divert_packet_append_tlv(token, FLOW_DIVERT_TLV_CTL_UNIT, sizeof(ctl_unit), &ctl_unit…  in flow_divert_token_get()
4047 		ctl_unit = htonl(control_group->ctl_unit);  in flow_divert_token_get()
4048 …rror = flow_divert_packet_append_tlv(token, FLOW_DIVERT_TLV_KEY_UNIT, sizeof(ctl_unit), &ctl_unit);  in flow_divert_token_get()
4105 	new_group->ctl_unit = sac->sc_unit;  in flow_divert_kctl_connect()
4225 			int error = ctl_enqueuembuf(g_flow_divert_kctl_ref, group->ctl_unit, next_packet, CTL_DATA_EOR);  in flow_divert_kctl_rcvd()