Rooba
/
boinc
mirror of https://github.com/BOINC/boinc.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

- client: fix bug that can cause no GPU jobs to be scheduled 

even when a GPU is free

svn path=/trunk/boinc/; revision=17329
This commit is contained in:
David Anderson 2009-02-21 01:09:29 +00:00
parent 3b31a9d803
commit 7c77fa14f3
2 changed files with 14 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
checkin_notes
View File

@ -1820,3 +1820,10 @@ David 20 Feb 2009
client/ client/
log_flags.cpp,h log_flags.cpp,h
work_fetch.cpp,h work_fetch.cpp,h
David 20 Feb 2009
- client: fix bug that can cause no GPU jobs to be scheduled
even when a GPU is free
client/
cpu_sched.cpp

28
client/cpu_sched.cpp
View File

@ -456,23 +456,11 @@ struct PROC_RESOURCES {
// should we consider scheduling this job? // should we consider scheduling this job?
// //
bool can_schedule(RESULT* rp, ACTIVE_TASK* atp) { bool can_schedule(RESULT* rp) {
if (rp->uses_coprocs()) { if (rp->uses_coprocs()) {
if (gstate.user_active && !gstate.global_prefs.run_gpu_if_user_active) { if (gstate.user_active && !gstate.global_prefs.run_gpu_if_user_active) {
return false; return false;
} }
// if it uses coprocs, and they're available, yes
//
if (atp && atp->coprocs_reserved) {
if (log_flags.cpu_sched_debug) {
msg_printf(rp->project, MSG_INFO,
"[cpu_sched_debug] already reserved coprocessors for %s", rp->name
);
}
return true;
}
if (coprocs.sufficient_coprocs( if (coprocs.sufficient_coprocs(
rp->avp->coprocs, log_flags.cpu_sched_debug, "cpu_sched_debug") rp->avp->coprocs, log_flags.cpu_sched_debug, "cpu_sched_debug")
) { ) {
@ -536,11 +524,9 @@ static bool schedule_if_possible(
"[cpu_sched_debug] scheduling %s", rp->name "[cpu_sched_debug] scheduling %s", rp->name
); );
} }
if (!atp || !atp->coprocs_reserved) { proc_rsc.coprocs.reserve_coprocs(
proc_rsc.coprocs.reserve_coprocs( rp->avp->coprocs, rp, log_flags.cpu_sched_debug, "cpu_sched_debug"
rp->avp->coprocs, rp, log_flags.cpu_sched_debug, "cpu_sched_debug" );
);
}
proc_rsc.ncpus_used += rp->avp->avg_ncpus; proc_rsc.ncpus_used += rp->avp->avg_ncpus;
if (rp->uses_coprocs()) { if (rp->uses_coprocs()) {
proc_rsc.ncoproc_jobs--; proc_rsc.ncoproc_jobs--;
@ -564,7 +550,7 @@ void CLIENT_STATE::schedule_cpus() {
proc_rsc.ncpus = ncpus; proc_rsc.ncpus = ncpus;
proc_rsc.ncpus_used = 0; proc_rsc.ncpus_used = 0;
proc_rsc.ram_left = available_ram(); proc_rsc.ram_left = available_ram();
proc_rsc.coprocs.clone(coprocs, true); proc_rsc.coprocs.clone(coprocs, false);
proc_rsc.ncoproc_jobs = 0; proc_rsc.ncoproc_jobs = 0;
if (log_flags.cpu_sched_debug) { if (log_flags.cpu_sched_debug) {
@ -610,7 +596,7 @@ void CLIENT_STATE::schedule_cpus() {
rp->already_selected = true; rp->already_selected = true;
atp = lookup_active_task_by_result(rp); atp = lookup_active_task_by_result(rp);
if (!proc_rsc.can_schedule(rp, atp)) continue; if (!proc_rsc.can_schedule(rp)) continue;
if (!schedule_if_possible(rp, atp, proc_rsc, rrs, expected_payoff)) continue; if (!schedule_if_possible(rp, atp, proc_rsc, rrs, expected_payoff)) continue;
rp->project->deadlines_missed--; rp->project->deadlines_missed--;
@ -628,7 +614,7 @@ void CLIENT_STATE::schedule_cpus() {
rp = largest_debt_project_best_result(); rp = largest_debt_project_best_result();
if (!rp) break; if (!rp) break;
atp = lookup_active_task_by_result(rp); atp = lookup_active_task_by_result(rp);
if (!proc_rsc.can_schedule(rp, atp)) continue; if (!proc_rsc.can_schedule(rp)) continue;
if (!schedule_if_possible(rp, atp, proc_rsc, rrs, expected_payoff)) continue; if (!schedule_if_possible(rp, atp, proc_rsc, rrs, expected_payoff)) continue;
ordered_scheduled_results.push_back(rp); ordered_scheduled_results.push_back(rp);
} }