Home
last modified time | relevance | path

Searched refs:flow (Results 1 – 25 of 30) sorted by relevance

12

/xnu-11215/tests/skywalk/
H A Dskt_flow.c57 struct sktu_flow *flow; in skt_flow_add_del() local
59 flow = sktu_create_nexus_flow(&handles, af, src, dst, protocol, sport, dport); in skt_flow_add_del()
62 assert(flow); in skt_flow_add_del()
63 sktu_destroy_nexus_flow(flow); in skt_flow_add_del()
65 assert(!flow); in skt_flow_add_del()
174 struct sktu_flow *flow; in skt_flow_config_main() local
176 assert(flow); in skt_flow_config_main()
180 int ret = sktu_get_nexus_flow_stats(flow->uuid, &sf); in skt_flow_config_main()
187 } while (uuid_compare(rand_uuid, flow->uuid) == 0); in skt_flow_config_main()
216 ret = sktu_get_nexus_flow_stats(flow->uuid, &sf); in skt_flow_config_main()
[all …]
H A Dskywalk_test_utils.c2618 flow->src_ip, flow->dport, flow->sport, data, data_len, flow->mtu, in _sktu_create_udp_flow_input_frames()
2630 flow->dst_ip, flow->sport, flow->dport, data, data_len, flow->mtu, in _sktu_create_udp_flow_output_frames()
2641 flow->src_ip, flow->dport, flow->sport, data, data_len, flow->mtu, in _sktu_create_tcp_flow_input_frames()
2653 flow->dst_ip, flow->sport, flow->dport, data, data_len, flow->mtu, in _sktu_create_tcp_flow_output_frames()
2664 flow->ip_protocol, data, data_len, flow->mtu, 0, 0, 0); in _sktu_create_ip_flow_input_frames()
2675 flow->ip_protocol, data, data_len, flow->mtu, 0, 0, 0); in _sktu_create_ip_flow_output_frames()
2721 struct sktu_flow *flow = malloc(sizeof(*flow)); in _sktu_create_nexus_flow() local
2723 memset(flow, 0, sizeof(*flow)); in _sktu_create_nexus_flow()
2766 free(flow); in _sktu_create_nexus_flow()
2803 return flow; in _sktu_create_nexus_flow()
[all …]
H A Dskt_restricted_port.c65 uuid_t flow; in skt_reserve_restricted_port() local
68 uuid_generate_random(flow); in skt_reserve_restricted_port()
70 0, NEXUS_PORT_FLOW_SWITCH_CLIENT, flow); in skt_reserve_restricted_port()
73 uuid_clear(flow); in skt_reserve_restricted_port()
H A Dskt_mpprotons.c59 struct sktu_flow *flow; in skt_flow_req_should_succeed() local
61 flow = sktu_create_nexus_flow(&handles, af, src, dst, protocol, sport, dport); in skt_flow_req_should_succeed()
62 assert(flow); in skt_flow_req_should_succeed()
69 struct sktu_flow *flow; in skt_flow_req_should_fail() local
71 flow = sktu_create_nexus_flow(&handles, af, src, dst, protocol, sport, dport); in skt_flow_req_should_fail()
72 assert(!flow); in skt_flow_req_should_fail()
H A Dskt_flowlookup.c100 struct sktu_flow *flow; in test_tcp_flow_send() local
104 …flow = sktu_create_nexus_flow_with_nx_port(&handles, NX_PORT, AF_INET, &our_ip, &dst_ip, IPPROTO_T… in test_tcp_flow_send()
105 sport = ntohs(flow->nfr.nfr_saddr.sin.sin_port); in test_tcp_flow_send()
110 flow->create_output_frames(flow, &tx_frame, 1, &tx_payload, sizeof(tx_payload), NO_CSUM_OFFLOAD); in test_tcp_flow_send()
137 sktu_destroy_nexus_flow(flow); in test_tcp_flow_send()
143 struct sktu_flow *flow; in test_tcp_flow_receive() local
148 …flow = sktu_create_nexus_flow_with_nx_port(&handles, NX_PORT, AF_INET, &our_ip, &dst_ip, IPPROTO_T… in test_tcp_flow_receive()
149 sport = ntohs(flow->nfr.nfr_saddr.sin.sin_port); in test_tcp_flow_receive()
154 flow->create_input_frames(flow, &tx_frame, 1, &tx_payload, sizeof(tx_payload)); in test_tcp_flow_receive()
162 assert(uuid_compare(rx_frame->flow_uuid, flow->nfr.nfr_flow_uuid) == 0); in test_tcp_flow_receive()
[all …]
H A Dskt_mangle.c71 struct sktu_flow *flow; member
117 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()
430 ctx.flow = sktu_create_nexus_flow(&ctx.handles, AF_INET, &ctx.our_ip, in skt_mangle_verify_internalize_metadata_main()
440 sktu_destroy_nexus_flow(ctx.flow); in skt_mangle_verify_internalize_metadata_main()
H A Dskywalk_test_utils.h178 size_t (*create_input_frames)(struct sktu_flow *flow,
182 size_t (*create_output_frames)(struct sktu_flow *flow,
236 …us_controller_t ncd, const uuid_t fsw, in_port_t in_port, nexus_port_t nx_port, const uuid_t flow);
237 int sktc_unbind_flow(nexus_controller_t ncd, const uuid_t fsw, const uuid_t flow);
252 void _sktu_destroy_nexus_flow(struct sktu_flow *flow);
H A Dskt_flowswitch_ns_reserve.c370 ErrorFlags error_flags, uuid_t flow, uint16_t *bound_port) in skt_ns_sky_bind() argument
398 uuid_generate_random(flow); in skt_ns_sky_bind()
403 uuid_copy(nfr.nfr_flow_uuid, flow); in skt_ns_sky_bind()
489 uuid_t flow; in skt_flowswitch_ns_sky_bsd() local
494 flow, &bound_port); in skt_flowswitch_ns_sky_bsd()
511 flow, &bound_port); in skt_flowswitch_ns_sky_bsd()
516 uuid_copy(nfr.nfr_flow_uuid, flow); in skt_flowswitch_ns_sky_bsd()
536 uuid_t flow; in skt_flowswitch_ns_check_v4mappedv6addr() local
593 uuid_copy(nfr.nfr_flow_uuid, flow); in skt_flowswitch_ns_check_v4mappedv6addr()
615 uuid_t flow; in skt_flowswitch_ns_check_v4mappedv6addr2() local
[all …]
H A Dskt_reass.c210 reass_common(channel_port *ch_port, struct sktu_flow *flow, void *data, in reass_common() argument
218 n_tx_frames = flow->create_input_frames(flow, tx_frames, MAX_FRAMES, in reass_common()
H A Dskt_xfer.c273 const uuid_t fsw, nexus_port_t nx_port, const uuid_t flow, in connect_flow() argument
285 uuid_copy(nfr.nfr_flow_uuid, flow); in connect_flow()
316 const uuid_t fsw, nexus_port_t nx_port, const uuid_t flow, in connect_child_flow() argument
329 uuid_copy(nfr.nfr_flow_uuid, flow); in connect_child_flow()
/xnu-11215/security/
H A Dmac_skywalk.c36 mac_skywalk_flow_check_connect(__unused proc_t proc, void *flow, const struct sockaddr *addr, int t… in mac_skywalk_flow_check_connect() argument
41 MAC_CHECK(skywalk_flow_check_connect, kauth_cred_get(), flow, addr, type, protocol); in mac_skywalk_flow_check_connect()
46 mac_skywalk_flow_check_listen(__unused proc_t proc, void *flow, const struct sockaddr *addr, int ty… in mac_skywalk_flow_check_listen() argument
51 MAC_CHECK(skywalk_flow_check_listen, kauth_cred_get(), flow, addr, type, protocol); in mac_skywalk_flow_check_listen()
H A Dmac_framework.h592 int mac_skywalk_flow_check_connect(proc_t p, void *flow, const struct sockaddr *addr, int type,…
593 int mac_skywalk_flow_check_listen(proc_t p, void *flow, const struct sockaddr *addr, int type, …
H A Dmac_policy.h2716 void *flow,
2738 void *flow,
/xnu-11215/bsd/net/
H A Dnecp_client.c2090 if (!flow->nexus && !flow->socket && flow->interface_index == interface_index) { in necp_client_add_interface_flow_if_needed()
2250 if (flow->viable && flow->u.cb) { in necp_flow_add_interface_flows()
2261 if (flow->viable && flow->u.cb) { in necp_flow_add_interface_flows()
2313 …if (flow->viable && client_updated && (flow->socket || (!flow->socket && !flow->nexus)) && flow->u… in necp_client_update_flows()
2315 …flow->u.cb(flow->u.socket_handle, NECP_CLIENT_CBACTION_VIABLE, flow->interface_index, flow->necp_f… in necp_client_update_flows()
2319 if (!flow->viable || flow->invalid) { in necp_client_update_flows()
2320 if (client_updated && (flow->socket || (!flow->socket && !flow->nexus)) && flow->u.cb) { in necp_client_update_flows()
2332 if (flow->invalid && flow->nexus && flow->assigned && !uuid_is_null(flow->u.nexus_agent)) { in necp_client_update_flows()
2347 if (!flow->viable || flow->invalid) { in necp_client_update_flows()
2349 if (!flow->nexus && !flow->assigned) { in necp_client_update_flows()
[all …]
/xnu-11215/bsd/skywalk/nexus/flowswitch/flow/
H A Dflow_var.h779 struct __flow *flow = pkt->pkt_flow; in flow_pkt2key() local
790 key->fk_proto = flow->flow_ip_proto; in flow_pkt2key()
793 key->fk_src4 = flow->flow_ipv4_dst; in flow_pkt2key()
794 key->fk_sport = flow->flow_tcp_dst; in flow_pkt2key()
795 key->fk_dst4 = flow->flow_ipv4_src; in flow_pkt2key()
796 key->fk_dport = flow->flow_tcp_src; in flow_pkt2key()
798 key->fk_src6 = flow->flow_ipv6_dst; in flow_pkt2key()
799 key->fk_sport = flow->flow_tcp_dst; in flow_pkt2key()
800 key->fk_dst6 = flow->flow_ipv6_src; in flow_pkt2key()
801 key->fk_dport = flow->flow_tcp_src; in flow_pkt2key()
[all …]
/xnu-11215/bsd/net/classq/
H A Dclassq.c307 _getq_flow(class_queue_t *q, classq_pkt_t *pkt, u_int32_t flow) in _getq_flow() argument
309 return _getq_flow_or_scidx(q, pkt, flow, TRUE); in _getq_flow()
586 _flushq_flow_mbuf(class_queue_t *q, u_int32_t flow, u_int32_t *cnt, in _flushq_flow_mbuf() argument
596 if (flow == 0 || ((m->m_flags & M_PKTHDR) && in _flushq_flow_mbuf()
597 m->m_pkthdr.pkt_flowid == flow)) { in _flushq_flow_mbuf()
637 _flushq_flow_kpkt(class_queue_t *q, u_int32_t flow, u_int32_t *cnt, in _flushq_flow_kpkt() argument
647 if (flow == 0 || p->pkt_flow_token == flow) { in _flushq_flow_kpkt()
687 _flushq_flow(class_queue_t *q, u_int32_t flow, u_int32_t *cnt, u_int32_t *len) in _flushq_flow() argument
691 _flushq_flow_mbuf(q, flow, cnt, len); in _flushq_flow()
696 _flushq_flow_kpkt(q, flow, cnt, len); in _flushq_flow()
H A Dif_classq.h53 u_int32_t flow; /* (in) 0 means all flows */ member
/xnu-11215/bsd/conf/
H A Dfiles577 bsd/skywalk/nexus/flowswitch/flow/flow.c optional config_nexus_flowswitch bound-checks
578 bsd/skywalk/nexus/flowswitch/flow/flow_classifier.c optional config_nexus_flowswitch bound-checks
579 bsd/skywalk/nexus/flowswitch/flow/flow_entry.c optional config_nexus_flowswitch bound-checks
580 bsd/skywalk/nexus/flowswitch/flow/flow_manager.c optional config_nexus_flowswitch bound-checks
581 bsd/skywalk/nexus/flowswitch/flow/flow_namespace.c optional config_nexus_flowswitch bound-checks
582 bsd/skywalk/nexus/flowswitch/flow/flow_owner.c optional config_nexus_flowswitch bound-checks
583 bsd/skywalk/nexus/flowswitch/flow/flow_route.c optional config_nexus_flowswitch bound-checks
584 bsd/skywalk/nexus/flowswitch/flow/flow_stats.c optional config_nexus_flowswitch bound-checks
585 bsd/skywalk/nexus/flowswitch/flow/flow_track.c optional config_nexus_flowswitch bound-checks
586 bsd/skywalk/nexus/flowswitch/flow/flow_agg.c optional config_nexus_flowswitch bound-checks
/xnu-11215/bsd/netinet/
H A Dmptcp_subr.c6082 tcp_getconninfo(so, &flow->flow_ci); in fill_mptcp_subflow()
6085 flow->flow_src.ss_family = AF_INET6; in fill_mptcp_subflow()
6086 flow->flow_dst.ss_family = AF_INET6; in fill_mptcp_subflow()
6094 flow->flow_src.ss_family = AF_INET; in fill_mptcp_subflow()
6095 flow->flow_dst.ss_family = AF_INET; in fill_mptcp_subflow()
6098 SIN(&flow->flow_src)->sin_port = inp->inp_lport; in fill_mptcp_subflow()
6103 flow->flow_len = sizeof(*flow); in fill_mptcp_subflow()
6105 flow->flow_flags = mpts->mpts_flags; in fill_mptcp_subflow()
6106 flow->flow_cid = mpts->mpts_connid; in fill_mptcp_subflow()
6107 flow->flow_relseq = mpts->mpts_rel_seq; in fill_mptcp_subflow()
[all …]
/xnu-11215/bsd/skywalk/nexus/flowswitch/
H A Dfsw_dp.c839 struct __flow *flow = pkt->pkt_flow; in pkt_is_for_listener() local
844 if (flow->flow_ip_ver == IPVERSION) { in pkt_is_for_listener()
845 if (IN_ZERONET(ntohl(flow->flow_ipv4_dst.s_addr)) || in pkt_is_for_listener()
846 IN_LOOPBACK(ntohl(flow->flow_ipv4_dst.s_addr)) || in pkt_is_for_listener()
847 IN_LINKLOCAL(ntohl(flow->flow_ipv4_dst.s_addr)) || in pkt_is_for_listener()
848 IN_DS_LITE(ntohl(flow->flow_ipv4_dst.s_addr)) || in pkt_is_for_listener()
850 IN_MULTICAST(ntohl(flow->flow_ipv4_dst.s_addr)) || in pkt_is_for_listener()
851 INADDR_BROADCAST == flow->flow_ipv4_dst.s_addr) { in pkt_is_for_listener()
920 if (IN6_IS_ADDR_LOOPBACK(&flow->flow_ipv6_dst) || in pkt_is_for_listener()
921 IN6_IS_ADDR_LINKLOCAL(&flow->flow_ipv6_dst) || in pkt_is_for_listener()
[all …]
/xnu-11215/doc/allocators/
H A Dread-only.md20 control of kernel execution, advances in control flow integrity defenses, such
/xnu-11215/bsd/skywalk/packet/
H A Dpbufpool.c555 struct __flow *__single flow; in pp_metadata_construct() local
561 flow = skmem_cache_alloc(pp_flow_cache, SKMEM_SLEEP); in pp_metadata_construct()
571 flow = kpkt->pkt_flow; in pp_metadata_construct()
584 KPKT_CTOR(kpkt, pflags, opt, flow, compl, midx, in pp_metadata_construct()
/xnu-11215/osfmk/mach/
H A Dtask.defs616 * entitlement is disallowed, and you must use this hardened exception flow.
/xnu-11215/doc/primitives/
H A Datomics.md289 Any control flow that attempts to exit its scope of the loop needs to be
/xnu-11215/doc/debugging/
H A Ddebugging.md363 Clearly an external library is involved and execution flow jumps between dSYM and the library few t…

12