Home
last modified time | relevance | path

Searched refs:nfr (Results 1 – 18 of 18) sorted by relevance

/xnu-12377.61.12/tests/skywalk/
H A Dskt_fswbinds.c49 struct nx_flow_req nfr; in skt_fswbind_common() local
60 memset(&nfr, 0, sizeof(nfr)); in skt_fswbind_common()
61 nfr.nfr_ip_protocol = IPPROTO_TCP; in skt_fswbind_common()
62 nfr.nfr_nx_port = nx_port1; in skt_fswbind_common()
63 nfr.nfr_saddr.sa.sa_len = sizeof(struct sockaddr_in); in skt_fswbind_common()
64 nfr.nfr_saddr.sa.sa_family = AF_INET; in skt_fswbind_common()
65 nfr.nfr_saddr.sin.sin_port = htons(0); in skt_fswbind_common()
66 nfr.nfr_saddr.sin.sin_addr.s_addr = htonl(INADDR_ANY); in skt_fswbind_common()
67 uuid_copy(nfr.nfr_flow_uuid, flow1); in skt_fswbind_common()
69 uuid_unparse(nfr.nfr_flow_uuid, uuidstr); in skt_fswbind_common()
[all …]
H A Dskt_flowswitch_ns_reserve.c126 struct nx_flow_req nfr; in skt_flowswitch_ns_bsd() local
194 memset(&nfr, 0, sizeof(nfr)); in skt_flowswitch_ns_bsd()
195 nfr.nfr_ip_protocol = proto; in skt_flowswitch_ns_bsd()
196 nfr.nfr_nx_port = NEXUS_PORT_FLOW_SWITCH_CLIENT; /* first usable */ in skt_flowswitch_ns_bsd()
197 memcpy(&nfr.nfr_saddr, &saddr, sizeof(nfr.nfr_saddr)); in skt_flowswitch_ns_bsd()
198 uuid_generate_random(nfr.nfr_flow_uuid); in skt_flowswitch_ns_bsd()
201 uuid_unparse_upper(nfr.nfr_flow_uuid, uuidstr); in skt_flowswitch_ns_bsd()
217 ntohs(nfr.nfr_saddr.sin.sin_port), uuidstr); in skt_flowswitch_ns_bsd()
219 handles->fsw_nx_uuid, &nfr); in skt_flowswitch_ns_bsd()
225 ntohs(nfr.nfr_saddr.sin.sin_port), uuidstr); in skt_flowswitch_ns_bsd()
[all …]
H A Dskt_listener.c98 struct nx_flow_req nfr; in skt_listener_cleanup() local
101 memset(&nfr, 0, sizeof(nfr)); in skt_listener_cleanup()
102 uuid_copy(nfr.nfr_flow_uuid, flow_id); in skt_listener_cleanup()
105 &nfr); in skt_listener_cleanup()
133 our_port = ntohs(listener->nfr.nfr_saddr.sin.sin_port); in skt_listener_main()
176 our_port = ntohs(listener->nfr.nfr_saddr.sin.sin_port); in skt_listener_main()
215 our_port = ntohs(connection_1->nfr.nfr_saddr.sin.sin_port); in skt_listener_main()
244 our_port = ntohs(listener->nfr.nfr_saddr.sin.sin_port); in skt_listener_main()
310 uint16_t our_port = ntohs(listener->nfr.nfr_saddr.sin.sin_port); in skt_listener_stress_main()
375 our_port = ntohs(listener->nfr.nfr_saddr.sin.sin_port); in skt_listener_reuse_main()
H A Dskywalk_test_utils.c694 struct nx_flow_req nfr; in sktc_bind_tcp4_flow() local
697 memset(&nfr, 0, sizeof(nfr)); in sktc_bind_tcp4_flow()
698 nfr.nfr_ip_protocol = IPPROTO_TCP; in sktc_bind_tcp4_flow()
699 nfr.nfr_nx_port = nx_port; in sktc_bind_tcp4_flow()
700 nfr.nfr_saddr.sa.sa_len = sizeof(struct sockaddr_in); in sktc_bind_tcp4_flow()
701 nfr.nfr_saddr.sa.sa_family = AF_INET; in sktc_bind_tcp4_flow()
702 nfr.nfr_saddr.sin.sin_port = htons(in_port); in sktc_bind_tcp4_flow()
703 nfr.nfr_saddr.sin.sin_addr.s_addr = htonl(INADDR_ANY); in sktc_bind_tcp4_flow()
704 uuid_copy(nfr.nfr_flow_uuid, flow); in sktc_bind_tcp4_flow()
709 uuid_unparse(nfr.nfr_flow_uuid, uuidstr); in sktc_bind_tcp4_flow()
[all …]
H A Dskt_filter.c448 struct nx_flow_req nfr; in custom_ether_setup_flow() local
454 bzero(&nfr, sizeof(nfr)); in custom_ether_setup_flow()
455 uuid_copy(nfr.nfr_flow_uuid, flow_uuid); in custom_ether_setup_flow()
456 nfr.nfr_nx_port = NEXUS_PORT_ANY; in custom_ether_setup_flow()
457 nfr.nfr_ethertype = args->ethertype; in custom_ether_setup_flow()
458 nfr.nfr_flags |= NXFLOWREQF_CUSTOM_ETHER; in custom_ether_setup_flow()
460 error = __os_nexus_flow_add(ncd, uuid, &nfr); in custom_ether_setup_flow()
463 uuid_unparse(nfr.nfr_bind_key, uuidstr); in custom_ether_setup_flow()
464 uuid_copy(bind_key, nfr.nfr_bind_key); in custom_ether_setup_flow()
465 *nx_port = nfr.nfr_nx_port; in custom_ether_setup_flow()
[all …]
H A Dskt_flowlookup.c105 sport = ntohs(flow->nfr.nfr_saddr.sin.sin_port); in test_tcp_flow_send()
149 sport = ntohs(flow->nfr.nfr_saddr.sin.sin_port); in test_tcp_flow_receive()
162 assert(uuid_compare(rx_frame->flow_uuid, flow->nfr.nfr_flow_uuid) == 0); in test_tcp_flow_receive()
197 assert(uuid_compare(rx_frame->flow_uuid, listener->nfr.nfr_flow_uuid) == 0); in test_tcp_flow_listen()
217 assert(uuid_compare(rx_frame->flow_uuid, connection->nfr.nfr_flow_uuid) == 0); in test_tcp_flow_listen()
251 assert(uuid_compare(rx_frame->flow_uuid, listener->nfr.nfr_flow_uuid) == 0); in test_tcp_flow_listen_v6()
272 assert(uuid_compare(rx_frame->flow_uuid, connection->nfr.nfr_flow_uuid) == 0); in test_tcp_flow_listen_v6()
358 assert(uuid_compare(rx_frame->flow_uuid, ip_listener->nfr.nfr_flow_uuid) == 0); in test_ip_flow_listen()
379 assert(uuid_compare(rx_frame->flow_uuid, ip_connection->nfr.nfr_flow_uuid) == 0); in test_ip_flow_listen()
H A Dskt_flow.c103 assert(regular_flow_0->nfr.nfr_nx_port == in skt_flow_req_low_latency()
104 regular_flow_1->nfr.nfr_nx_port); in skt_flow_req_low_latency()
114 assert(low_latency_flow_0->nfr.nfr_nx_port != in skt_flow_req_low_latency()
115 regular_flow_0->nfr.nfr_nx_port); in skt_flow_req_low_latency()
125 assert(low_latency_flow_0->nfr.nfr_nx_port == in skt_flow_req_low_latency()
126 low_latency_flow_1->nfr.nfr_nx_port); in skt_flow_req_low_latency()
H A Dskt_netifdirect.c134 struct nx_flow_req nfr; in skt_add_netif_ipv6_flow() local
137 bzero(&nfr, sizeof(nfr)); in skt_add_netif_ipv6_flow()
138 uuid_generate(nfr.nfr_flow_uuid); in skt_add_netif_ipv6_flow()
139 nfr.nfr_nx_port = NEXUS_PORT_ANY; in skt_add_netif_ipv6_flow()
140 nfr.nfr_flags |= flags; in skt_add_netif_ipv6_flow()
143 sin6 = &nfr.nfr_saddr.sin6; in skt_add_netif_ipv6_flow()
150 sin6 = &nfr.nfr_daddr.sin6; in skt_add_netif_ipv6_flow()
157 handles->netif_nx_uuid, &nfr); in skt_add_netif_ipv6_flow()
161 *nx_port = nfr.nfr_nx_port; in skt_add_netif_ipv6_flow()
H A Dskt_xfer.c279 struct nx_flow_req nfr; in connect_flow() local
282 memset(&nfr, 0, sizeof(nfr)); in connect_flow()
283 nfr.nfr_ip_protocol = protocol; in connect_flow()
284 nfr.nfr_nx_port = nx_port; in connect_flow()
285 uuid_copy(nfr.nfr_flow_uuid, flow); in connect_flow()
286 nfr.nfr_flags = flags; in connect_flow()
288 nfr.nfr_saddr.sa.sa_len = sizeof(struct sockaddr_in); in connect_flow()
289 nfr.nfr_saddr.sa.sa_family = AF_INET; in connect_flow()
290 nfr.nfr_saddr.sin.sin_port = htons(src_port); in connect_flow()
291 nfr.nfr_saddr.sin.sin_addr = src_addr; in connect_flow()
[all …]
H A Dskt_mangle.c117 sport = ntohs(ctx->flow->nfr.nfr_saddr.sin.sin_port); in skt_mangle_verify_internalize_metadata()
118 dport = ntohs(ctx->flow->nfr.nfr_daddr.sin.sin_port); in skt_mangle_verify_internalize_metadata()
129 uuid_copy(tx_frame->flow_uuid, ctx->flow->nfr.nfr_flow_uuid); in skt_mangle_verify_internalize_metadata()
H A Dskt_reass.c602 assert(flow_ipv4->nfr.nfr_nx_port == flow_ipv6->nfr.nfr_nx_port); in skt_reass_main()
605 flow_ipv4->nfr.nfr_nx_port, true, false, false); in skt_reass_main()
H A Dskywalk_test_utils.h202 struct nx_flow_req nfr; member
237 char * skt_nfr_print(struct nx_flow_req *nfr, char *buf, size_t buf_max);
/xnu-12377.61.12/bsd/skywalk/nexus/netif/
H A Dnx_netif_netagent.c146 flow_ipv6_ula_match(struct netif_agent_flow *naf, struct nx_flow_req *nfr) in flow_ipv6_ula_match() argument
150 if (naf->naf_pid != nfr->nfr_pid) { in flow_ipv6_ula_match()
152 pid_t, nfr->nfr_pid); in flow_ipv6_ula_match()
160 s2 = &nfr->nfr_saddr.sin6.sin6_addr; in flow_ipv6_ula_match()
167 d2 = &nfr->nfr_daddr.sin6.sin6_addr; in flow_ipv6_ula_match()
209 nx_netif_netagent_fill_port_info(struct nx_netif *nif, struct nx_flow_req *nfr, in nx_netif_netagent_fill_port_info() argument
219 if ((nfr->nfr_flags & (NXFLOWREQF_CUSTOM_ETHER | in nx_netif_netagent_fill_port_info()
229 if ((nfr->nfr_flags & NXFLOWREQF_CUSTOM_ETHER) != 0) { in nx_netif_netagent_fill_port_info()
230 if ((err = validate_ethertype(nfr->nfr_ethertype)) != 0) { in nx_netif_netagent_fill_port_info()
234 fd->fd_ethertype = nfr->nfr_ethertype; in nx_netif_netagent_fill_port_info()
[all …]
H A Dnx_netif.c785 struct nx_flow_req nfr; in nx_netif_prov_config() local
787 bzero(&nfr, sizeof(nfr)); in nx_netif_prov_config()
788 err = sooptcopyin(&sopt, &nfr, sizeof(nfr), sizeof(nfr)); in nx_netif_prov_config()
793 err = nx_netif_ctl(nx, ncr->nc_cmd, &nfr, p); in nx_netif_prov_config()
799 (void) sooptcopyout(&sopt, &nfr, sizeof(nfr)); in nx_netif_prov_config()
1638 struct nx_flow_req *__single nfr = data; in nx_netif_ctl() local
1653 error = nx_netif_ctl_flow_add(nif, p, nfr); in nx_netif_ctl()
1657 error = nx_netif_ctl_flow_del(nif, p, nfr); in nx_netif_ctl()
/xnu-12377.61.12/libsyscall/wrappers/skywalk/
H A Dos_nexus.c484 const struct nx_flow_req *nfr) in __os_nexus_flow_add() argument
489 nfr, sizeof(*nfr)); in __os_nexus_flow_add()
497 const struct nx_flow_req *nfr) in __os_nexus_flow_del() argument
502 nfr, sizeof(*nfr)); in __os_nexus_flow_del()
509 __os_nexus_config_flow(const uuid_t nx_uuid, struct nx_flow_req *nfr) in __os_nexus_config_flow() argument
514 nfr, sizeof(*nfr)); in __os_nexus_config_flow()
524 struct nx_flow_req nfr = {0}; in os_nexus_flow_set_wake_from_sleep() local
525 memcpy(nfr.nfr_flow_uuid, flow_uuid, sizeof(uuid_t)); in os_nexus_flow_set_wake_from_sleep()
526 nfr.nfr_flags = enable ? 0 : NXFLOWREQF_NOWAKEFROMSLEEP; in os_nexus_flow_set_wake_from_sleep()
528 return __os_nexus_config_flow(nx_uuid, &nfr); in os_nexus_flow_set_wake_from_sleep()
[all …]
/xnu-12377.61.12/bsd/skywalk/nexus/flowswitch/
H A Dnx_flowswitch.c518 struct nx_flow_req nfr; in nx_fsw_prov_config() local
519 bzero(&nfr, sizeof(nfr)); in nx_fsw_prov_config()
520 err = sooptcopyin(&sopt, &nfr, sizeof(nfr), sizeof(nfr)); in nx_fsw_prov_config()
525 err = fsw_ctl(nx, ncr->nc_cmd, p, &nfr); in nx_fsw_prov_config()
530 err = sooptcopyout(&sopt, &nfr, sizeof(nfr)); in nx_fsw_prov_config()
/xnu-12377.61.12/bsd/netinet/
H A Dtcp_subr.c5600 struct nx_flow_req nfr; in tcp_add_fsw_flow() local
5612 memset(&nfr, 0, sizeof(nfr)); in tcp_add_fsw_flow()
5619 nfr.nfr_saddr.sin.sin_len = sizeof(struct sockaddr_in); in tcp_add_fsw_flow()
5620 nfr.nfr_saddr.sin.sin_family = AF_INET; in tcp_add_fsw_flow()
5621 nfr.nfr_saddr.sin.sin_port = inp->inp_lport; in tcp_add_fsw_flow()
5622 memcpy(&nfr.nfr_saddr.sin.sin_addr, &inp->inp_laddr, in tcp_add_fsw_flow()
5624 nfr.nfr_daddr.sin.sin_len = sizeof(struct sockaddr_in); in tcp_add_fsw_flow()
5625 nfr.nfr_daddr.sin.sin_family = AF_INET; in tcp_add_fsw_flow()
5626 nfr.nfr_daddr.sin.sin_port = inp->inp_fport; in tcp_add_fsw_flow()
5627 memcpy(&nfr.nfr_daddr.sin.sin_addr, &inp->inp_faddr, in tcp_add_fsw_flow()
[all …]
/xnu-12377.61.12/bsd/skywalk/nexus/
H A Dos_nexus_private.h689 const uuid_t nx_uuid, const struct nx_flow_req *nfr);
691 const uuid_t nx_uuid, const struct nx_flow_req *nfr);