Lines Matching refs:search_flow
1278 struct necp_client_flow *search_flow = NULL; in necp_defunct_flow_registration() local
1279 LIST_FOREACH(search_flow, &flow_registration->flow_list, flow_chain) { in necp_defunct_flow_registration()
1280 if (search_flow->nexus && in necp_defunct_flow_registration()
1281 !uuid_is_null(search_flow->u.nexus_agent)) { in necp_defunct_flow_registration()
1287 uuid_copy(flow_defunct->nexus_agent, search_flow->u.nexus_agent); in necp_defunct_flow_registration()
1586 struct necp_client_flow *search_flow = NULL; in necp_destroy_client_flow_registration() local
1588 LIST_FOREACH_SAFE(search_flow, &flow_registration->flow_list, flow_chain, temp_flow) { in necp_destroy_client_flow_registration()
1589 if (search_flow->nexus && in necp_destroy_client_flow_registration()
1590 !uuid_is_null(search_flow->u.nexus_agent)) { in necp_destroy_client_flow_registration()
1600 int netagent_error = netagent_client_message_with_params(search_flow->u.nexus_agent, in necp_destroy_client_flow_registration()
1612 uuid_clear(search_flow->u.nexus_agent); in necp_destroy_client_flow_registration()
1614 if (search_flow->assigned_results != NULL) { in necp_destroy_client_flow_registration()
1615 kfree_data(search_flow->assigned_results, search_flow->assigned_results_length); in necp_destroy_client_flow_registration()
1616 search_flow->assigned_results = NULL; in necp_destroy_client_flow_registration()
1618 LIST_REMOVE(search_flow, flow_chain); in necp_destroy_client_flow_registration()
1620 if (search_flow->nexus) { in necp_destroy_client_flow_registration()
1624 if (search_flow->socket) { in necp_destroy_client_flow_registration()
1629 mcache_free(necp_flow_cache, search_flow); in necp_destroy_client_flow_registration()
3570 struct necp_client_flow *search_flow = NULL; in necp_client_unregister_socket_flow() local
3572 LIST_FOREACH_SAFE(search_flow, &flow_registration->flow_list, flow_chain, temp_flow) { in necp_client_unregister_socket_flow()
3573 if (search_flow->socket && search_flow->u.socket_handle == handle) { in necp_client_unregister_socket_flow()
3574 if (search_flow->assigned_results != NULL) { in necp_client_unregister_socket_flow()
3575 kfree_data(search_flow->assigned_results, search_flow->assigned_results_length); in necp_client_unregister_socket_flow()
3576 search_flow->assigned_results = NULL; in necp_client_unregister_socket_flow()
3580 LIST_REMOVE(search_flow, flow_chain); in necp_client_unregister_socket_flow()
3582 mcache_free(necp_flow_cache, search_flow); in necp_client_unregister_socket_flow()
3624 struct necp_client_flow *search_flow = NULL; in necp_client_unregister_multipath_cb() local
3626 LIST_FOREACH_SAFE(search_flow, &flow_registration->flow_list, flow_chain, temp_flow) { in necp_client_unregister_multipath_cb()
3627 if (!search_flow->socket && !search_flow->nexus && in necp_client_unregister_multipath_cb()
3628 search_flow->u.socket_handle == handle) { in necp_client_unregister_multipath_cb()
3629 search_flow->u.socket_handle = NULL; in necp_client_unregister_multipath_cb()
3630 search_flow->u.cb = NULL; in necp_client_unregister_multipath_cb()
4436 struct necp_client_flow *search_flow = NULL; in necp_update_client_result() local
4438 LIST_FOREACH(search_flow, &flow_registration->flow_list, flow_chain) { in necp_update_client_result()
4439 if (search_flow->assigned) { in necp_update_client_result()
4803 struct necp_client_flow *search_flow = NULL; in necp_defunct_client_fd_locked_inner() local
4805 LIST_FOREACH(search_flow, &flow_registration->flow_list, flow_chain) { in necp_defunct_client_fd_locked_inner()
4806 if (search_flow->nexus && in necp_defunct_client_fd_locked_inner()
4807 !uuid_is_null(search_flow->u.nexus_agent)) { in necp_defunct_client_fd_locked_inner()
4810 uuid_copy(flow_defunct->nexus_agent, search_flow->u.nexus_agent); in necp_defunct_client_fd_locked_inner()