Lines Matching refs:new_wrapper
807 struct netagent_wrapper *new_wrapper; in netagent_alloc_wrapper_memory() local
809 new_wrapper = kalloc_type(struct netagent_wrapper, in netagent_alloc_wrapper_memory()
811 new_wrapper->netagent = kalloc_data(sizeof(struct netagent) + data_size, in netagent_alloc_wrapper_memory()
814 lck_rw_init(&new_wrapper->agent_lock, &netagent_mtx_grp, LCK_ATTR_NULL); in netagent_alloc_wrapper_memory()
816 return new_wrapper; in netagent_alloc_wrapper_memory()
938 …agent_handle_register_inner(struct netagent_session *session, struct netagent_wrapper *new_wrapper) in netagent_handle_register_inner() argument
949 new_wrapper->control_unit = session->control_unit; in netagent_handle_register_inner()
950 new_wrapper->event_handler = session->event_handler; in netagent_handle_register_inner()
951 new_wrapper->event_context = session->event_context; in netagent_handle_register_inner()
952 new_wrapper->generation = g_next_generation++; in netagent_handle_register_inner()
954 session->wrapper = new_wrapper; in netagent_handle_register_inner()
955 LIST_INSERT_HEAD(&shared_netagent_list, new_wrapper, list_chain); in netagent_handle_register_inner()
956 TAILQ_INIT(&new_wrapper->token_list); in netagent_handle_register_inner()
957 LIST_INIT(&new_wrapper->pending_triggers_list); in netagent_handle_register_inner()
959 new_wrapper->netagent->netagent_flags |= NETAGENT_FLAG_REGISTERED; in netagent_handle_register_inner()
961 if (new_wrapper->netagent->netagent_flags & NETAGENT_FLAG_ACTIVE) { in netagent_handle_register_inner()
973 struct netagent_wrapper *new_wrapper = NULL; in netagent_register() local
994 new_wrapper = netagent_alloc_wrapper_memory(data_size); in netagent_register()
996 __nochk_memcpy(new_wrapper->netagent, agent, sizeof(struct netagent)); in netagent_register()
997 __nochk_memcpy(netagent_get_data(new_wrapper->netagent), netagent_get_data(agent), data_size); in netagent_register()
999 uuid_copy(registered_uuid, new_wrapper->netagent->netagent_uuid); in netagent_register()
1001 errno_t error = netagent_handle_register_inner(session, new_wrapper); in netagent_register()
1003 netagent_free_wrapper_memory(new_wrapper); in netagent_register()
1017 struct netagent_wrapper *new_wrapper = NULL; in netagent_handle_register_setopt() local
1054 new_wrapper = netagent_alloc_wrapper_memory(data_size); in netagent_handle_register_setopt()
1056 __nochk_memcpy(new_wrapper->netagent, register_netagent, sizeof(struct netagent)); in netagent_handle_register_setopt()
1057 …__nochk_memcpy(netagent_get_data(new_wrapper->netagent), netagent_get_data(register_netagent), dat… in netagent_handle_register_setopt()
1059 uuid_copy(registered_uuid, new_wrapper->netagent->netagent_uuid); in netagent_handle_register_setopt()
1061 response_error = netagent_handle_register_inner(session, new_wrapper); in netagent_handle_register_setopt()
1063 netagent_free_wrapper_memory(new_wrapper); in netagent_handle_register_setopt()
1079 struct netagent_wrapper *new_wrapper = NULL; in netagent_handle_register_message() local
1104 new_wrapper = netagent_alloc_wrapper_memory(data_size); in netagent_handle_register_message()
1107 new_wrapper->netagent); in netagent_handle_register_message()
1110 netagent_free_wrapper_memory(new_wrapper); in netagent_handle_register_message()
1115 uuid_copy(registered_uuid, new_wrapper->netagent->netagent_uuid); in netagent_handle_register_message()
1117 error = netagent_handle_register_inner(session, new_wrapper); in netagent_handle_register_message()
1120 netagent_free_wrapper_memory(new_wrapper); in netagent_handle_register_message()
1206 netagent_handle_update_inner(struct netagent_session *session, struct netagent_wrapper *new_wrapper, in netagent_handle_update_inner() argument
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()
1230 sizeof(new_wrapper->netagent->netagent_domain)) != 0 || in netagent_handle_update_inner()
1231 memcmp(&session->wrapper->netagent->netagent_type, &new_wrapper->netagent->netagent_type, in netagent_handle_update_inner()
1232 sizeof(new_wrapper->netagent->netagent_type)) != 0) { in netagent_handle_update_inner()
1245 new_wrapper->netagent->netagent_flags |= NETAGENT_FLAG_REGISTERED; 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()
1269 …netagent_send_cellular_failed_event(new_wrapper, search_client->client_pid, search_client->client_… in netagent_handle_update_inner()
1278 new_wrapper->generation = g_next_generation++; in netagent_handle_update_inner()
1279 new_wrapper->use_count = session->wrapper->use_count; in netagent_handle_update_inner()
1281 TAILQ_INIT(&new_wrapper->token_list); 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()
1288 if ((new_wrapper->netagent->netagent_flags & NETAGENT_FLAG_ACTIVE) && in netagent_handle_update_inner()
1291 } else if (!(new_wrapper->netagent->netagent_flags & NETAGENT_FLAG_ACTIVE) && in netagent_handle_update_inner()
1300 session->wrapper = new_wrapper; in netagent_handle_update_inner()
1301 new_wrapper->control_unit = session->control_unit; in netagent_handle_update_inner()
1302 new_wrapper->event_handler = session->event_handler; in netagent_handle_update_inner()
1303 new_wrapper->event_context = session->event_context; in netagent_handle_update_inner()
1304 LIST_INSERT_HEAD(&shared_netagent_list, new_wrapper, list_chain); in netagent_handle_update_inner()
1305 LIST_INIT(&new_wrapper->pending_triggers_list); in netagent_handle_update_inner()
1320 struct netagent_wrapper *new_wrapper = NULL; in netagent_update() local
1341 new_wrapper = netagent_alloc_wrapper_memory(data_size); in netagent_update()
1343 __nochk_memcpy(new_wrapper->netagent, agent, sizeof(struct netagent)); in netagent_update()
1344 __nochk_memcpy(netagent_get_data(new_wrapper->netagent), netagent_get_data(agent), data_size); in netagent_update()
1346 uuid_copy(updated_uuid, new_wrapper->netagent->netagent_uuid); in netagent_update()
1347 …should_update_immediately = (NETAGENT_FLAG_UPDATE_IMMEDIATELY == (new_wrapper->netagent->netagent_… in netagent_update()
1349 …errno_t error = netagent_handle_update_inner(session, new_wrapper, data_size, &agent_changed, kNet… in netagent_update()
1354 netagent_free_wrapper_memory(new_wrapper); in netagent_update()
1357 netagent_free_wrapper_memory(new_wrapper); in netagent_update()
1367 struct netagent_wrapper *new_wrapper = NULL; in netagent_handle_update_setopt() local
1406 new_wrapper = netagent_alloc_wrapper_memory(data_size); in netagent_handle_update_setopt()
1408 __nochk_memcpy(new_wrapper->netagent, update_netagent, sizeof(struct netagent)); in netagent_handle_update_setopt()
1409 …__nochk_memcpy(netagent_get_data(new_wrapper->netagent), netagent_get_data(update_netagent), data_… in netagent_handle_update_setopt()
1411 uuid_copy(updated_uuid, new_wrapper->netagent->netagent_uuid); in netagent_handle_update_setopt()
1412 …should_update_immediately = (NETAGENT_FLAG_UPDATE_IMMEDIATELY == (new_wrapper->netagent->netagent_… in netagent_handle_update_setopt()
1414 …response_error = netagent_handle_update_inner(session, new_wrapper, data_size, &agent_changed, kNe… in netagent_handle_update_setopt()
1419 netagent_free_wrapper_memory(new_wrapper); in netagent_handle_update_setopt()
1422 netagent_free_wrapper_memory(new_wrapper); in netagent_handle_update_setopt()
1434 struct netagent_wrapper *new_wrapper = NULL; in netagent_handle_update_message() local
1461 new_wrapper = netagent_alloc_wrapper_memory(data_size); in netagent_handle_update_message()
1463 error = mbuf_copydata(packet, offset, sizeof(struct netagent) + data_size, new_wrapper->netagent); in netagent_handle_update_message()
1466 netagent_free_wrapper_memory(new_wrapper); in netagent_handle_update_message()
1471 uuid_copy(updated_uuid, new_wrapper->netagent->netagent_uuid); in netagent_handle_update_message()
1472 …should_update_immediately = (NETAGENT_FLAG_UPDATE_IMMEDIATELY == (new_wrapper->netagent->netagent_… in netagent_handle_update_message()
1474 …response_error = (u_int32_t)netagent_handle_update_inner(session, new_wrapper, data_size, &agent_c… in netagent_handle_update_message()
1479 netagent_free_wrapper_memory(new_wrapper); in netagent_handle_update_message()
1489 netagent_free_wrapper_memory(new_wrapper); in netagent_handle_update_message()