240 flow_divert_group_lookup(uint32_t ctl_unit, struct flow_divert_pcb *fd_cb)  in flow_divert_group_lookup()  argument
248 	} else if (ctl_unit == 0 || ctl_unit >= GROUP_COUNT_MAX) {  in flow_divert_group_lookup()
249 		FDLOG(LOG_ERR, fd_cb, "Cannot lookup group with invalid control unit (%u)", ctl_unit);  in flow_divert_group_lookup()
251 		group = g_flow_divert_groups[ctl_unit];  in flow_divert_group_lookup()
254 … fd_cb, "Group for control unit %u is NULL, flow divert cannot be used for this socket", ctl_unit);  in flow_divert_group_lookup()
272 			fd_cb->control_group_unit = group->ctl_unit;  in flow_divert_pcb_insert()
275 …FDLOG(LOG_ERR, fd_cb, "Group %u already contains a PCB with hash %u", group->ctl_unit, fd_cb->hash…  in flow_divert_pcb_insert()
279 		FDLOG(LOG_ERR, fd_cb, "Group %u is defunct, cannot insert", group->ctl_unit);  in flow_divert_pcb_insert()
287 flow_divert_add_to_group(struct flow_divert_pcb *fd_cb, uint32_t ctl_unit)  in flow_divert_add_to_group()  argument
295 	group = flow_divert_group_lookup(ctl_unit, fd_cb);  in flow_divert_add_to_group()
315 			if (idx == ctl_unit) {  in flow_divert_add_to_group()
385 …FDLOG(LOG_INFO, fd_cb, "Removing from group %d, ref count = %d", group->ctl_unit, fd_cb->ref_count…  in flow_divert_pcb_remove()
549 flow_divert_packet_verify_hmac(mbuf_t packet, uint32_t ctl_unit)  in flow_divert_packet_verify_hmac()  argument
558 	group = flow_divert_group_lookup(ctl_unit, NULL);  in flow_divert_packet_verify_hmac()
560 		FDLOG(LOG_ERR, &nil_pcb, "Failed to lookup group for control unit %u", ctl_unit);  in flow_divert_packet_verify_hmac()
1183 		error = ctl_enqueuembuf(g_flow_divert_kctl_ref, fd_cb->group->ctl_unit, packet, CTL_DATA_EOR);  in flow_divert_send_packet()
1926 flow_divert_derive_kernel_control_unit(uint32_t *ctl_unit, uint32_t *aggregate_unit, bool *is_aggre…  in flow_divert_derive_kernel_control_unit()  argument
1928 	uint32_t result = *ctl_unit;  in flow_divert_derive_kernel_control_unit()
1943 			*ctl_unit = 0;  in flow_divert_derive_kernel_control_unit()
1947 		*ctl_unit = 0;  in flow_divert_derive_kernel_control_unit()
2285 	uint32_t                                        ctl_unit                        = 0;  in flow_divert_handle_connect_result()  local
2311 …divert_packet_get_tlv(packet, offset, FLOW_DIVERT_TLV_CTL_UNIT, sizeof(ctl_unit), &ctl_unit, NULL);  in flow_divert_handle_connect_result()
2426 		ctl_unit = ntohl(ctl_unit);  in flow_divert_handle_connect_result()
2427 		if (ctl_unit > 0) {  in flow_divert_handle_connect_result()
2431 			if (ctl_unit >= GROUP_COUNT_MAX) {  in flow_divert_handle_connect_result()
2432 				FDLOG(LOG_ERR, fd_cb, "Connect result contains an invalid control unit: %u", ctl_unit);  in flow_divert_handle_connect_result()
2437 			grp = flow_divert_group_lookup(ctl_unit, fd_cb);  in flow_divert_handle_connect_result()
2765 		FDLOG(LOG_ERR, &nil_pcb, "Skipping (re)initialization of defunct group %u", group->ctl_unit);  in flow_divert_handle_group_init()
3059 …r an unknown pcb: %u", flow_divert_packet_type2str(hdr.packet_type), group->ctl_unit, hdr.conn_id);  in flow_divert_input()
3866 flow_divert_pcb_init_internal(struct socket *so, uint32_t ctl_unit, uint32_t aggregate_unit)  in flow_divert_pcb_init_internal()  argument
3871 	uint32_t policy_control_unit = ctl_unit;  in flow_divert_pcb_init_internal()
3896 			fd_cb->policy_control_unit = ctl_unit;  in flow_divert_pcb_init_internal()
3928 	uint32_t ctl_unit = necp_socket_get_flow_divert_control_unit(inp, &aggregate_units);  in flow_divert_pcb_init()  local
3929 	return flow_divert_pcb_init_internal(so, ctl_unit, aggregate_units);  in flow_divert_pcb_init()
3935 	uint32_t ctl_unit = 0;  in flow_divert_token_set()  local
3993 …vert_packet_get_tlv(token, 0, FLOW_DIVERT_TLV_CTL_UNIT, sizeof(ctl_unit), (void *)&ctl_unit, NULL);  in flow_divert_token_set()
4006 	ctl_unit = ntohl(ctl_unit);  in flow_divert_token_set()
4009 	if (ctl_unit > 0 && ctl_unit < GROUP_COUNT_MAX) {  in flow_divert_token_set()
4010 		hmac_error = flow_divert_packet_verify_hmac(token, (key_unit != 0 ? key_unit : ctl_unit));  in flow_divert_token_set()
4018 	error = flow_divert_pcb_init_internal(so, ctl_unit, aggregate_unit);  in flow_divert_token_set()
4053 	uint32_t                                        ctl_unit;  in flow_divert_token_get()  local
4076 	ctl_unit = htonl(fd_cb->group->ctl_unit);  in flow_divert_token_get()
4078 …error = flow_divert_packet_append_tlv(token, FLOW_DIVERT_TLV_CTL_UNIT, sizeof(ctl_unit), &ctl_unit…  in flow_divert_token_get()
4098 		ctl_unit = htonl(control_group->ctl_unit);  in flow_divert_token_get()
4099 …rror = flow_divert_packet_append_tlv(token, FLOW_DIVERT_TLV_KEY_UNIT, sizeof(ctl_unit), &ctl_unit);  in flow_divert_token_get()
4143 	FDLOG(LOG_NOTICE, &nil_pcb, "Destroying group %u", group->ctl_unit);  in flow_divert_group_destroy()
4180 	new_group->ctl_unit = sac->sc_unit;  in flow_divert_kctl_connect()
4292 			int error = ctl_enqueuembuf(g_flow_divert_kctl_ref, group->ctl_unit, next_packet, CTL_DATA_EOR);  in flow_divert_kctl_rcvd()