github/acrn-hypervisor
1
0
Fork 0
mirror of https://github.com/projectacrn/acrn-hypervisor.git synced 2025-09-22 09:17:58 +00:00
Code Issues Projects Releases Wiki Activity

hv: sched: add sleep/wake for thread object

Browse Source 
sleep one thread_object means to prevent it from being scheduled.
wake one thread_object is an opposite operation of sleep.
This patch also add notify_mode in thread_object to indicate how to
deliver the request.

Tracked-On: #3813
Signed-off-by: Jason Chen CJ <jason.cj.chen@intel.com>
Signed-off-by: Yu Wang <yu1.wang@intel.com>
Signed-off-by: Shuo A Liu <shuo.a.liu@intel.com>
Acked-by: Eddie Dong <eddie.dong@intel.com>
This commit is contained in:
Shuo A Liu
2019-06-14 13:10:05 +08:00
committed by ACRN System Integration
parent 9b8c6e6a90
commit 27163df9b1
3 changed files with 45 additions and 26 deletions
Download Patch File Download Diff File Expand all files Collapse all files

33
hypervisor/arch/x86/guest/vcpu.c
View File

@@ -670,46 +670,25 @@ void pause_vcpu(struct acrn_vcpu *vcpu, enum vcpu_state new_state)
pr_dbg("vcpu%hu paused, new state: %d",
vcpu->vcpu_id, new_state);
get_schedule_lock(pcpu_id);
vcpu->prev_state = vcpu->state;
vcpu->state = new_state;
if (vcpu->running) {
remove_thread_obj(&vcpu->thread_obj, pcpu_id);
if (is_lapic_pt_enabled(vcpu)) {
make_reschedule_request(pcpu_id, DEL_MODE_INIT);
} else {
make_reschedule_request(pcpu_id, DEL_MODE_IPI);
sleep_thread(&vcpu->thread_obj);
if (pcpu_id != get_pcpu_id()) {
while (vcpu->running) {
asm_pause();
}
release_schedule_lock(pcpu_id);
if (pcpu_id != get_pcpu_id()) {
while (vcpu->running) {
asm_pause();
}
}
} else {
remove_thread_obj(&vcpu->thread_obj, pcpu_id);
release_schedule_lock(pcpu_id);
}
}
void resume_vcpu(struct acrn_vcpu *vcpu)
{
uint16_t pcpu_id = pcpuid_from_vcpu(vcpu);
pr_dbg("vcpu%hu resumed", vcpu->vcpu_id);
get_schedule_lock(pcpu_id);
vcpu->state = vcpu->prev_state;
if (vcpu->state == VCPU_RUNNING) {
insert_thread_obj(&vcpu->thread_obj, pcpu_id);
make_reschedule_request(pcpu_id, DEL_MODE_IPI);
wake_thread(&vcpu->thread_obj);
}
release_schedule_lock(pcpu_id);
}
/* TODO:
@@ -777,6 +756,8 @@ int32_t prepare_vcpu(struct acrn_vm *vm, uint16_t pcpu_id)
vcpu->thread_obj.sched_ctl = &per_cpu(sched_ctl, pcpu_id);
vcpu->thread_obj.thread_entry = vcpu_thread;
vcpu->thread_obj.pcpu_id = pcpu_id;
vcpu->thread_obj.notify_mode = is_lapic_pt_enabled(vcpu) ?
SCHED_NOTIFY_INIT : SCHED_NOTIFY_IPI;
vcpu->thread_obj.host_sp = build_stack_frame(vcpu);
vcpu->thread_obj.switch_out = context_switch_out;
vcpu->thread_obj.switch_in = context_switch_in;