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

- scheduler: if anonymous platform, ignore coprocessor requests 

(since anonymous platforms apps are treated as CPU)

svn path=/trunk/boinc/; revision=17011
This commit is contained in:
David Anderson 2009-01-24 21:51:19 +00:00
parent 3edb52ed5b
commit db8f15e396
3 changed files with 25 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
checkin_notes
View File

@ -715,3 +715,11 @@ David 23 Jan 2009
sched/
handle_request.cpp
David 23 Jan 2009
- scheduler: if anonymous platform, ignore coprocessor requests
(since anonymous platforms apps are treated as CPU)
sched/
sched_send.cpp
server_types.h

23
sched/sched_send.cpp
View File

@ -158,6 +158,7 @@ BEST_APP_VERSION* get_app_version(WORKUNIT& wu) {
// if we previously chose a CUDA app but don't need more CUDA work,
// reset pointer and see if there's another app
// TODO: this is wrong; delete the record and fall through
//
if (g_wreq->rsc_spec_request
&& bavp->host_usage.cuda_instances() > 0
@ -179,7 +180,7 @@ BEST_APP_VERSION* get_app_version(WORKUNIT& wu) {
bavp = new BEST_APP_VERSION;
bavp->appid = wu.appid;
if (anonymous(g_request->platforms.list[0])) {
if (g_wreq->anonymous_platform) {
found = g_request->has_version(*app);
if (!found) {
if (config.debug_send) {
@ -506,7 +507,7 @@ double estimate_duration(WORKUNIT& wu, BEST_APP_VERSION& bav) {
}
if (config.debug_send) {
log_messages.printf(MSG_NORMAL,
"[send] est. duration for WU %d: unscaled %f scaled %f\n",
"[send] est. duration for WU %d: unscaled %.2f scaled %.2f\n",
wu.id, edu, ed
);
}
@ -749,9 +750,8 @@ static inline int check_deadline(
if (diff > 0) {
if (config.debug_send) {
log_messages.printf(MSG_NORMAL,
"[send] [WU#%d %s] est report delay %d on [HOST#%d]; delay_bound is %d\n",
wu.id, wu.name, (int)est_report_delay,
g_reply->host.id, wu.delay_bound
"[send] [WU#%d] deadline miss %d > %d\n",
wu.id, (int)est_report_delay, wu.delay_bound
);
}
g_reply->wreq.speed.set_insufficient(diff);
@ -1535,9 +1535,16 @@ void send_work() {
g_wreq->seconds_to_fill = clamp_req_sec(g_request->work_req_seconds);
g_wreq->cpu_req_secs = clamp_req_sec(g_request->cpu_req_secs);
g_wreq->cpu_req_instances = g_request->cpu_req_instances;
if (coproc_cuda) {
g_wreq->cuda_req_secs = clamp_req_sec(coproc_cuda->req_secs);
g_wreq->cuda_req_instances = coproc_cuda->req_instances;
g_wreq->anonymous_platform = anonymous(g_request->platforms.list[0]);
// if anonymous platform, ignore coprocessor requests
// since app versions are assumed to be CPU
//
if (!g_wreq->anonymous_platform) {
if (coproc_cuda) {
g_wreq->cuda_req_secs = clamp_req_sec(coproc_cuda->req_secs);
g_wreq->cuda_req_instances = coproc_cuda->req_instances;
}
}
if (g_wreq->cpu_req_secs || g_wreq->cuda_req_secs) {
g_wreq->rsc_spec_request = true;

2
sched/server_types.h
View File

@ -103,6 +103,8 @@ struct BEST_APP_VERSION {
// Note: this is zeroed out in SCHEDULER_REPLY constructor
//
struct WORK_REQ {
bool anonymous_platform;
// Flags used by old-style scheduling,
// while making multiple passes through the work array
bool infeasible_only;