Lines Matching refs:new_wrapper
763 struct netagent_wrapper *new_wrapper; in netagent_alloc_wrapper_memory() local
765 new_wrapper = kalloc_type(struct netagent_wrapper, in netagent_alloc_wrapper_memory()
767 new_wrapper->netagent = kalloc_data(sizeof(struct netagent) + data_size, in netagent_alloc_wrapper_memory()
770 lck_rw_init(&new_wrapper->agent_lock, &netagent_mtx_grp, LCK_ATTR_NULL); in netagent_alloc_wrapper_memory()
772 return new_wrapper; in netagent_alloc_wrapper_memory()
894 …agent_handle_register_inner(struct netagent_session *session, struct netagent_wrapper *new_wrapper) in netagent_handle_register_inner() argument
905 new_wrapper->control_unit = session->control_unit; in netagent_handle_register_inner()
906 new_wrapper->event_handler = session->event_handler; in netagent_handle_register_inner()
907 new_wrapper->event_context = session->event_context; in netagent_handle_register_inner()
908 new_wrapper->generation = g_next_generation++; in netagent_handle_register_inner()
910 session->wrapper = new_wrapper; in netagent_handle_register_inner()
911 LIST_INSERT_HEAD(&shared_netagent_list, new_wrapper, list_chain); in netagent_handle_register_inner()
912 TAILQ_INIT(&new_wrapper->token_list); in netagent_handle_register_inner()
913 LIST_INIT(&new_wrapper->pending_triggers_list); in netagent_handle_register_inner()
915 new_wrapper->netagent->netagent_flags |= NETAGENT_FLAG_REGISTERED; in netagent_handle_register_inner()
917 if (new_wrapper->netagent->netagent_flags & NETAGENT_FLAG_ACTIVE) { in netagent_handle_register_inner()
929 struct netagent_wrapper *new_wrapper = NULL; in netagent_register() local
950 new_wrapper = netagent_alloc_wrapper_memory(data_size); in netagent_register()
952 __nochk_memcpy(new_wrapper->netagent, agent, sizeof(struct netagent) + data_size); in netagent_register()
954 uuid_copy(registered_uuid, new_wrapper->netagent->netagent_uuid); in netagent_register()
956 errno_t error = netagent_handle_register_inner(session, new_wrapper); in netagent_register()
958 netagent_free_wrapper_memory(new_wrapper); in netagent_register()
972 struct netagent_wrapper *new_wrapper = NULL; in netagent_handle_register_setopt() local
1009 new_wrapper = netagent_alloc_wrapper_memory(data_size); in netagent_handle_register_setopt()
1011 __nochk_memcpy(new_wrapper->netagent, register_netagent, sizeof(struct netagent) + data_size); in netagent_handle_register_setopt()
1013 uuid_copy(registered_uuid, new_wrapper->netagent->netagent_uuid); in netagent_handle_register_setopt()
1015 response_error = netagent_handle_register_inner(session, new_wrapper); in netagent_handle_register_setopt()
1017 netagent_free_wrapper_memory(new_wrapper); in netagent_handle_register_setopt()
1033 struct netagent_wrapper *new_wrapper = NULL; in netagent_handle_register_message() local
1058 new_wrapper = netagent_alloc_wrapper_memory(data_size); in netagent_handle_register_message()
1061 new_wrapper->netagent); in netagent_handle_register_message()
1064 netagent_free_wrapper_memory(new_wrapper); in netagent_handle_register_message()
1069 uuid_copy(registered_uuid, new_wrapper->netagent->netagent_uuid); in netagent_handle_register_message()
1071 error = netagent_handle_register_inner(session, new_wrapper); in netagent_handle_register_message()
1074 netagent_free_wrapper_memory(new_wrapper); in netagent_handle_register_message()
1160 netagent_handle_update_inner(struct netagent_session *session, struct netagent_wrapper *new_wrapper, in netagent_handle_update_inner() argument
1182 …if (uuid_compare(session->wrapper->netagent->netagent_uuid, new_wrapper->netagent->netagent_uuid) … in netagent_handle_update_inner()
1183 memcmp(&session->wrapper->netagent->netagent_domain, &new_wrapper->netagent->netagent_domain, in netagent_handle_update_inner()
1184 sizeof(new_wrapper->netagent->netagent_domain)) != 0 || in netagent_handle_update_inner()
1185 memcmp(&session->wrapper->netagent->netagent_type, &new_wrapper->netagent->netagent_type, in netagent_handle_update_inner()
1186 sizeof(new_wrapper->netagent->netagent_type)) != 0) { in netagent_handle_update_inner()
1199 new_wrapper->netagent->netagent_flags |= NETAGENT_FLAG_REGISTERED; in netagent_handle_update_inner()
1200 if (session->wrapper->netagent->netagent_data_size == new_wrapper->netagent->netagent_data_size && in netagent_handle_update_inner()
1201 …memcmp(session->wrapper->netagent, new_wrapper->netagent, sizeof(struct netagent) + data_size) == … in netagent_handle_update_inner()
1222 …netagent_send_cellular_failed_event(new_wrapper, search_client->client_pid, search_client->client_… in netagent_handle_update_inner()
1231 new_wrapper->generation = g_next_generation++; in netagent_handle_update_inner()
1232 new_wrapper->use_count = session->wrapper->use_count; in netagent_handle_update_inner()
1234 TAILQ_INIT(&new_wrapper->token_list); in netagent_handle_update_inner()
1235 TAILQ_CONCAT(&new_wrapper->token_list, &session->wrapper->token_list, token_chain); in netagent_handle_update_inner()
1236 new_wrapper->token_count = session->wrapper->token_count; in netagent_handle_update_inner()
1237 new_wrapper->token_low_water = session->wrapper->token_low_water; in netagent_handle_update_inner()
1238 new_wrapper->last_client_error = session->wrapper->last_client_error; in netagent_handle_update_inner()
1239 new_wrapper->client_error_count = session->wrapper->client_error_count; in netagent_handle_update_inner()
1241 if ((new_wrapper->netagent->netagent_flags & NETAGENT_FLAG_ACTIVE) && in netagent_handle_update_inner()
1244 } else if (!(new_wrapper->netagent->netagent_flags & NETAGENT_FLAG_ACTIVE) && in netagent_handle_update_inner()
1253 session->wrapper = new_wrapper; in netagent_handle_update_inner()
1254 new_wrapper->control_unit = session->control_unit; in netagent_handle_update_inner()
1255 new_wrapper->event_handler = session->event_handler; in netagent_handle_update_inner()
1256 new_wrapper->event_context = session->event_context; in netagent_handle_update_inner()
1257 LIST_INSERT_HEAD(&shared_netagent_list, new_wrapper, list_chain); in netagent_handle_update_inner()
1258 LIST_INIT(&new_wrapper->pending_triggers_list); in netagent_handle_update_inner()
1273 struct netagent_wrapper *new_wrapper = NULL; in netagent_update() local
1294 new_wrapper = netagent_alloc_wrapper_memory(data_size); in netagent_update()
1296 __nochk_memcpy(new_wrapper->netagent, agent, sizeof(struct netagent) + data_size); in netagent_update()
1298 uuid_copy(updated_uuid, new_wrapper->netagent->netagent_uuid); in netagent_update()
1299 …should_update_immediately = (NETAGENT_FLAG_UPDATE_IMMEDIATELY == (new_wrapper->netagent->netagent_… in netagent_update()
1301 …errno_t error = netagent_handle_update_inner(session, new_wrapper, data_size, &agent_changed, kNet… in netagent_update()
1306 netagent_free_wrapper_memory(new_wrapper); in netagent_update()
1309 netagent_free_wrapper_memory(new_wrapper); in netagent_update()
1319 struct netagent_wrapper *new_wrapper = NULL; in netagent_handle_update_setopt() local
1358 new_wrapper = netagent_alloc_wrapper_memory(data_size); in netagent_handle_update_setopt()
1360 __nochk_memcpy(new_wrapper->netagent, update_netagent, sizeof(struct netagent) + data_size); in netagent_handle_update_setopt()
1362 uuid_copy(updated_uuid, new_wrapper->netagent->netagent_uuid); in netagent_handle_update_setopt()
1363 …should_update_immediately = (NETAGENT_FLAG_UPDATE_IMMEDIATELY == (new_wrapper->netagent->netagent_… in netagent_handle_update_setopt()
1365 …response_error = netagent_handle_update_inner(session, new_wrapper, data_size, &agent_changed, kNe… in netagent_handle_update_setopt()
1370 netagent_free_wrapper_memory(new_wrapper); in netagent_handle_update_setopt()
1373 netagent_free_wrapper_memory(new_wrapper); in netagent_handle_update_setopt()
1385 struct netagent_wrapper *new_wrapper = NULL; in netagent_handle_update_message() local
1412 new_wrapper = netagent_alloc_wrapper_memory(data_size); in netagent_handle_update_message()
1414 error = mbuf_copydata(packet, offset, sizeof(struct netagent) + data_size, new_wrapper->netagent); in netagent_handle_update_message()
1417 netagent_free_wrapper_memory(new_wrapper); in netagent_handle_update_message()
1422 uuid_copy(updated_uuid, new_wrapper->netagent->netagent_uuid); in netagent_handle_update_message()
1423 …should_update_immediately = (NETAGENT_FLAG_UPDATE_IMMEDIATELY == (new_wrapper->netagent->netagent_… in netagent_handle_update_message()
1425 …response_error = (u_int32_t)netagent_handle_update_inner(session, new_wrapper, data_size, &agent_c… in netagent_handle_update_message()
1430 netagent_free_wrapper_memory(new_wrapper); in netagent_handle_update_message()
1440 netagent_free_wrapper_memory(new_wrapper); in netagent_handle_update_message()