Home
last modified time | relevance | path

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

/xnu-8020.101.4/bsd/skywalk/nexus/flowswitch/flow/
H A Dflow_entry.c171 struct flow_entry find, *fe = NULL; in flow_entry_find_by_uuid() local
175 fe = RB_FIND(flow_entry_id_tree, &fo->fo_flow_entry_id_head, &find); in flow_entry_find_by_uuid()
176 if (fe != NULL) { in flow_entry_find_by_uuid()
177 flow_entry_retain(fe); in flow_entry_find_by_uuid()
180 return fe; in flow_entry_find_by_uuid()
189 struct flow_entry *fe = NULL; in flow_entry_alloc() local
209 fe = flow_mgr_find_conflicting_fe(fm, &key); in flow_entry_alloc()
210 if (fe != NULL) { in flow_entry_alloc()
212 "flags 0x%b %s(%d)", fe_as_string(fe, in flow_entry_alloc()
213 dbgbuf, sizeof(dbgbuf)), SK_KVA(fe), fe->fe_flags, in flow_entry_alloc()
[all …]
H A Dflow_track.c95 flow_track_tcp_init(struct flow_entry *fe, struct flow_track *src, in flow_track_tcp_init() argument
134 fe->fe_linger_wait = (2 * tcp_msl) / TCP_RETRANSHZ; in flow_track_tcp_init()
135 if (fe->fe_linger_wait < FLOWTRACK_LINGER_MIN) { in flow_track_tcp_init()
136 fe->fe_linger_wait = FLOWTRACK_LINGER_MIN; in flow_track_tcp_init()
137 } else if (fe->fe_linger_wait > FLOWTRACK_LINGER_MAX) { in flow_track_tcp_init()
138 fe->fe_linger_wait = FLOWTRACK_LINGER_MAX; in flow_track_tcp_init()
141 atomic_bitset_32(&fe->fe_flags, FLOWENTF_INITED); in flow_track_tcp_init()
159 flow_track_tcp_rtt(struct flow_entry *fe, boolean_t input, in flow_track_tcp_rtt() argument
163 #pragma unused(fe, input) /* KDBG defined as noop in release build */ in flow_track_tcp_rtt()
183 SK_KVA(fe), fe->fe_pid, ntohs(fe->fe_key.fk_sport), in flow_track_tcp_rtt()
[all …]
H A Dflow_manager.c96 struct flow_entry *fe = container_of(node, struct flow_entry, fe_cnode); in __fe_cuckoo_cmp() local
129 return flow_key_cmp(&fe->fe_key, key); in __fe_cuckoo_cmp()
132 return flow_key_cmp_mask(&fe->fe_key, key, mask); in __fe_cuckoo_cmp()
138 struct flow_entry *fe = container_of(node, struct flow_entry, fe_cnode); in __fe_cuckoo_retain() local
139 return flow_entry_retain(fe); in __fe_cuckoo_retain()
146 struct flow_entry *fe = container_of(node, struct flow_entry, fe_cnode); in __fe_cuckoo_release() local
147 flow_entry_release(&fe); in __fe_cuckoo_release()
916 struct flow_entry *fe; in flow_mgr_flow_add() local
939 fe = flow_entry_alloc(fo, req, &err); in flow_mgr_flow_add()
940 if (__improbable(fe == NULL)) { in flow_mgr_flow_add()
[all …]
H A Dflow_owner.c147 struct flow_entry *fe, *tfe; in flow_owner_bucket_purge_common() local
161 RB_FOREACH_SAFE(fe, flow_entry_id_tree, in flow_owner_bucket_purge_common()
163 ASSERT(fe->fe_nx_port == fo->fo_nx_port); in flow_owner_bucket_purge_common()
164 flow_entry_retain(fe); in flow_owner_bucket_purge_common()
165 flow_entry_destroy(fo, fe, FALSE, NULL); in flow_owner_bucket_purge_common()
201 struct flow_entry *fe; in flow_owner_bucket_activate_nx_port_common() local
217 RB_FOREACH(fe, flow_entry_id_tree, in flow_owner_bucket_activate_nx_port_common()
219 if (fe->fe_flags & FLOWENTF_TORN_DOWN) { in flow_owner_bucket_activate_nx_port_common()
222 VERIFY(fe->fe_nx_port == fo->fo_nx_port); in flow_owner_bucket_activate_nx_port_common()
223 if (fe->fe_adv_idx != FLOWADV_IDX_NONE) { in flow_owner_bucket_activate_nx_port_common()
[all …]
H A Dflow_agg.c1388 _estimate_buflet_cnt(struct flow_entry *fe, struct kern_pbufpool *pp) in _estimate_buflet_cnt() argument
1393 cnt = howmany(((fe->fe_rx_pktq_bytes + sizeof(struct ip6_hdr)) + in _estimate_buflet_cnt()
1395 cnt = MAX(KPKTQ_LEN(&fe->fe_rx_pktq), cnt); in _estimate_buflet_cnt()
1431 flow_rx_agg_channel(struct nx_flowswitch *fsw, struct flow_entry *fe, in flow_rx_agg_channel() argument
1444 ring = fsw_flow_get_rx_ring(fsw, fe); in flow_rx_agg_channel()
1447 KPKTQ_CONCAT(dropped_pkts, &fe->fe_rx_pktq); in flow_rx_agg_channel()
1473 SK_DF(logflags, "Rx input queue len %u", KPKTQ_LEN(&fe->fe_rx_pktq)); in flow_rx_agg_channel()
1475 bh_cnt_tmp = bh_cnt = _estimate_buflet_cnt(fe, dpp); in flow_rx_agg_channel()
1481 bool is_ipv4 = (fe->fe_key.fk_ipver == IPVERSION); in flow_rx_agg_channel()
1482 KPKTQ_FOREACH_SAFE(pkt, &fe->fe_rx_pktq, tpkt) { in flow_rx_agg_channel()
[all …]
H A Dflow_var.h230 typedef void (*flow_action_t)(struct nx_flowswitch *fsw, struct flow_entry *fe);
920 void (^flow_handler)(struct flow_entry *fe));
929 extern void flow_entry_retain(struct flow_entry *fe);
931 extern uint32_t flow_entry_refcnt(struct flow_entry *fe);
949 extern void flow_rx_agg_tcp(struct nx_flowswitch *fsw, struct flow_entry *fe);
988 extern char *fe_as_string(const struct flow_entry *fe, char *, size_t);
/xnu-8020.101.4/libkern/libkern/coreanalytics/
H A Dcoreanalytics_internal.h55 #define _f1(fe, e, fo, x, ...) fo(x) argument
56 #define _f2(fe, e, fo, x, ...) fe(x) e _f1(fe, e, fo, __VA_ARGS__) argument
57 #define _f3(fe, e, fo, x, ...) fo(x) e _f2(fe, e, fo, __VA_ARGS__) argument
58 #define _f4(fe, e, fo, x, ...) fe(x) e _f3(fe, e, fo, __VA_ARGS__) argument
59 #define _f5(fe, e, fo, x, ...) fo(x) e _f4(fe, e, fo, __VA_ARGS__) argument
60 #define _f6(fe, e, fo, x, ...) fe(x) e _f5(fe, e, fo, __VA_ARGS__) argument
61 #define _f7(fe, e, fo, x, ...) fo(x) e _f6(fe, e, fo, __VA_ARGS__) argument
62 #define _f8(fe, e, fo, x, ...) fe(x) e _f7(fe, e, fo, __VA_ARGS__) argument
63 #define _f9(fe, e, fo, x, ...) fo(x) e _f8(fe, e, fo, __VA_ARGS__) argument
64 #define _f10(fe, e, fo, x, ...) fe(x) e _f9(fe, e, fo, __VA_ARGS__) argument
[all …]
/xnu-8020.101.4/bsd/skywalk/nexus/flowswitch/
H A Dfsw_dp.c304 fsw_snoop(struct nx_flowswitch *fsw, struct flow_entry *fe, bool input) in fsw_snoop() argument
316 ASSERT(fe != NULL); in fsw_snoop()
319 if (fe->fe_nx_port == FSW_VP_HOST) { in fsw_snoop()
321 tap_early = (input && fe->fe_key.fk_proto == IPPROTO_TCP); in fsw_snoop()
327 if (fe->fe_key.fk_ipver == IPVERSION) { in fsw_snoop()
329 } else if (fe->fe_key.fk_ipver == IPV6_VERSION) { in fsw_snoop()
335 pid = fe->fe_pid; in fsw_snoop()
336 if (fe->fe_proc_name[0] != '\0') { in fsw_snoop()
337 (void) strlcpy(proc_name_buf, fe->fe_proc_name, in fsw_snoop()
341 epid = fe->fe_epid; in fsw_snoop()
[all …]
H A Dfsw_var.h158 extern void fsw_snoop(struct nx_flowswitch *fsw, struct flow_entry *fe,
162 struct flow_entry *fe);
164 struct flow_entry *fe);
175 extern void fsw_flow_abort_tcp(struct nx_flowswitch *fsw, struct flow_entry *fe,
177 extern void fsw_flow_abort_quic(struct flow_entry *fe, uint8_t *token);
179 struct flow_entry *fe);
181 struct flow_entry *fe);
201 extern void fsw_qos_mark(struct nx_flowswitch *fsw, struct flow_entry *fe,
223 fsw_snoop_and_dequeue(struct flow_entry *fe, struct pktq *target, bool input) in fsw_snoop_and_dequeue() argument
226 fsw_snoop(fe->fe_fsw, fe, input); in fsw_snoop_and_dequeue()
[all …]
H A Dfsw_qos.c92 fsw_qos_mark(struct nx_flowswitch *fsw, struct flow_entry *fe, in fsw_qos_mark() argument
98 ASSERT(KPKT_VALID_SVC(fe->fe_svc_class)); in fsw_qos_mark()
102 pkt->pkt_svc_class = fe->fe_svc_class; in fsw_qos_mark()
113 if ((fe->fe_flags & FLOWENTF_QOS_MARKING) == 0) { in fsw_qos_mark()
H A Dfsw_flow.c257 struct flow_entry *fe; in fsw_flow_add() local
258 if ((fe = flow_entry_find_by_uuid(fo, req.nfr_flow_uuid)) != NULL) { in fsw_flow_add()
263 fe_as_string(fe, dbgbuf, sizeof(dbgbuf)), SK_KVA(fe), in fsw_flow_add()
264 fe->fe_flags, FLOWENTF_BITS, fe->fe_proc_name, fe->fe_pid); in fsw_flow_add()
267 flow_entry_release(&fe); in fsw_flow_add()
H A Dfsw.c1045 struct flow_entry *fe = NULL; in fsw_protoctl_event_callback() local
1089 fe = flow_mgr_find_fe_by_key(fsw->fsw_flow_mgr, &fk); in fsw_protoctl_event_callback()
1090 if (__improbable(fe == NULL)) { in fsw_protoctl_event_callback()
1094 uuid_copy(fe_uuid, fe->fe_uuid); in fsw_protoctl_event_callback()
1117 fe_as_string(fe, dbgbuf, sizeof(dbgbuf)), in fsw_protoctl_event_callback()
1133 if (fe != NULL) { in fsw_protoctl_event_callback()
1134 flow_entry_release(&fe); in fsw_protoctl_event_callback()
1560 struct flow_entry *fe; in fsw_mib_get_flow() local
1565 fe = flow_mgr_get_fe_by_uuid_rlock(fm, filter->nmf_flow_id); in fsw_mib_get_flow()
1566 if (fe != NULL) { in fsw_mib_get_flow()
[all …]
/xnu-8020.101.4/tools/lldbmacros/
H A Dskywalk.py698 def FlowEntryStr(fe): argument
699 return "(struct flow_entry*){} {} ".format(hex(fe), FlowKeyStr(fe.fe_key))
701 def GetFlowEntryPid(fe): argument
702 return fe.fe_pid
710 fe = containerof(node, 'struct flow_entry', 'fe_cnode')
711 flows.append(fe)
745 for fe in flows:
746 print(" {}".format(FlowEntryStr(fe)))
/xnu-8020.101.4/libsyscall/wrappers/skywalk/
H A Dos_channel.c1222 _flowadv_id_equal(struct __flowadv_entry *fe, uuid_t id) in _flowadv_id_equal() argument
1230 return fe->fae_id_64[0] == id_64[0] && in _flowadv_id_equal()
1231 fe->fae_id_64[1] == id_64[1]; in _flowadv_id_equal()
1234 return fe->fae_id_32[0] == id_32[0] && in _flowadv_id_equal()
1235 fe->fae_id_32[1] == id_32[1] && in _flowadv_id_equal()
1236 fe->fae_id_32[2] == id_32[2] && in _flowadv_id_equal()
1237 fe->fae_id_32[3] == id_32[3]; in _flowadv_id_equal()
1240 return UUID_COMPARE(fe->fae_id, id); in _flowadv_id_equal()
1249 struct __flowadv_entry *fe = CHD_NX_FLOWADV(chd); in os_channel_flow_admissible() local
1270 fe = &CHD_NX_FLOWADV(chd)[flow_index]; in os_channel_flow_admissible()
[all …]
/xnu-8020.101.4/bsd/net/
H A Dif_ports_used.h206 bool if_ports_used_add_flow_entry(const struct flow_entry *fe, const uint32_t ifindex,
H A Dif_ports_used.c791 if_ports_used_add_flow_entry(const struct flow_entry *fe, const uint32_t ifindex, in if_ports_used_add_flow_entry() argument
878 uuid_copy(npi.npi_effective_uuid, fe->fe_eproc_uuid); in if_ports_used_add_flow_entry()
/xnu-8020.101.4/bsd/skywalk/
H A Dos_stats_private.h1225 #define FLOW_STATS_IN_ADD(fe, stat, cnt) { \ argument
1227 fst = &(fe)->fe_stats->fs_rtrack; \
1231 #define FLOW_STATS_OUT_ADD(fe, stat, cnt) { \ argument
1233 fst = &(fe)->fe_stats->fs_ltrack; \
/xnu-8020.101.4/bsd/skywalk/namespace/
H A Dnetns.c1790 netns_local_port_scan_flow_entry(struct flow_entry *fe, protocol_family_t protocol, in netns_local_port_scan_flow_entry() argument
1793 struct ns_token *token = fe->fe_port_reservation; in netns_local_port_scan_flow_entry()
1796 if (fe == NULL || token == NULL) { in netns_local_port_scan_flow_entry()
1864 (void) if_ports_used_add_flow_entry(fe, token->nt_ifp->if_index, in netns_local_port_scan_flow_entry()