Lines Matching refs:search_flow
1544 struct necp_client_flow *search_flow = NULL; in necp_defunct_flow_registration() local
1545 LIST_FOREACH(search_flow, &flow_registration->flow_list, flow_chain) { in necp_defunct_flow_registration()
1547 if (search_flow->nexus && in necp_defunct_flow_registration()
1548 !uuid_is_null(search_flow->u.nexus_agent)) { in necp_defunct_flow_registration()
1551 search_flow->socket && in necp_defunct_flow_registration()
1552 search_flow->u.socket_handle != NULL) { in necp_defunct_flow_registration()
1562 if (search_flow->nexus) { in necp_defunct_flow_registration()
1563 uuid_copy(flow_defunct->nexus_agent, search_flow->u.nexus_agent); in necp_defunct_flow_registration()
1564 } else if (search_flow->socket) { in necp_defunct_flow_registration()
1565 flow_defunct->socket_handle = search_flow->u.socket_handle; in necp_defunct_flow_registration()
1865 struct necp_client_flow * __single search_flow = NULL; in necp_destroy_client_flow_registration() local
1867 LIST_FOREACH_SAFE(search_flow, &flow_registration->flow_list, flow_chain, temp_flow) { in necp_destroy_client_flow_registration()
1868 if (search_flow->nexus && in necp_destroy_client_flow_registration()
1869 !uuid_is_null(search_flow->u.nexus_agent)) { in necp_destroy_client_flow_registration()
1881 int netagent_error = netagent_client_message_with_params(search_flow->u.nexus_agent, in necp_destroy_client_flow_registration()
1893 uuid_clear(search_flow->u.nexus_agent); in necp_destroy_client_flow_registration()
1895 if (search_flow->assigned_results != NULL) { in necp_destroy_client_flow_registration()
1896 kfree_data_counted_by(search_flow->assigned_results, search_flow->assigned_results_length); in necp_destroy_client_flow_registration()
1898 LIST_REMOVE(search_flow, flow_chain); in necp_destroy_client_flow_registration()
1900 if (search_flow->nexus) { in necp_destroy_client_flow_registration()
1904 if (search_flow->socket) { in necp_destroy_client_flow_registration()
1910 necp_aop_offload_stats_destroy(search_flow); in necp_destroy_client_flow_registration()
1912 kfree_type(struct necp_client_flow, search_flow); in necp_destroy_client_flow_registration()
4005 struct necp_client_flow * __single search_flow = NULL; in necp_client_unregister_socket_flow() local
4007 LIST_FOREACH_SAFE(search_flow, &flow_registration->flow_list, flow_chain, temp_flow) { in necp_client_unregister_socket_flow()
4008 if (search_flow->socket && search_flow->u.socket_handle == handle) { in necp_client_unregister_socket_flow()
4009 if (search_flow->assigned_results != NULL) { in necp_client_unregister_socket_flow()
4010 kfree_data_counted_by(search_flow->assigned_results, search_flow->assigned_results_length); in necp_client_unregister_socket_flow()
4014 LIST_REMOVE(search_flow, flow_chain); in necp_client_unregister_socket_flow()
4016 kfree_type(struct necp_client_flow, search_flow); in necp_client_unregister_socket_flow()
4058 struct necp_client_flow *search_flow = NULL; in necp_client_unregister_multipath_cb() local
4060 LIST_FOREACH_SAFE(search_flow, &flow_registration->flow_list, flow_chain, temp_flow) { in necp_client_unregister_multipath_cb()
4061 if (!search_flow->socket && !search_flow->nexus && in necp_client_unregister_multipath_cb()
4062 search_flow->u.socket_handle == handle) { in necp_client_unregister_multipath_cb()
4063 search_flow->u.socket_handle = NULL; in necp_client_unregister_multipath_cb()
4064 search_flow->u.cb = NULL; in necp_client_unregister_multipath_cb()
4903 struct necp_client_flow *search_flow = NULL; in necp_update_client_result() local
4905 LIST_FOREACH(search_flow, &flow_registration->flow_list, flow_chain) { in necp_update_client_result()
4906 if (search_flow->assigned) { in necp_update_client_result()
5321 struct necp_client_flow *search_flow = NULL; in necp_defunct_client_fd_locked_inner() local
5323 LIST_FOREACH(search_flow, &flow_registration->flow_list, flow_chain) { in necp_defunct_client_fd_locked_inner()
5324 if (search_flow->nexus && in necp_defunct_client_fd_locked_inner()
5325 !uuid_is_null(search_flow->u.nexus_agent)) { in necp_defunct_client_fd_locked_inner()
5328 uuid_copy(flow_defunct->nexus_agent, search_flow->u.nexus_agent); in necp_defunct_client_fd_locked_inner()