Home
last modified time | relevance | path

Searched refs:flows (Results 1 – 5 of 5) sorted by relevance

/xnu-12377.1.9/tests/skywalk/
H A Dskt_manyflows.c49 …ncd, const uuid_t fsw, nexus_port_t nx_port_start, int nports, int nflows_per_port, uuid_t flows[]) in do_flows() argument
54 uuid_generate_random(flows[i * nflows_per_port + j]); in do_flows()
56 error = sktc_bind_tcp4_flow(ncd, fsw, 0, nx_port_start + i, flows[i * nflows_per_port + j]); in do_flows()
63 undo_flows(nexus_controller_t ncd, const uuid_t fsw, int nflows, const uuid_t flows[]) in undo_flows() argument
68 uuid_unparse_upper(flows[i], uuidstr); in undo_flows()
70 error = sktc_unbind_flow(ncd, fsw, flows[i]); in undo_flows()
81 uuid_t flows[nports * nflows_per_port]; in skt_manyflows_common() local
83 …es.controller, handles.fsw_nx_uuid, NEXUS_PORT_FLOW_SWITCH_CLIENT, nports, nflows_per_port, flows); in skt_manyflows_common()
84 undo_flows(handles.controller, handles.fsw_nx_uuid, sizeof(flows) / sizeof(flows[0]), flows); in skt_manyflows_common()
173 uuid_t flows[nports]; in skt_mf1xall_common() local
[all …]
H A Dskt_listener.c287 struct sktu_flow *listener, *flows[511]; in skt_listener_stress_main() local
313 …flows[i] = sktu_create_nexus_flow(&handles, AF_INET, &our_ip, &peer_ip, IPPROTO_TCP, our_port, 100… in skt_listener_stress_main()
314 assert(flows[i]); in skt_listener_stress_main()
/xnu-12377.1.9/tools/lldbmacros/
H A Dskywalk.py708 flows = []
711 flows.append(fe)
714 return flows
743 flows = GetFlowswitchFlowEntries(fsw)
744 flows.sort(key=GetFlowEntryPid)
745 for fe in flows:
/xnu-12377.1.9/bsd/netinet/
H A Dmptcp_subr.c6130 mptcp_flow_t *flows = NULL; variable
6145 flows = NULL;
6174 len = sizeof(*flows) * mpte->mpte_numflows;
6176 flows = kalloc_data(len, Z_WAITOK | Z_ZERO);
6177 if (flows == NULL) {
6182 sizeof(*flows) * (mptcpci.mptcpci_nflows - 1);
6191 kfree_data(flows, len);
6197 fill_mptcp_subflow(so, &flows[f], mpts);
6201 if (flows) {
6202 error = SYSCTL_OUT(req, flows, len);
[all …]
/xnu-12377.1.9/bsd/net/
H A Dnecp_client.c657 struct _necp_fd_flow_tree flows; member
1054 …struct necp_client_flow_registration *flow = RB_FIND(_necp_fd_flow_tree, &client_fd->flows, &find); in necp_client_fd_find_client_unlocked()
2073 RB_FOREACH_SAFE(flow_registration, _necp_fd_flow_tree, &fd_data->flows, temp_flow_registration) { in necpop_close()
2080 RB_REMOVE(_necp_fd_flow_tree, &fd_data->flows, flow_registration); in necpop_close()
3639 RB_INSERT(_necp_fd_flow_tree, &fd_data->flows, new_registration); in necp_client_create_flow_registration()
7773 RB_INIT(&fd_data->flows); in necp_open()
8258 RB_FOREACH_SAFE(flow_registration, _necp_fd_flow_tree, &fd_data->flows, temp_flow_registration) { in necp_client_remove()
8266 RB_REMOVE(_necp_fd_flow_tree, &fd_data->flows, flow_registration); in necp_client_remove()
8326 flow = RB_FIND(_necp_fd_flow_tree, &client_fd->flows, &find); in necp_client_fd_find_flow()
8373 RB_REMOVE(_necp_fd_flow_tree, &fd_data->flows, flow_registration); in necp_client_remove_flow()
[all …]