提交 c08d7424 编写于 作者: A Andreas Färber

cpus: Pass CPUState to qemu_cpu_kick()

CPUArchState is no longer needed there.
Signed-off-by: NAndreas Färber <afaerber@suse.de>
上级 d5a68146
...@@ -661,7 +661,7 @@ void run_on_cpu(CPUArchState *env, void (*func)(void *data), void *data) ...@@ -661,7 +661,7 @@ void run_on_cpu(CPUArchState *env, void (*func)(void *data), void *data)
wi.next = NULL; wi.next = NULL;
wi.done = false; wi.done = false;
qemu_cpu_kick(env); qemu_cpu_kick(cpu);
while (!wi.done) { while (!wi.done) {
CPUArchState *self_env = cpu_single_env; CPUArchState *self_env = cpu_single_env;
...@@ -870,11 +870,8 @@ static void qemu_cpu_kick_thread(CPUState *cpu) ...@@ -870,11 +870,8 @@ static void qemu_cpu_kick_thread(CPUState *cpu)
#endif #endif
} }
void qemu_cpu_kick(void *_env) void qemu_cpu_kick(CPUState *cpu)
{ {
CPUArchState *env = _env;
CPUState *cpu = ENV_GET_CPU(env);
qemu_cond_broadcast(cpu->halt_cond); qemu_cond_broadcast(cpu->halt_cond);
if (!tcg_enabled() && !cpu->thread_kicked) { if (!tcg_enabled() && !cpu->thread_kicked) {
qemu_cpu_kick_thread(cpu); qemu_cpu_kick_thread(cpu);
...@@ -950,7 +947,7 @@ void pause_all_vcpus(void) ...@@ -950,7 +947,7 @@ void pause_all_vcpus(void)
while (penv) { while (penv) {
CPUState *pcpu = ENV_GET_CPU(penv); CPUState *pcpu = ENV_GET_CPU(penv);
pcpu->stop = true; pcpu->stop = true;
qemu_cpu_kick(penv); qemu_cpu_kick(pcpu);
penv = penv->next_cpu; penv = penv->next_cpu;
} }
...@@ -971,7 +968,7 @@ void pause_all_vcpus(void) ...@@ -971,7 +968,7 @@ void pause_all_vcpus(void)
qemu_cond_wait(&qemu_pause_cond, &qemu_global_mutex); qemu_cond_wait(&qemu_pause_cond, &qemu_global_mutex);
penv = first_cpu; penv = first_cpu;
while (penv) { while (penv) {
qemu_cpu_kick(penv); qemu_cpu_kick(ENV_GET_CPU(penv));
penv = penv->next_cpu; penv = penv->next_cpu;
} }
} }
...@@ -986,7 +983,7 @@ void resume_all_vcpus(void) ...@@ -986,7 +983,7 @@ void resume_all_vcpus(void)
CPUState *pcpu = ENV_GET_CPU(penv); CPUState *pcpu = ENV_GET_CPU(penv);
pcpu->stop = false; pcpu->stop = false;
pcpu->stopped = false; pcpu->stopped = false;
qemu_cpu_kick(penv); qemu_cpu_kick(pcpu);
penv = penv->next_cpu; penv = penv->next_cpu;
} }
} }
......
...@@ -1704,7 +1704,7 @@ static void tcg_handle_interrupt(CPUArchState *env, int mask) ...@@ -1704,7 +1704,7 @@ static void tcg_handle_interrupt(CPUArchState *env, int mask)
* case its halted. * case its halted.
*/ */
if (!qemu_cpu_is_self(cpu)) { if (!qemu_cpu_is_self(cpu)) {
qemu_cpu_kick(env); qemu_cpu_kick(cpu);
return; return;
} }
......
...@@ -206,7 +206,7 @@ static void ppc970_set_irq(void *opaque, int pin, int level) ...@@ -206,7 +206,7 @@ static void ppc970_set_irq(void *opaque, int pin, int level)
} else { } else {
LOG_IRQ("%s: restart the CPU\n", __func__); LOG_IRQ("%s: restart the CPU\n", __func__);
env->halted = 0; env->halted = 0;
qemu_cpu_kick(env); qemu_cpu_kick(CPU(cpu));
} }
break; break;
case PPC970_INPUT_HRESET: case PPC970_INPUT_HRESET:
...@@ -335,7 +335,7 @@ static void ppc40x_set_irq(void *opaque, int pin, int level) ...@@ -335,7 +335,7 @@ static void ppc40x_set_irq(void *opaque, int pin, int level)
} else { } else {
LOG_IRQ("%s: restart the CPU\n", __func__); LOG_IRQ("%s: restart the CPU\n", __func__);
env->halted = 0; env->halted = 0;
qemu_cpu_kick(env); qemu_cpu_kick(CPU(cpu));
} }
break; break;
case PPC40x_INPUT_DEBUG: case PPC40x_INPUT_DEBUG:
......
...@@ -115,7 +115,7 @@ static void spin_kick(void *data) ...@@ -115,7 +115,7 @@ static void spin_kick(void *data)
env->halted = 0; env->halted = 0;
env->exception_index = -1; env->exception_index = -1;
cpu->stopped = false; cpu->stopped = false;
qemu_cpu_kick(env); qemu_cpu_kick(cpu);
} }
static void spin_write(void *opaque, hwaddr addr, uint64_t value, static void spin_write(void *opaque, hwaddr addr, uint64_t value,
......
...@@ -163,6 +163,7 @@ static void rtas_start_cpu(sPAPREnvironment *spapr, ...@@ -163,6 +163,7 @@ static void rtas_start_cpu(sPAPREnvironment *spapr,
uint32_t nret, target_ulong rets) uint32_t nret, target_ulong rets)
{ {
target_ulong id, start, r3; target_ulong id, start, r3;
CPUState *cpu;
CPUPPCState *env; CPUPPCState *env;
if (nargs != 3 || nret != 1) { if (nargs != 3 || nret != 1) {
...@@ -175,6 +176,8 @@ static void rtas_start_cpu(sPAPREnvironment *spapr, ...@@ -175,6 +176,8 @@ static void rtas_start_cpu(sPAPREnvironment *spapr,
r3 = rtas_ld(args, 2); r3 = rtas_ld(args, 2);
for (env = first_cpu; env; env = env->next_cpu) { for (env = first_cpu; env; env = env->next_cpu) {
cpu = ENV_GET_CPU(env);
if (env->cpu_index != id) { if (env->cpu_index != id) {
continue; continue;
} }
...@@ -194,7 +197,7 @@ static void rtas_start_cpu(sPAPREnvironment *spapr, ...@@ -194,7 +197,7 @@ static void rtas_start_cpu(sPAPREnvironment *spapr,
env->gpr[3] = r3; env->gpr[3] = r3;
env->halted = 0; env->halted = 0;
qemu_cpu_kick(env); qemu_cpu_kick(cpu);
rtas_st(rets, 0, 0); rtas_st(rets, 0, 0);
return; return;
......
...@@ -259,7 +259,7 @@ static void cpu_kick_irq(SPARCCPU *cpu) ...@@ -259,7 +259,7 @@ static void cpu_kick_irq(SPARCCPU *cpu)
env->halted = 0; env->halted = 0;
cpu_check_irqs(env); cpu_check_irqs(env);
qemu_cpu_kick(env); qemu_cpu_kick(CPU(cpu));
} }
static void cpu_set_irq(void *opaque, int irq, int level) static void cpu_set_irq(void *opaque, int irq, int level)
......
...@@ -317,7 +317,7 @@ static void cpu_kick_irq(SPARCCPU *cpu) ...@@ -317,7 +317,7 @@ static void cpu_kick_irq(SPARCCPU *cpu)
env->halted = 0; env->halted = 0;
cpu_check_irqs(env); cpu_check_irqs(env);
qemu_cpu_kick(env); qemu_cpu_kick(CPU(cpu));
} }
static void cpu_set_ivec_irq(void *opaque, int irq, int level) static void cpu_set_ivec_irq(void *opaque, int irq, int level)
......
...@@ -95,6 +95,14 @@ void cpu_reset(CPUState *cpu); ...@@ -95,6 +95,14 @@ void cpu_reset(CPUState *cpu);
*/ */
bool qemu_cpu_is_self(CPUState *cpu); bool qemu_cpu_is_self(CPUState *cpu);
/**
* qemu_cpu_kick:
* @cpu: The vCPU to kick.
*
* Kicks @cpu's thread.
*/
void qemu_cpu_kick(CPUState *cpu);
/** /**
* cpu_is_stopped: * cpu_is_stopped:
* @cpu: The CPU to check. * @cpu: The CPU to check.
......
...@@ -833,7 +833,7 @@ static void kvm_handle_interrupt(CPUArchState *env, int mask) ...@@ -833,7 +833,7 @@ static void kvm_handle_interrupt(CPUArchState *env, int mask)
env->interrupt_request |= mask; env->interrupt_request |= mask;
if (!qemu_cpu_is_self(cpu)) { if (!qemu_cpu_is_self(cpu)) {
qemu_cpu_kick(env); qemu_cpu_kick(cpu);
} }
} }
......
...@@ -324,7 +324,6 @@ void cpu_save(QEMUFile *f, void *opaque); ...@@ -324,7 +324,6 @@ void cpu_save(QEMUFile *f, void *opaque);
int cpu_load(QEMUFile *f, void *opaque, int version_id); int cpu_load(QEMUFile *f, void *opaque, int version_id);
/* Unblock cpu */ /* Unblock cpu */
void qemu_cpu_kick(void *env);
void qemu_cpu_kick_self(void); void qemu_cpu_kick_self(void);
/* work queue */ /* work queue */
......
...@@ -76,9 +76,8 @@ static QEMUTimer *idle_timer; ...@@ -76,9 +76,8 @@ static QEMUTimer *idle_timer;
static void kvm_kick_cpu(void *opaque) static void kvm_kick_cpu(void *opaque)
{ {
PowerPCCPU *cpu = opaque; PowerPCCPU *cpu = opaque;
CPUPPCState *env = &cpu->env;
qemu_cpu_kick(env); qemu_cpu_kick(CPU(cpu));
} }
int kvm_arch_init(KVMState *s) int kvm_arch_init(KVMState *s)
......
...@@ -403,7 +403,7 @@ static int s390_cpu_restart(S390CPU *cpu) ...@@ -403,7 +403,7 @@ static int s390_cpu_restart(S390CPU *cpu)
kvm_s390_interrupt(env, KVM_S390_RESTART, 0); kvm_s390_interrupt(env, KVM_S390_RESTART, 0);
s390_add_running_cpu(env); s390_add_running_cpu(env);
qemu_cpu_kick(env); qemu_cpu_kick(CPU(cpu));
dprintf("DONE: SIGP cpu restart: %p\n", env); dprintf("DONE: SIGP cpu restart: %p\n", env);
return 0; return 0;
} }
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册