Lines Matching refs:wrapper
170 struct netagent_wrapper *wrapper; member
199 #define NETAGENT_LOCK_EXCLUSIVE(wrapper) lck_rw_lock_exclusive(&wrapper->agent_lock) argument
200 #define NETAGENT_LOCK_SHARED(wrapper) lck_rw_lock_shared(&wrapper->agent_lock) argument
201 #define NETAGENT_LOCK_SHARED_TO_EXCLUSIVE(wrapper) lck_rw_lock_shared_to_exclusive(&wrapper->agent_… argument
202 #define NETAGENT_UNLOCK(wrapper) lck_rw_done(&wrapper->agent_lock) argument
203 #define NETAGENT_ASSERT_LOCKED(wrapper) LCK_RW_ASSERT(&wrapper->agent_lock, LCK_RW_ASSERT_HELD) argument
390 netagent_send_trigger(struct netagent_wrapper *wrapper, struct proc *p, u_int32_t flags, u_int8_t t… in netagent_send_trigger() argument
413 if ((error = netagent_send_ctl_data(wrapper->control_unit, trigger, trigger_size))) { in netagent_send_trigger()
414 NETAGENTLOG(LOG_ERR, "Failed to send trigger message on control unit %d", wrapper->control_unit); in netagent_send_trigger()
422 netagent_send_client_message(struct netagent_wrapper *wrapper, uuid_t client_id, u_int8_t message_t… in netagent_send_client_message() argument
439 if ((error = netagent_send_ctl_data(wrapper->control_unit, message, message_size))) { in netagent_send_client_message()
440 …NETAGENTLOG(LOG_ERR, "Failed to send client message %d on control unit %d", message_type, wrapper-… in netagent_send_client_message()
448 netagent_send_error_message(struct netagent_wrapper *wrapper, uuid_t client_id, u_int8_t message_ty… in netagent_send_error_message() argument
466 if ((error = netagent_send_ctl_data(wrapper->control_unit, message, message_size))) { in netagent_send_error_message()
467 …NETAGENTLOG(LOG_ERR, "Failed to send client message %d on control unit %d", message_type, wrapper-… in netagent_send_error_message()
475 netagent_send_group_message(struct netagent_wrapper *wrapper, uuid_t client_id, u_int8_t message_ty… in netagent_send_group_message() argument
493 if ((error = netagent_send_ctl_data(wrapper->control_unit, message, message_size))) { in netagent_send_group_message()
494 … "Failed to send client group message %d on control unit %d", message_type, wrapper->control_unit); in netagent_send_group_message()
502 netagent_send_tokens_needed(struct netagent_wrapper *wrapper) in netagent_send_tokens_needed() argument
516 if ((error = netagent_send_ctl_data(wrapper->control_unit, message, message_size))) { in netagent_send_tokens_needed()
517 …NETAGENTLOG(LOG_ERR, "Failed to send client tokens needed message on control unit %d", wrapper->co… in netagent_send_tokens_needed()
820 netagent_free_wrapper_memory(struct netagent_wrapper *wrapper) in netagent_free_wrapper_memory() argument
832 NETAGENT_LOCK_EXCLUSIVE(wrapper); in netagent_free_wrapper_memory()
833 NETAGENT_UNLOCK(wrapper); in netagent_free_wrapper_memory()
834 lck_rw_destroy(&wrapper->agent_lock, &netagent_mtx_grp); in netagent_free_wrapper_memory()
836 kfree_data(wrapper->netagent, sizeof(struct netagent) + in netagent_free_wrapper_memory()
837 wrapper->netagent->netagent_data_size); in netagent_free_wrapper_memory()
838 kfree_type(struct netagent_wrapper, wrapper); in netagent_free_wrapper_memory()
842 netagent_free_wrapper(struct netagent_wrapper *wrapper) in netagent_free_wrapper() argument
847 TAILQ_FOREACH_SAFE(search_token, &wrapper->token_list, token_chain, temp_token) { in netagent_free_wrapper()
848 TAILQ_REMOVE(&wrapper->token_list, search_token, token_chain); in netagent_free_wrapper()
855 LIST_FOREACH_SAFE(search_client, &wrapper->pending_triggers_list, client_chain, temp_client) { in netagent_free_wrapper()
861 netagent_free_wrapper_memory(wrapper); in netagent_free_wrapper()
869 struct netagent_wrapper *wrapper = NULL; in netagent_unregister_session_wrapper() local
873 wrapper = session->wrapper; in netagent_unregister_session_wrapper()
874 if (wrapper != NULL) { in netagent_unregister_session_wrapper()
878 if ((session->wrapper->netagent->netagent_flags & NETAGENT_FLAG_ACTIVE) && in netagent_unregister_session_wrapper()
883 LIST_REMOVE(wrapper, list_chain); in netagent_unregister_session_wrapper()
886 uuid_copy(unregistered_uuid, session->wrapper->netagent->netagent_uuid); in netagent_unregister_session_wrapper()
888 netagent_free_wrapper(session->wrapper); in netagent_unregister_session_wrapper()
889 session->wrapper = NULL; in netagent_unregister_session_wrapper()
943 if (session->wrapper != NULL) { in netagent_handle_register_inner()
954 session->wrapper = new_wrapper; in netagent_handle_register_inner()
1187 netagent_send_cellular_failed_event(struct netagent_wrapper *wrapper, in netagent_send_cellular_failed_event() argument
1190 if (strlcmp(wrapper->netagent->netagent_domain, "Cellular", NETAGENT_DOMAINSIZE) != 0) { in netagent_send_cellular_failed_event()
1219 if (session->wrapper == NULL) { in netagent_handle_update_inner()
1226 NETAGENT_LOCK_EXCLUSIVE(session->wrapper); in netagent_handle_update_inner()
1228 …if (uuid_compare(session->wrapper->netagent->netagent_uuid, new_wrapper->netagent->netagent_uuid) … in netagent_handle_update_inner()
1229 memcmp(&session->wrapper->netagent->netagent_domain, &new_wrapper->netagent->netagent_domain, in netagent_handle_update_inner()
1231 memcmp(&session->wrapper->netagent->netagent_type, &new_wrapper->netagent->netagent_type, in netagent_handle_update_inner()
1233 NETAGENT_UNLOCK(session->wrapper); in netagent_handle_update_inner()
1246 if (session->wrapper->netagent->netagent_data_size == new_wrapper->netagent->netagent_data_size && in netagent_handle_update_inner()
1247 memcmp(session->wrapper->netagent, new_wrapper->netagent, sizeof(struct netagent)) == 0 && in netagent_handle_update_inner()
1248 …memcmp(netagent_get_data(session->wrapper->netagent), netagent_get_data(new_wrapper->netagent), da… in netagent_handle_update_inner()
1256 …LIST_FOREACH_SAFE(search_client, &session->wrapper->pending_triggers_list, client_chain, temp_clie… in netagent_handle_update_inner()
1260 NETAGENT_UNLOCK(session->wrapper); in netagent_handle_update_inner()
1268 …e_update_client(search_client->client_id, session->wrapper->netagent->netagent_uuid, session->wrap… in netagent_handle_update_inner()
1279 new_wrapper->use_count = session->wrapper->use_count; in netagent_handle_update_inner()
1282 TAILQ_CONCAT(&new_wrapper->token_list, &session->wrapper->token_list, token_chain); in netagent_handle_update_inner()
1283 new_wrapper->token_count = session->wrapper->token_count; in netagent_handle_update_inner()
1284 new_wrapper->token_low_water = session->wrapper->token_low_water; in netagent_handle_update_inner()
1285 new_wrapper->last_client_error = session->wrapper->last_client_error; in netagent_handle_update_inner()
1286 new_wrapper->client_error_count = session->wrapper->client_error_count; in netagent_handle_update_inner()
1289 !(session->wrapper->netagent->netagent_flags & NETAGENT_FLAG_ACTIVE)) { in netagent_handle_update_inner()
1292 (session->wrapper->netagent->netagent_flags & NETAGENT_FLAG_ACTIVE) && in netagent_handle_update_inner()
1297 LIST_REMOVE(session->wrapper, list_chain); in netagent_handle_update_inner()
1298 NETAGENT_UNLOCK(session->wrapper); in netagent_handle_update_inner()
1299 netagent_free_wrapper(session->wrapper); in netagent_handle_update_inner()
1300 session->wrapper = new_wrapper; in netagent_handle_update_inner()
1509 if (session->wrapper == NULL) { in netagent_assign_nexus()
1514 NETAGENT_LOCK_SHARED(session->wrapper); in netagent_assign_nexus()
1515 uuid_copy(netagent_uuid, session->wrapper->netagent->netagent_uuid); in netagent_assign_nexus()
1516 NETAGENT_UNLOCK(session->wrapper); in netagent_assign_nexus()
1546 if (session->wrapper == NULL) { in netagent_update_flow_protoctl_event()
1551 NETAGENT_LOCK_SHARED(session->wrapper); in netagent_update_flow_protoctl_event()
1552 uuid_copy(netagent_uuid, session->wrapper->netagent->netagent_uuid); in netagent_update_flow_protoctl_event()
1553 NETAGENT_UNLOCK(session->wrapper); in netagent_update_flow_protoctl_event()
1585 if (session->wrapper == NULL) { in netagent_handle_assign_nexus_setopt()
1592 NETAGENT_LOCK_SHARED(session->wrapper); in netagent_handle_assign_nexus_setopt()
1593 uuid_copy(netagent_uuid, session->wrapper->netagent->netagent_uuid); in netagent_handle_assign_nexus_setopt()
1594 NETAGENT_UNLOCK(session->wrapper); in netagent_handle_assign_nexus_setopt()
1650 if (session->wrapper == NULL) { in netagent_handle_assign_nexus_message()
1656 NETAGENT_LOCK_SHARED(session->wrapper); in netagent_handle_assign_nexus_message()
1657 uuid_copy(netagent_uuid, session->wrapper->netagent->netagent_uuid); in netagent_handle_assign_nexus_message()
1658 NETAGENT_UNLOCK(session->wrapper); in netagent_handle_assign_nexus_message()
1731 if (session->wrapper == NULL) { in netagent_handle_assign_group_setopt()
1738 NETAGENT_LOCK_SHARED(session->wrapper); in netagent_handle_assign_group_setopt()
1739 uuid_copy(netagent_uuid, session->wrapper->netagent->netagent_uuid); in netagent_handle_assign_group_setopt()
1740 NETAGENT_UNLOCK(session->wrapper); in netagent_handle_assign_group_setopt()
1807 if (session->wrapper == NULL) { in netagent_handle_use_count_setopt()
1814 NETAGENT_LOCK_EXCLUSIVE(session->wrapper); in netagent_handle_use_count_setopt()
1815 session->wrapper->use_count = use_count; in netagent_handle_use_count_setopt()
1816 NETAGENT_UNLOCK(session->wrapper); in netagent_handle_use_count_setopt()
1849 if (session->wrapper == NULL) { in netagent_handle_use_count_getopt()
1856 NETAGENT_LOCK_SHARED(session->wrapper); in netagent_handle_use_count_getopt()
1857 use_count = session->wrapper->use_count; in netagent_handle_use_count_getopt()
1858 NETAGENT_UNLOCK(session->wrapper); in netagent_handle_use_count_getopt()
1892 if (session->wrapper == NULL) { in netagent_handle_add_token_setopt()
1899 NETAGENT_LOCK_EXCLUSIVE(session->wrapper); in netagent_handle_add_token_setopt()
1900 if (session->wrapper->token_count >= NETAGENT_MAX_TOKEN_COUNT) { in netagent_handle_add_token_setopt()
1901 NETAGENT_UNLOCK(session->wrapper); in netagent_handle_add_token_setopt()
1915 TAILQ_INSERT_TAIL(&session->wrapper->token_list, token_struct, token_chain); in netagent_handle_add_token_setopt()
1917 session->wrapper->token_count++; in netagent_handle_add_token_setopt()
1920 session->wrapper->need_tokens_event_deadline = 0; in netagent_handle_add_token_setopt()
1922 NETAGENT_UNLOCK(session->wrapper); in netagent_handle_add_token_setopt()
1940 if (session->wrapper == NULL) { in netagent_handle_flush_tokens_setopt()
1947 NETAGENT_LOCK_EXCLUSIVE(session->wrapper); in netagent_handle_flush_tokens_setopt()
1950 TAILQ_FOREACH_SAFE(search_token, &session->wrapper->token_list, token_chain, temp_token) { in netagent_handle_flush_tokens_setopt()
1951 TAILQ_REMOVE(&session->wrapper->token_list, search_token, token_chain); in netagent_handle_flush_tokens_setopt()
1954 session->wrapper->token_count = 0; in netagent_handle_flush_tokens_setopt()
1955 NETAGENT_UNLOCK(session->wrapper); in netagent_handle_flush_tokens_setopt()
1986 if (session->wrapper == NULL) { in netagent_handle_token_count_getopt()
1993 NETAGENT_LOCK_SHARED(session->wrapper); in netagent_handle_token_count_getopt()
1994 token_count = session->wrapper->token_count; in netagent_handle_token_count_getopt()
1995 NETAGENT_UNLOCK(session->wrapper); in netagent_handle_token_count_getopt()
2032 if (session->wrapper == NULL) { in netagent_handle_token_low_water_setopt()
2039 NETAGENT_LOCK_EXCLUSIVE(session->wrapper); in netagent_handle_token_low_water_setopt()
2040 session->wrapper->token_low_water = token_low_water; in netagent_handle_token_low_water_setopt()
2041 NETAGENT_UNLOCK(session->wrapper); in netagent_handle_token_low_water_setopt()
2073 if (session->wrapper == NULL) { in netagent_handle_token_low_water_getopt()
2080 NETAGENT_LOCK_SHARED(session->wrapper); in netagent_handle_token_low_water_getopt()
2081 token_low_water = session->wrapper->token_low_water; in netagent_handle_token_low_water_getopt()
2082 NETAGENT_UNLOCK(session->wrapper); in netagent_handle_token_low_water_getopt()
2104 if (session->wrapper == NULL) { in netagent_handle_reset_client_error_setopt()
2111 NETAGENT_LOCK_EXCLUSIVE(session->wrapper); in netagent_handle_reset_client_error_setopt()
2114 TAILQ_FOREACH_SAFE(search_token, &session->wrapper->token_list, token_chain, temp_token) { in netagent_handle_reset_client_error_setopt()
2115 TAILQ_REMOVE(&session->wrapper->token_list, search_token, token_chain); in netagent_handle_reset_client_error_setopt()
2118 session->wrapper->last_client_error = 0; in netagent_handle_reset_client_error_setopt()
2119 session->wrapper->client_error_count = 0; in netagent_handle_reset_client_error_setopt()
2121 NETAGENT_UNLOCK(session->wrapper); in netagent_handle_reset_client_error_setopt()
2215 …struct netagent_wrapper *wrapper = netagent_find_agent_with_uuid_and_lock(ifsir32->netagent_uuid, … in netagent_ioctl() local
2216 if (wrapper == NULL) { in netagent_ioctl()
2220 uuid_copy(ifsir32->netagent_uuid, wrapper->netagent->netagent_uuid); in netagent_ioctl()
2221 …memcpy(ifsir32->netagent_domain, wrapper->netagent->netagent_domain, sizeof(ifsir32->netagent_doma… in netagent_ioctl()
2222 memcpy(ifsir32->netagent_type, wrapper->netagent->netagent_type, sizeof(ifsir32->netagent_type)); in netagent_ioctl()
2223 memcpy(ifsir32->netagent_desc, wrapper->netagent->netagent_desc, sizeof(ifsir32->netagent_desc)); in netagent_ioctl()
2224 ifsir32->netagent_flags = wrapper->netagent->netagent_flags; in netagent_ioctl()
2227 ifsir32->netagent_data_size = wrapper->netagent->netagent_data_size; in netagent_ioctl()
2229 ifsir32->netagent_data_size == wrapper->netagent->netagent_data_size) { in netagent_ioctl()
2231 …error = copyout(netagent_get_data(wrapper->netagent), ifsir32->netagent_data, wrapper->netagent->n… in netagent_ioctl()
2235 NETAGENT_UNLOCK(wrapper); in netagent_ioctl()
2240 …struct netagent_wrapper *wrapper = netagent_find_agent_with_uuid_and_lock(ifsir64->netagent_uuid, … in netagent_ioctl() local
2241 if (wrapper == NULL) { in netagent_ioctl()
2245 uuid_copy(ifsir64->netagent_uuid, wrapper->netagent->netagent_uuid); in netagent_ioctl()
2246 …memcpy(ifsir64->netagent_domain, wrapper->netagent->netagent_domain, sizeof(ifsir64->netagent_doma… in netagent_ioctl()
2247 memcpy(ifsir64->netagent_type, wrapper->netagent->netagent_type, sizeof(ifsir64->netagent_type)); in netagent_ioctl()
2248 memcpy(ifsir64->netagent_desc, wrapper->netagent->netagent_desc, sizeof(ifsir64->netagent_desc)); in netagent_ioctl()
2249 ifsir64->netagent_flags = wrapper->netagent->netagent_flags; in netagent_ioctl()
2252 ifsir64->netagent_data_size = wrapper->netagent->netagent_data_size; in netagent_ioctl()
2254 ifsir64->netagent_data_size == wrapper->netagent->netagent_data_size) { in netagent_ioctl()
2256 …error = copyout(netagent_get_data(wrapper->netagent), ifsir64->netagent_data, wrapper->netagent->n… in netagent_ioctl()
2260 NETAGENT_UNLOCK(wrapper); in netagent_ioctl()
2325 struct netagent_wrapper *wrapper = netagent_find_agent_with_uuid_and_lock(uuid, false, false); in netagent_get_flags() local
2326 if (wrapper != NULL) { in netagent_get_flags()
2327 flags = wrapper->netagent->netagent_flags; in netagent_get_flags()
2328 NETAGENT_UNLOCK(wrapper); in netagent_get_flags()
2344 struct netagent_wrapper *wrapper = netagent_find_agent_with_uuid_and_lock(uuid, true, false); in netagent_set_flags() local
2345 if (wrapper != NULL) { in netagent_set_flags()
2349 wrapper->netagent->netagent_flags & NETAGENT_FLAG_REGISTERED; in netagent_set_flags()
2351 if (wrapper->netagent->netagent_flags != flags) { in netagent_set_flags()
2352 wrapper->netagent->netagent_flags = flags; in netagent_set_flags()
2353 wrapper->generation = g_next_generation++; in netagent_set_flags()
2356 NETAGENT_UNLOCK(wrapper); in netagent_set_flags()
2375 struct netagent_wrapper *wrapper = netagent_find_agent_with_uuid_and_lock(uuid, false, false); in netagent_get_generation() local
2376 if (wrapper != NULL) { in netagent_get_generation()
2377 generation = wrapper->generation; in netagent_get_generation()
2378 NETAGENT_UNLOCK(wrapper); in netagent_get_generation()
2397 struct netagent_wrapper *wrapper = netagent_find_agent_with_uuid_and_lock(uuid, false, false); in netagent_get_agent_domain_and_type() local
2398 if (wrapper != NULL) { in netagent_get_agent_domain_and_type()
2400 memcpy(domain, wrapper->netagent->netagent_domain, NETAGENT_DOMAINSIZE); in netagent_get_agent_domain_and_type()
2401 memcpy(type, wrapper->netagent->netagent_type, NETAGENT_TYPESIZE); in netagent_get_agent_domain_and_type()
2402 NETAGENT_UNLOCK(wrapper); in netagent_get_agent_domain_and_type()
2417 struct netagent_wrapper *wrapper = netagent_find_agent_with_uuid_and_lock(uuid, false, false); in netagent_kernel_trigger() local
2418 if (wrapper == NULL) { in netagent_kernel_trigger()
2424 if ((wrapper->netagent->netagent_flags & NETAGENT_FLAG_KERNEL_ACTIVATED) == 0) { in netagent_kernel_trigger()
2431 if ((wrapper->netagent->netagent_flags & NETAGENT_FLAG_ACTIVE)) { in netagent_kernel_trigger()
2438 …error = netagent_send_trigger(wrapper, current_proc(), NETAGENT_TRIGGER_FLAG_KERNEL, NETAGENT_MESS… in netagent_kernel_trigger()
2441 if (wrapper != NULL) { in netagent_kernel_trigger()
2442 NETAGENT_UNLOCK(wrapper); in netagent_kernel_trigger()
2476 …struct netagent_wrapper *wrapper = netagent_find_agent_with_uuid_and_lock(agent_uuid, false, false… in netagent_client_message_with_params() local
2477 if (wrapper == NULL) { in netagent_client_message_with_params()
2484 if ((wrapper->netagent->netagent_flags & NETAGENT_FLAG_USER_ACTIVATED) == 0) { in netagent_client_message_with_params()
2502 netagent_send_cellular_failed_event(wrapper, report_pid, report_proc_uuid); in netagent_client_message_with_params()
2508 bool is_nexus_agent = ((wrapper->netagent->netagent_flags & in netagent_client_message_with_params()
2521 if ((wrapper->netagent->netagent_flags & NETAGENT_FLAG_ACTIVE) == 0) { in netagent_client_message_with_params()
2529 …bool is_group_agent = ((wrapper->netagent->netagent_flags & (NETAGENT_FLAG_SUPPORTS_GROUPS)) != 0); in netagent_client_message_with_params()
2536 if ((wrapper->netagent->netagent_flags & NETAGENT_FLAG_ACTIVE) == 0) { in netagent_client_message_with_params()
2544 if (wrapper->control_unit == 0) { in netagent_client_message_with_params()
2545 if (wrapper->event_handler == NULL) { in netagent_client_message_with_params()
2556 error = wrapper->event_handler(message_type, necp_client_uuid, pid, handle, in netagent_client_message_with_params()
2557 wrapper->event_context, parameters, in netagent_client_message_with_params()
2573 if (wrapper->last_client_error != client_error || // Always notify for an error change in netagent_client_message_with_params()
2575 (client_error == 0 && wrapper->client_error_count == 0) || // Only notify once for no-error in netagent_client_message_with_params()
2576 (client_error != 0 && wrapper->client_error_count < NETAGENT_MAX_CLIENT_ERROR_COUNT)) { in netagent_client_message_with_params()
2577 if (NETAGENT_LOCK_SHARED_TO_EXCLUSIVE(wrapper)) { in netagent_client_message_with_params()
2578 if (wrapper->last_client_error != client_error) { in netagent_client_message_with_params()
2579 wrapper->last_client_error = client_error; in netagent_client_message_with_params()
2580 wrapper->client_error_count = 1; in netagent_client_message_with_params()
2582 wrapper->client_error_count++; in netagent_client_message_with_params()
2584 error = netagent_send_error_message(wrapper, necp_client_uuid, message_type, client_error); in netagent_client_message_with_params()
2592 …error = netagent_send_group_message(wrapper, necp_client_uuid, message_type, ¶meters->u.group_… in netagent_client_message_with_params()
2594 error = netagent_send_client_message(wrapper, necp_client_uuid, message_type); in netagent_client_message_with_params()
2597 if (NETAGENT_LOCK_SHARED_TO_EXCLUSIVE(wrapper)) { in netagent_client_message_with_params()
2615 LIST_INSERT_HEAD(&wrapper->pending_triggers_list, new_pending_client, client_chain); in netagent_client_message_with_params()
2630 if (should_unlock_wrapper && wrapper != NULL) { in netagent_client_message_with_params()
2631 NETAGENT_UNLOCK(wrapper); in netagent_client_message_with_params()
2654 struct netagent_wrapper *wrapper = netagent_find_agent_with_uuid_and_lock(agent_uuid, true, false); in netagent_use() local
2655 if (wrapper == NULL) { in netagent_use()
2661 uint64_t current_count = wrapper->use_count; in netagent_use()
2662 wrapper->use_count++; in netagent_use()
2669 if (wrapper != NULL) { in netagent_use()
2670 NETAGENT_UNLOCK(wrapper); in netagent_use()
2682 …struct netagent_wrapper *wrapper = netagent_find_agent_with_uuid_and_lock(agent_uuid, false, false… in netagent_copyout() local
2683 if (wrapper == NULL) { in netagent_copyout()
2689 u_int32_t total_size = (sizeof(struct netagent) + wrapper->netagent->netagent_data_size); in netagent_copyout()
2696 u_int8_t *ptr = __unsafe_forge_bidi_indexable(u_int8_t *, wrapper->netagent, total_size); in netagent_copyout()
2701 if (wrapper != NULL) { in netagent_copyout()
2702 NETAGENT_UNLOCK(wrapper); in netagent_copyout()
2716 struct netagent_wrapper *wrapper = netagent_find_agent_with_uuid_and_lock(agent_uuid, true, false); in netagent_acquire_token() local
2717 if (wrapper == NULL) { in netagent_acquire_token()
2723 struct netagent_token *token = TAILQ_FIRST(&wrapper->token_list); in netagent_acquire_token()
2726 if (wrapper->token_low_water != 0) { in netagent_acquire_token()
2728 if (mach_absolute_time() >= wrapper->need_tokens_event_deadline) { in netagent_acquire_token()
2729 int event_error = netagent_send_tokens_needed(wrapper); in netagent_acquire_token()
2735 wrapper->need_tokens_event_deadline = deadline; in netagent_acquire_token()
2756 TAILQ_REMOVE(&wrapper->token_list, token, token_chain); in netagent_acquire_token()
2758 if (wrapper->token_count > 0) { in netagent_acquire_token()
2759 wrapper->token_count--; in netagent_acquire_token()
2761 if (wrapper->token_count < wrapper->token_low_water) { in netagent_acquire_token()
2762 (void)netagent_send_tokens_needed(wrapper); in netagent_acquire_token()
2765 if (wrapper != NULL) { in netagent_acquire_token()
2766 NETAGENT_UNLOCK(wrapper); in netagent_acquire_token()
2804 …struct netagent_wrapper *wrapper = netagent_find_agent_with_uuid_and_lock(agent_uuid, false, false… in netagent_trigger() local
2805 if (wrapper == NULL) { in netagent_trigger()
2811 if ((wrapper->netagent->netagent_flags & NETAGENT_FLAG_USER_ACTIVATED) == 0) { in netagent_trigger()
2818 if ((wrapper->netagent->netagent_flags & NETAGENT_FLAG_ACTIVE)) { in netagent_trigger()
2825 …error = netagent_send_trigger(wrapper, p, NETAGENT_TRIGGER_FLAG_USER, NETAGENT_MESSAGE_TYPE_TRIGGE… in netagent_trigger()
2828 if (wrapper != NULL) { in netagent_trigger()
2829 NETAGENT_UNLOCK(wrapper); in netagent_trigger()