mirror of https://github.com/BOINC/boinc.git
*** empty log message ***
svn path=/trunk/boinc/; revision=4868
This commit is contained in:
parent
a3368bbf65
commit
f1d1077c17
|
@ -21400,3 +21400,14 @@ David 16 Dec 2004
|
||||||
team_change_founder_action.php (new)
|
team_change_founder_action.php (new)
|
||||||
team_change_founder_form.php (new)
|
team_change_founder_form.php (new)
|
||||||
team_manage.php
|
team_manage.php
|
||||||
|
|
||||||
|
David 16 Dec 2004
|
||||||
|
- transitioner: if a result times out, update the hosts'
|
||||||
|
avg_turnaround (charge it with the full delay bound)
|
||||||
|
- scheduler: print work_req_seconds as a double, not int
|
||||||
|
|
||||||
|
db/
|
||||||
|
boinc_db.C,h
|
||||||
|
sched/
|
||||||
|
sched_send.C
|
||||||
|
transitioner.C
|
||||||
|
|
|
@ -727,7 +727,7 @@ int send_work(
|
||||||
|
|
||||||
log_messages.printf(
|
log_messages.printf(
|
||||||
SCHED_MSG_LOG::NORMAL,
|
SCHED_MSG_LOG::NORMAL,
|
||||||
"[HOST#%d] got request for %d seconds of work; available disk %f GB\n",
|
"[HOST#%d] got request for %f seconds of work; available disk %f GB\n",
|
||||||
reply.host.id, sreq.work_req_seconds, wreq.disk_available/1e9
|
reply.host.id, sreq.work_req_seconds, wreq.disk_available/1e9
|
||||||
);
|
);
|
||||||
|
|
||||||
|
|
|
@ -62,6 +62,21 @@ int result_suffix(char* name) {
|
||||||
return 0;
|
return 0;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// The given result just timed out.
|
||||||
|
// update the host's avg_turnaround.
|
||||||
|
//
|
||||||
|
int penalize_host(int hostid, double delay_bound) {
|
||||||
|
DB_HOST host;
|
||||||
|
int retval = host.lookup_id(hostid);
|
||||||
|
if (retval) return retval;
|
||||||
|
if (host.avg_turnaround == 0) {
|
||||||
|
host.avg_turnaround = delay_bound;
|
||||||
|
} else {
|
||||||
|
host.avg_turnaround = .7*host.avg_turnaround + .3*delay_bound;
|
||||||
|
}
|
||||||
|
return host.update();
|
||||||
|
}
|
||||||
|
|
||||||
int handle_wu(
|
int handle_wu(
|
||||||
DB_TRANSITIONER_ITEM_SET& transitioner,
|
DB_TRANSITIONER_ITEM_SET& transitioner,
|
||||||
std::vector<TRANSITIONER_ITEM>& items
|
std::vector<TRANSITIONER_ITEM>& items
|
||||||
|
@ -121,6 +136,7 @@ int handle_wu(
|
||||||
res_item.res_name, retval
|
res_item.res_name, retval
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
|
penalize_host(res_item.res_hostid, wu_item.delay_bound);
|
||||||
nover++;
|
nover++;
|
||||||
} else {
|
} else {
|
||||||
ninprogress++;
|
ninprogress++;
|
||||||
|
|
Loading…
Reference in New Issue