Home
last modified time | relevance | path

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

/xnu-11215.61.5/libkern/libkern/coreanalytics/
H A Dcoreanalytics_internal.h58 #define _f1(fe, e, fo, x, ...) fo(x) argument
59 #define _f2(fe, e, fo, x, ...) fe(x) e _f1(fe, e, fo, __VA_ARGS__) argument
60 #define _f3(fe, e, fo, x, ...) fo(x) e _f2(fe, e, fo, __VA_ARGS__) argument
61 #define _f4(fe, e, fo, x, ...) fe(x) e _f3(fe, e, fo, __VA_ARGS__) argument
62 #define _f5(fe, e, fo, x, ...) fo(x) e _f4(fe, e, fo, __VA_ARGS__) argument
63 #define _f6(fe, e, fo, x, ...) fe(x) e _f5(fe, e, fo, __VA_ARGS__) argument
64 #define _f7(fe, e, fo, x, ...) fo(x) e _f6(fe, e, fo, __VA_ARGS__) argument
65 #define _f8(fe, e, fo, x, ...) fe(x) e _f7(fe, e, fo, __VA_ARGS__) argument
66 #define _f9(fe, e, fo, x, ...) fo(x) e _f8(fe, e, fo, __VA_ARGS__) argument
67 #define _f10(fe, e, fo, x, ...) fe(x) e _f9(fe, e, fo, __VA_ARGS__) argument
[all …]
/xnu-11215.61.5/bsd/skywalk/nexus/flowswitch/flow/
H A Dflow_entry.c172 struct flow_entry find, *fe = NULL; in flow_entry_find_by_uuid() local
176 fe = RB_FIND(flow_entry_id_tree, &fo->fo_flow_entry_id_head, &find); in flow_entry_find_by_uuid()
177 if (fe != NULL) { in flow_entry_find_by_uuid()
178 flow_entry_retain(fe); in flow_entry_find_by_uuid()
181 return fe; in flow_entry_find_by_uuid()
185 flow_entry_calc_flowid(struct flow_entry *fe) in flow_entry_calc_flowid() argument
191 _CASSERT(sizeof(fe->fe_key.fk_src) == sizeof(fk.ffk_laddr)); in flow_entry_calc_flowid()
192 _CASSERT(sizeof(fe->fe_key.fk_dst) == sizeof(fk.ffk_raddr)); in flow_entry_calc_flowid()
193 bcopy(&fe->fe_key.fk_src, &fk.ffk_laddr, sizeof(fk.ffk_laddr)); in flow_entry_calc_flowid()
194 bcopy(&fe->fe_key.fk_dst, &fk.ffk_raddr, sizeof(fk.ffk_raddr)); in flow_entry_calc_flowid()
[all …]
H A Dflow_track.c97 flow_track_tcp_init(struct flow_entry *fe, struct flow_track *src, in flow_track_tcp_init() argument
136 fe->fe_linger_wait = (2 * tcp_msl) / TCP_RETRANSHZ; in flow_track_tcp_init()
137 if (fe->fe_linger_wait < FLOWTRACK_LINGER_MIN) { in flow_track_tcp_init()
138 fe->fe_linger_wait = FLOWTRACK_LINGER_MIN; in flow_track_tcp_init()
139 } else if (fe->fe_linger_wait > FLOWTRACK_LINGER_MAX) { in flow_track_tcp_init()
140 fe->fe_linger_wait = FLOWTRACK_LINGER_MAX; in flow_track_tcp_init()
143 os_atomic_or(&fe->fe_flags, FLOWENTF_INITED, relaxed); in flow_track_tcp_init()
161 flow_track_tcp_rtt(struct flow_entry *fe, boolean_t input, in flow_track_tcp_rtt() argument
165 #pragma unused(fe, input) /* KDBG defined as noop in release build */ in flow_track_tcp_rtt()
185 SK_KVA(fe), fe->fe_pid, ntohs(fe->fe_key.fk_sport), in flow_track_tcp_rtt()
[all …]
H A Dflow_manager.c87 struct flow_entry *__single fe = __container_of(node, struct flow_entry, in __fe_cuckoo_cmp() local
121 return flow_key_cmp(&fe->fe_key, key); in __fe_cuckoo_cmp()
124 return flow_key_cmp_mask(&fe->fe_key, key, mask); in __fe_cuckoo_cmp()
130 struct flow_entry *__single fe = __container_of(node, struct flow_entry, in __fe_cuckoo_retain() local
132 return flow_entry_retain(fe); in __fe_cuckoo_retain()
139 struct flow_entry *__single fe = in __fe_cuckoo_release() local
141 flow_entry_release(&fe); in __fe_cuckoo_release()
925 struct flow_entry *__single fe; in flow_mgr_flow_add() local
948 fe = flow_entry_alloc(fo, req, &err); in flow_mgr_flow_add()
949 if (__improbable(fe == NULL)) { in flow_mgr_flow_add()
[all …]
H A Dflow_owner.c140 struct flow_entry *fe, *tfe; in flow_owner_bucket_purge_common() local
154 RB_FOREACH_SAFE(fe, flow_entry_id_tree, in flow_owner_bucket_purge_common()
156 ASSERT(fe->fe_nx_port == fo->fo_nx_port); in flow_owner_bucket_purge_common()
157 flow_entry_retain(fe); in flow_owner_bucket_purge_common()
158 flow_entry_destroy(fo, fe, FALSE, NULL); in flow_owner_bucket_purge_common()
194 struct flow_entry *fe; in flow_owner_bucket_activate_nx_port_common() local
210 RB_FOREACH(fe, flow_entry_id_tree, in flow_owner_bucket_activate_nx_port_common()
212 if (fe->fe_flags & FLOWENTF_TORN_DOWN) { in flow_owner_bucket_activate_nx_port_common()
215 VERIFY(fe->fe_nx_port == fo->fo_nx_port); in flow_owner_bucket_activate_nx_port_common()
216 if (fe->fe_adv_idx != FLOWADV_IDX_NONE) { in flow_owner_bucket_activate_nx_port_common()
[all …]
H A Dflow_agg.c1518 estimate_buf_cnt(struct flow_entry *fe, uint32_t total_bytes, uint32_t total_pkts, in estimate_buf_cnt() argument
1522 uint32_t agg_size = MAX(fe->fe_rx_largest_size, min_bufsize); in estimate_buf_cnt()
1588 converge_aggregation_size(struct flow_entry *fe, uint32_t largest_agg_size) in converge_aggregation_size() argument
1590 if (fe->fe_rx_largest_size > largest_agg_size) { in converge_aggregation_size()
1598 fe->fe_rx_largest_size -= in converge_aggregation_size()
1599 ((fe->fe_rx_largest_size - largest_agg_size) >> 2); in converge_aggregation_size()
1601 fe->fe_rx_largest_size += in converge_aggregation_size()
1602 ((largest_agg_size - fe->fe_rx_largest_size) >> 2); in converge_aggregation_size()
1608 flow_rx_agg_channel(struct nx_flowswitch *fsw, struct flow_entry *fe, in flow_rx_agg_channel() argument
1627 ring = fsw_flow_get_rx_ring(fsw, fe); in flow_rx_agg_channel()
[all …]
H A Dflow_var.h248 typedef void (*flow_tx_action_t)(struct nx_flowswitch *fsw, struct flow_entry *fe,
252 typedef void (*flow_rx_action_t)(struct nx_flowswitch *fsw, struct flow_entry *fe,
987 void (^flow_handler)(struct flow_entry *fe));
995 extern void flow_entry_retain(struct flow_entry *fe);
997 extern uint32_t flow_entry_refcnt(struct flow_entry *fe);
1015 extern void flow_track_abort_tcp( struct flow_entry *fe,
1017 extern void flow_track_abort_quic(struct flow_entry *fe,
1024 extern void flow_rx_agg_tcp(struct nx_flowswitch *fsw, struct flow_entry *fe,
1066 extern char *fe_as_string(const struct flow_entry *fe, char *__counted_by(dsz)dst, size_t dsz);
/xnu-11215.61.5/bsd/skywalk/nexus/flowswitch/
H A Dfsw_dp.c369 fsw_snoop(struct nx_flowswitch *fsw, struct flow_entry *fe, struct pktq *pktq, in fsw_snoop() argument
382 ASSERT(fe != NULL); in fsw_snoop()
385 if (fe->fe_nx_port == FSW_VP_HOST) { in fsw_snoop()
387 tap_early = (input && fe->fe_key.fk_proto == IPPROTO_TCP); in fsw_snoop()
393 if (fe->fe_key.fk_ipver == IPVERSION) { in fsw_snoop()
395 } else if (fe->fe_key.fk_ipver == IPV6_VERSION) { in fsw_snoop()
401 pid = fe->fe_pid; in fsw_snoop()
402 if (fe->fe_proc_name[0] != '\0') { in fsw_snoop()
404 fe->fe_proc_name, sizeof(fe->fe_proc_name)); in fsw_snoop()
406 epid = fe->fe_epid; in fsw_snoop()
[all …]
H A Dfsw_flow.c257 struct flow_entry *__single 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()
454 struct flow_entry *__single fe = NULL; in fsw_flow_config() local
459 fe = flow_mgr_get_fe_by_uuid_rlock(fm, req->nfr_flow_uuid); in fsw_flow_config()
460 if (fe == NULL) { in fsw_flow_config()
466 if (fe->fe_pid != req->nfr_pid) { in fsw_flow_config()
473 nt = fe->fe_port_reservation; in fsw_flow_config()
[all …]
H A Dfsw_var.h159 extern void fsw_snoop(struct nx_flowswitch *fsw, struct flow_entry *fe,
164 struct flow_entry *fe, uint32_t flags);
166 struct flow_entry *fe, struct pktq *rx_pkts, uint32_t rx_bytes,
184 extern void fsw_flow_abort_tcp(struct nx_flowswitch *fsw, struct flow_entry *fe,
186 extern void fsw_flow_abort_quic(struct flow_entry *fe, uint8_t *token);
188 struct flow_entry *fe);
190 struct flow_entry *fe);
210 extern void fsw_qos_mark(struct nx_flowswitch *fsw, struct flow_entry *fe,
232 fsw_snoop_and_dequeue(struct flow_entry *fe, struct pktq *target, in fsw_snoop_and_dequeue() argument
236 fsw_snoop(fe->fe_fsw, fe, source, input); in fsw_snoop_and_dequeue()
H A Dfsw_qos.c94 fsw_qos_mark(struct nx_flowswitch *fsw, struct flow_entry *fe, in fsw_qos_mark() argument
100 ASSERT(KPKT_VALID_SVC(fe->fe_svc_class)); in fsw_qos_mark()
104 pkt->pkt_svc_class = fe->fe_svc_class; in fsw_qos_mark()
115 if ((fe->fe_flags & FLOWENTF_QOS_MARKING) == 0) { in fsw_qos_mark()
H A Dfsw.c1187 struct flow_entry *__single fe = NULL; in fsw_protoctl_event_callback() local
1246 fe = flow_mgr_find_fe_by_key(fsw->fsw_flow_mgr, &fk); in fsw_protoctl_event_callback()
1247 if (__improbable(fe == NULL)) { in fsw_protoctl_event_callback()
1251 uuid_copy(fe_uuid, fe->fe_uuid); in fsw_protoctl_event_callback()
1274 fe_as_string(fe, dbgbuf, sizeof(dbgbuf)), in fsw_protoctl_event_callback()
1290 if (fe != NULL) { in fsw_protoctl_event_callback()
1291 flow_entry_release(&fe); in fsw_protoctl_event_callback()
1723 struct flow_entry *__single fe; in fsw_mib_get_flow() local
1728 fe = flow_mgr_get_fe_by_uuid_rlock(fm, filter->nmf_flow_id); in fsw_mib_get_flow()
1729 if (fe != NULL) { in fsw_mib_get_flow()
[all …]
/xnu-11215.61.5/tools/lldbmacros/
H A Dskywalk.py697 def FlowEntryStr(fe): argument
699 hex(fe), GetUUIDSummary(fe.fe_uuid), FlowKeyStr(fe.fe_key), str(fe.fe_proc_name))
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-11215.61.5/libsyscall/wrappers/skywalk/
H A Dos_channel.c1235 _flowadv_id_equal(struct __flowadv_entry *fe, uuid_t id) in _flowadv_id_equal() argument
1243 return fe->fae_id_64[0] == id_64[0] && in _flowadv_id_equal()
1244 fe->fae_id_64[1] == id_64[1]; in _flowadv_id_equal()
1247 return fe->fae_id_32[0] == id_32[0] && in _flowadv_id_equal()
1248 fe->fae_id_32[1] == id_32[1] && in _flowadv_id_equal()
1249 fe->fae_id_32[2] == id_32[2] && in _flowadv_id_equal()
1250 fe->fae_id_32[3] == id_32[3]; in _flowadv_id_equal()
1253 return UUID_COMPARE(fe->fae_id, id); in _flowadv_id_equal()
1262 struct __flowadv_entry *fe = CHD_NX_FLOWADV(chd); in os_channel_flow_admissible() local
1283 fe = &CHD_NX_FLOWADV(chd)[flow_index]; in os_channel_flow_admissible()
[all …]
/xnu-11215.61.5/pexpert/pexpert/arm/
H A Dpl011.h14 uint32_t fe : 1; member
24 uint32_t fe : 1; member
/xnu-11215.61.5/bsd/skywalk/namespace/
H A Dnetns.c1761 netns_local_port_scan_flow_entry(struct flow_entry *fe, protocol_family_t protocol, in netns_local_port_scan_flow_entry() argument
1767 if (fe == NULL) { in netns_local_port_scan_flow_entry()
1771 if (fe->fe_flags & FLOWENTF_EXTRL_PORT) { in netns_local_port_scan_flow_entry()
1775 token = fe->fe_port_reservation; in netns_local_port_scan_flow_entry()
1838 struct flow_route *fr = fe->fe_route; in netns_local_port_scan_flow_entry()
1926 (void) if_ports_used_add_flow_entry(fe, token->nt_ifp->if_index, in netns_local_port_scan_flow_entry()
/xnu-11215.61.5/bsd/net/
H A Dif_ports_used.h312 bool if_ports_used_add_flow_entry(const struct flow_entry *fe, const uint32_t ifindex,
H A Dif_ports_used.c852 if_ports_used_add_flow_entry(const struct flow_entry *fe, const uint32_t ifindex, in if_ports_used_add_flow_entry() argument
937 uuid_copy(npi.npi_effective_uuid, fe->fe_eproc_uuid); in if_ports_used_add_flow_entry()
/xnu-11215.61.5/bsd/skywalk/
H A Dos_stats_private.h1308 #define FLOW_STATS_IN_ADD(fe, stat, cnt) { \ argument
1310 fst = &(fe)->fe_stats->fs_rtrack; \
1314 #define FLOW_STATS_OUT_ADD(fe, stat, cnt) { \ argument
1316 fst = &(fe)->fe_stats->fs_ltrack; \