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

- scheduler: revise [21428] to include non-anonymous-platform, 

and change the ratio limit from 2 to 10.


svn path=/trunk/boinc/; revision=24217
This commit is contained in:
David Anderson 2011-09-15 06:53:01 +00:00
parent 49a7287949
commit a4cccec2cc
3 changed files with 36 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
checkin_notes
View File

@ -6081,3 +6081,11 @@ David 14 Sept 2011
sched/
sched_customize.cpp
David 14 Sept 2011
- scheduler: revise [21428] to include non-anonymous-platform,
and change the ratio limit from 2 to 10.
sched/
sched_send.cpp
sched_version.cpp

2
sched/sched_send.cpp
View File

@ -1042,7 +1042,7 @@ bool work_needed(bool locality_sched) {
return false;
}
#if 1
#if 0
if (config.debug_send) {
log_messages.printf(MSG_NORMAL,
"[send] work_needed: spec req %d sec to fill %.2f; CPU (%.2f, %.2f) CUDA (%.2f, %.2f) ATI(%.2f, %.2f)\n",

32
sched/sched_version.cpp
View File

@ -235,6 +235,11 @@ CLIENT_APP_VERSION* get_app_version_anonymous(
return best;
}
#define ET_RATIO_LIMIT 10.
// if the FLOPS estimate based on elapsed time
// exceeds project_flops by more than this factor, cap it.
// The host may have received a bunch of short jobs recently
// input:
// cav.host_usage.projected_flops
// This is the <flops> specified in app_info.xml
@ -288,17 +293,19 @@ void estimate_flops_anon_platform() {
//
double new_flops = 1./havp->et.get_avg();
// cap this at 2*projected,
// cap this at ET_RATIO_LIMIT*projected,
// in case we've had a bunch of short jobs recently
//
if (new_flops > 2*cav.host_usage.projected_flops) {
if (new_flops > ET_RATIO_LIMIT*cav.host_usage.projected_flops) {
if (config.debug_version_select) {
log_messages.printf(MSG_NORMAL,
"[version] (%s) capping new_flops; %f > 2*%f\n",
cav.plan_class, new_flops, cav.host_usage.projected_flops
"[version] (%s) capping new_flops; %.1fG > %.0f*%.1fG\n",
cav.plan_class, new_flops/1e9,
ET_RATIO_LIMIT,
cav.host_usage.projected_flops/1e9
);
}
new_flops = 2*cav.host_usage.projected_flops;
new_flops = ET_RATIO_LIMIT*cav.host_usage.projected_flops;
}
cav.rsc_fpops_scale = cav.host_usage.projected_flops/new_flops;
cav.host_usage.projected_flops = new_flops;
@ -330,7 +337,22 @@ void estimate_flops(HOST_USAGE& hu, APP_VERSION& av) {
DB_HOST_APP_VERSION* havp = gavid_to_havp(av.id);
if (havp && havp->et.n > MIN_HOST_SAMPLES) {
double new_flops = 1./havp->et.get_avg();
// cap this at ET_RATIO_LIMIT*projected,
// in case we've had a bunch of short jobs recently
//
if (new_flops > ET_RATIO_LIMIT*hu.projected_flops) {
if (config.debug_version_select) {
log_messages.printf(MSG_NORMAL,
"[version] (%s) capping new_flops; %.1fG > %.0f*%.1fG\n",
av.plan_class, new_flops/1e9,
ET_RATIO_LIMIT,
hu.projected_flops/1e9
);
}
new_flops = ET_RATIO_LIMIT*hu.projected_flops;
}
hu.projected_flops = new_flops;
if (config.debug_version_select) {
log_messages.printf(MSG_NORMAL,
"[version] [AV#%d] (%s) setting projected flops based on host elapsed time avg: %.2fG\n",