From nobody Thu Nov 6 20:37:52 2025 Delivered-To: importer@patchew.org Received-SPF: pass (zoho.com: domain of gnu.org designates 208.118.235.17 as permitted sender) client-ip=208.118.235.17; envelope-from=qemu-devel-bounces+importer=patchew.org@nongnu.org; helo=lists.gnu.org; Authentication-Results: mx.zoho.com; spf=pass (zoho.com: domain of gnu.org designates 208.118.235.17 as permitted sender) smtp.mailfrom=qemu-devel-bounces+importer=patchew.org@nongnu.org; Return-Path: Received: from lists.gnu.org (lists.gnu.org [208.118.235.17]) by mx.zohomail.com with SMTPS id 1487748108185487.3286763516767; Tue, 21 Feb 2017 23:21:48 -0800 (PST) Received: from localhost ([::1]:50394 helo=lists.gnu.org) by lists.gnu.org with esmtp (Exim 4.71) (envelope-from ) id 1cgRF9-0008VF-P0 for importer@patchew.org; Wed, 22 Feb 2017 02:21:43 -0500 Received: from eggs.gnu.org ([2001:4830:134:3::10]:38339) by lists.gnu.org with esmtp (Exim 4.71) (envelope-from ) id 1cgQVI-0003HP-C0 for qemu-devel@nongnu.org; Wed, 22 Feb 2017 01:34:23 -0500 Received: from Debian-exim by eggs.gnu.org with spam-scanned (Exim 4.71) (envelope-from ) id 1cgQVD-0008G2-Db for qemu-devel@nongnu.org; Wed, 22 Feb 2017 01:34:20 -0500 Received: from ozlabs.org ([2401:3900:2:1::2]:41989) by eggs.gnu.org with esmtps (TLS1.0:DHE_RSA_AES_256_CBC_SHA1:32) (Exim 4.71) (envelope-from ) id 1cgQVC-0008Ce-IG; Wed, 22 Feb 2017 01:34:15 -0500 Received: by ozlabs.org (Postfix, from userid 1007) id 3vSndM4ky3z9s7c; Wed, 22 Feb 2017 17:33:57 +1100 (AEDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/simple; d=gibson.dropbear.id.au; s=201602; t=1487745239; bh=aj8Sg906VEP1uTei1CwmEZu0i18+YUgPGZtOpuYXpyI=; h=From:To:Cc:Subject:Date:In-Reply-To:References:From; b=P7elMVYe7L2fOIv6T77vV47gXZ55kQ1TMJDyO7fj8eHSobpxQyBS6cWj3ev9DPicu CBXdw6HZCVzDXNUzwNLPSHhFoCq2BVsT2kjiRScNzF1mA8TSVbs9901dZhrIK7npVE MMhUaX8FXIp0L+5nHg7mrviLPSVW5eWC5UKjPC0w= From: David Gibson To: peter.maydell@linaro.org Date: Wed, 22 Feb 2017 17:33:42 +1100 Message-Id: <20170222063348.32176-38-david@gibson.dropbear.id.au> X-Mailer: git-send-email 2.9.3 In-Reply-To: <20170222063348.32176-1-david@gibson.dropbear.id.au> References: <20170222063348.32176-1-david@gibson.dropbear.id.au> X-detected-operating-system: by eggs.gnu.org: Genre and OS details not recognized. X-Received-From: 2401:3900:2:1::2 Subject: [Qemu-devel] [PULL 37/43] spapr: reuse machine->possible_cpus instead of cores[] X-BeenThere: qemu-devel@nongnu.org X-Mailman-Version: 2.1.21 Precedence: list List-Id: List-Unsubscribe: , List-Archive: List-Post: List-Help: List-Subscribe: , Cc: lvivier@redhat.com, thuth@redhat.com, qemu-devel@nongnu.org, mdroth@linux.vnet.ibm.com, agraf@suse.de, qemu-ppc@nongnu.org, imammedo@redhat.com, David Gibson Errors-To: qemu-devel-bounces+importer=patchew.org@nongnu.org Sender: "Qemu-devel" X-ZohoMail: RSF_0 Z_629925259 SPT_0 Content-Transfer-Encoding: quoted-printable MIME-Version: 1.0 Content-Type: text/plain; charset="utf-8" From: Igor Mammedov Replace SPAPR specific cores[] array with generic machine->possible_cpus and store core objects there. It makes cores bookkeeping similar to x86 cpus and will allow to unify similar code. It would allow to replace cpu_index based NUMA node mapping with iproperty based one (for -device created cores) since possible_cpus carries board defined topology/layout. Signed-off-by: Igor Mammedov Acked-by: David Gibson Signed-off-by: David Gibson --- hw/ppc/spapr.c | 129 ++++++++++++++++++++++++++++++++++-----------= ---- include/hw/ppc/spapr.h | 1 - 2 files changed, 90 insertions(+), 40 deletions(-) diff --git a/hw/ppc/spapr.c b/hw/ppc/spapr.c index 37cb338..a0aa69e 100644 --- a/hw/ppc/spapr.c +++ b/hw/ppc/spapr.c @@ -1751,13 +1751,28 @@ static void spapr_validate_node_memory(MachineState= *machine, Error **errp) } } =20 +/* find cpu slot in machine->possible_cpus by core_id */ +static CPUArchId *spapr_find_cpu_slot(MachineState *ms, uint32_t id, int *= idx) +{ + int index =3D id / smp_threads; + + if (index >=3D ms->possible_cpus->len) { + return NULL; + } + if (idx) { + *idx =3D index; + } + return &ms->possible_cpus->cpus[index]; +} + static void spapr_init_cpus(sPAPRMachineState *spapr) { MachineState *machine =3D MACHINE(spapr); MachineClass *mc =3D MACHINE_GET_CLASS(machine); char *type =3D spapr_get_cpu_core_type(machine->cpu_model); int smt =3D kvmppc_smt_threads(); - int spapr_max_cores, spapr_cores; + const CPUArchIdList *possible_cpus; + int boot_cores_nr =3D smp_cpus / smp_threads; int i; =20 if (!type) { @@ -1765,6 +1780,7 @@ static void spapr_init_cpus(sPAPRMachineState *spapr) exit(1); } =20 + possible_cpus =3D mc->possible_cpu_arch_ids(machine); if (mc->query_hotpluggable_cpus) { if (smp_cpus % smp_threads) { error_report("smp_cpus (%u) must be multiple of threads (%u)", @@ -1776,21 +1792,15 @@ static void spapr_init_cpus(sPAPRMachineState *spap= r) max_cpus, smp_threads); exit(1); } - - spapr_max_cores =3D max_cpus / smp_threads; - spapr_cores =3D smp_cpus / smp_threads; } else { if (max_cpus !=3D smp_cpus) { error_report("This machine version does not support CPU hotplu= g"); exit(1); } - - spapr_max_cores =3D QEMU_ALIGN_UP(smp_cpus, smp_threads) / smp_thr= eads; - spapr_cores =3D spapr_max_cores; + boot_cores_nr =3D possible_cpus->len; } =20 - spapr->cores =3D g_new0(Object *, spapr_max_cores); - for (i =3D 0; i < spapr_max_cores; i++) { + for (i =3D 0; i < possible_cpus->len; i++) { int core_id =3D i * smp_threads; =20 if (mc->query_hotpluggable_cpus) { @@ -1802,7 +1812,7 @@ static void spapr_init_cpus(sPAPRMachineState *spapr) qemu_register_reset(spapr_drc_reset, drc); } =20 - if (i < spapr_cores) { + if (i < boot_cores_nr) { Object *core =3D object_new(type); int nr_threads =3D smp_threads; =20 @@ -2491,10 +2501,11 @@ void *spapr_populate_hotplug_cpu_dt(CPUState *cs, i= nt *fdt_offset, static void spapr_core_unplug(HotplugHandler *hotplug_dev, DeviceState *de= v, Error **errp) { - sPAPRMachineState *spapr =3D SPAPR_MACHINE(qdev_get_machine()); + MachineState *ms =3D MACHINE(qdev_get_machine()); CPUCore *cc =3D CPU_CORE(dev); + CPUArchId *core_slot =3D spapr_find_cpu_slot(ms, cc->core_id, NULL); =20 - spapr->cores[cc->core_id / smp_threads] =3D NULL; + core_slot->cpu =3D NULL; object_unparent(OBJECT(dev)); } =20 @@ -2510,19 +2521,24 @@ static void spapr_core_unplug_request(HotplugHandler *hotplug_dev, DeviceState *d= ev, Error **errp) { - CPUCore *cc =3D CPU_CORE(dev); - int smt =3D kvmppc_smt_threads(); - int index =3D cc->core_id / smp_threads; - sPAPRDRConnector *drc =3D - spapr_dr_connector_by_id(SPAPR_DR_CONNECTOR_TYPE_CPU, index * smt); + int index; + sPAPRDRConnector *drc; sPAPRDRConnectorClass *drck; Error *local_err =3D NULL; + CPUCore *cc =3D CPU_CORE(dev); + int smt =3D kvmppc_smt_threads(); =20 + if (!spapr_find_cpu_slot(MACHINE(hotplug_dev), cc->core_id, &index)) { + error_setg(errp, "Unable to find CPU core with core-id: %d", + cc->core_id); + return; + } if (index =3D=3D 0) { error_setg(errp, "Boot CPU core may not be unplugged"); return; } =20 + drc =3D spapr_dr_connector_by_id(SPAPR_DR_CONNECTOR_TYPE_CPU, index * = smt); g_assert(drc); =20 drck =3D SPAPR_DR_CONNECTOR_GET_CLASS(drc); @@ -2547,11 +2563,17 @@ static void spapr_core_plug(HotplugHandler *hotplug= _dev, DeviceState *dev, Error *local_err =3D NULL; void *fdt =3D NULL; int fdt_offset =3D 0; - int index =3D cc->core_id / smp_threads; int smt =3D kvmppc_smt_threads(); + CPUArchId *core_slot; + int index; =20 + core_slot =3D spapr_find_cpu_slot(MACHINE(hotplug_dev), cc->core_id, &= index); + if (!core_slot) { + error_setg(errp, "Unable to find CPU core with core-id: %d", + cc->core_id); + return; + } drc =3D spapr_dr_connector_by_id(SPAPR_DR_CONNECTOR_TYPE_CPU, index * = smt); - spapr->cores[index] =3D OBJECT(dev); =20 g_assert(drc || !mc->query_hotpluggable_cpus); =20 @@ -2568,7 +2590,6 @@ static void spapr_core_plug(HotplugHandler *hotplug_d= ev, DeviceState *dev, drck->attach(drc, dev, fdt, fdt_offset, !dev->hotplugged, &local_e= rr); if (local_err) { g_free(fdt); - spapr->cores[index] =3D NULL; error_propagate(errp, local_err); return; } @@ -2590,6 +2611,7 @@ static void spapr_core_plug(HotplugHandler *hotplug_d= ev, DeviceState *dev, drck->set_isolation_state(drc, SPAPR_DR_ISOLATION_STATE_UNISOL= ATED); } } + core_slot->cpu =3D OBJECT(dev); } =20 static void spapr_core_pre_plug(HotplugHandler *hotplug_dev, DeviceState *= dev, @@ -2597,13 +2619,12 @@ static void spapr_core_pre_plug(HotplugHandler *hot= plug_dev, DeviceState *dev, { MachineState *machine =3D MACHINE(OBJECT(hotplug_dev)); MachineClass *mc =3D MACHINE_GET_CLASS(hotplug_dev); - sPAPRMachineState *spapr =3D SPAPR_MACHINE(OBJECT(hotplug_dev)); - int spapr_max_cores =3D max_cpus / smp_threads; - int index; Error *local_err =3D NULL; CPUCore *cc =3D CPU_CORE(dev); char *base_core_type =3D spapr_get_cpu_core_type(machine->cpu_model); const char *type =3D object_get_typename(OBJECT(dev)); + CPUArchId *core_slot; + int index; =20 if (dev->hotplugged && !mc->query_hotpluggable_cpus) { error_setg(&local_err, "CPU hotplug not supported for this machine= "); @@ -2620,13 +2641,13 @@ static void spapr_core_pre_plug(HotplugHandler *hot= plug_dev, DeviceState *dev, goto out; } =20 - index =3D cc->core_id / smp_threads; - if (index < 0 || index >=3D spapr_max_cores) { + core_slot =3D spapr_find_cpu_slot(MACHINE(hotplug_dev), cc->core_id, &= index); + if (!core_slot) { error_setg(&local_err, "core id %d out of range", cc->core_id); goto out; } =20 - if (spapr->cores[index]) { + if (core_slot->cpu) { error_setg(&local_err, "core %d already populated", cc->core_id); goto out; } @@ -2758,29 +2779,58 @@ static unsigned spapr_cpu_index_to_socket_id(unsign= ed cpu_index) return cpu_index / smp_threads / smp_cores; } =20 +static const CPUArchIdList *spapr_possible_cpu_arch_ids(MachineState *mach= ine) +{ + int i; + int spapr_max_cores =3D max_cpus / smp_threads; + MachineClass *mc =3D MACHINE_GET_CLASS(machine); + + if (!mc->query_hotpluggable_cpus) { + spapr_max_cores =3D QEMU_ALIGN_UP(smp_cpus, smp_threads) / smp_thr= eads; + } + if (machine->possible_cpus) { + assert(machine->possible_cpus->len =3D=3D spapr_max_cores); + return machine->possible_cpus; + } + + machine->possible_cpus =3D g_malloc0(sizeof(CPUArchIdList) + + sizeof(CPUArchId) * spapr_max_cores); + machine->possible_cpus->len =3D spapr_max_cores; + for (i =3D 0; i < machine->possible_cpus->len; i++) { + int core_id =3D i * smp_threads; + + machine->possible_cpus->cpus[i].arch_id =3D core_id; + machine->possible_cpus->cpus[i].props.has_core_id =3D true; + machine->possible_cpus->cpus[i].props.core_id =3D core_id; + /* TODO: add 'has_node/node' here to describe + to which node core belongs */ + } + return machine->possible_cpus; +} + static HotpluggableCPUList *spapr_query_hotpluggable_cpus(MachineState *ma= chine) { int i; + Object *cpu; HotpluggableCPUList *head =3D NULL; - sPAPRMachineState *spapr =3D SPAPR_MACHINE(machine); - int spapr_max_cores =3D max_cpus / smp_threads; + const char *cpu_type; =20 - for (i =3D 0; i < spapr_max_cores; i++) { + cpu =3D machine->possible_cpus->cpus[0].cpu; + assert(cpu); /* Boot cpu is always present */ + cpu_type =3D object_get_typename(cpu); + for (i =3D 0; i < machine->possible_cpus->len; i++) { HotpluggableCPUList *list_item =3D g_new0(typeof(*list_item), 1); HotpluggableCPU *cpu_item =3D g_new0(typeof(*cpu_item), 1); - CpuInstanceProperties *cpu_props =3D g_new0(typeof(*cpu_props), 1); =20 - cpu_item->type =3D spapr_get_cpu_core_type(machine->cpu_model); - cpu_item->vcpus_count =3D smp_threads; - cpu_props->has_core_id =3D true; - cpu_props->core_id =3D i * smp_threads; - /* TODO: add 'has_node/node' here to describe - to which node core belongs */ + cpu_item->type =3D g_strdup(cpu_type); + cpu_item->vcpus_count =3D smp_threads; // TODO: ??? generalize + cpu_item->props =3D g_memdup(&machine->possible_cpus->cpus[i].prop= s, + sizeof(*cpu_item->props)); =20 - cpu_item->props =3D cpu_props; - if (spapr->cores[i]) { + cpu =3D machine->possible_cpus->cpus[i].cpu; + if (cpu) { cpu_item->has_qom_path =3D true; - cpu_item->qom_path =3D object_get_canonical_path(spapr->cores[= i]); + cpu_item->qom_path =3D object_get_canonical_path(cpu); } list_item->value =3D cpu_item; list_item->next =3D head; @@ -2872,6 +2922,7 @@ static void spapr_machine_class_init(ObjectClass *oc,= void *data) hc->plug =3D spapr_machine_device_plug; hc->unplug =3D spapr_machine_device_unplug; mc->cpu_index_to_socket_id =3D spapr_cpu_index_to_socket_id; + mc->possible_cpu_arch_ids =3D spapr_possible_cpu_arch_ids; hc->unplug_request =3D spapr_machine_device_unplug_request; =20 smc->dr_lmb_enabled =3D true; diff --git a/include/hw/ppc/spapr.h b/include/hw/ppc/spapr.h index a2d8964..f9b17d8 100644 --- a/include/hw/ppc/spapr.h +++ b/include/hw/ppc/spapr.h @@ -94,7 +94,6 @@ struct sPAPRMachineState { /*< public >*/ char *kvm_type; MemoryHotplugState hotplug_memory; - Object **cores; }; =20 #define H_SUCCESS 0 --=20 2.9.3