Changes between Version 14 and Version 15 of GpuWorkFetch

Timestamp:

Dec 26, 2008, 1:09:10 PM (15 years ago)

Author:

davea

Comment:

--

GpuWorkFetch

@@ -186 +186 @@
 
 void send_req(p)
-   req.cpu_req_seconds = cpu_work_fetch.shortfall;
+   req.cpu_req_seconds = cpu_work_fetch.shortfall
    req.cpu_req_ninstances = cpu_work_fetch.nidle
-   req.cuda_req_seconds = cuda_work_fetch.shortfall;
-
-for prior = NEED_NOW, NEED
-        for each coproc C (in decreasing order of importance)
-        p = C.work_fetch.select_proj(prior, msg);
-                if p
-                        put msg in req message
-                        send_req(p)
-                        return
-                else 
-        p = cpu_work_fetch(prior)
-                if p
-                        send_req(p)
-                        return
+   req.cuda_req_seconds = cuda_work_fetch.shortfall
+   req.cuda_req_ninstances = cuda_work_fetch.nidle
+   req.work_req_seconds = max(req.cpu_req_seconds, req.cuda_req_seconds)
+
 }}}
 
 === Handling scheduler reply ===
 
-if request.
+if no jobs returned
+   double backoff for each requested PRSC
 
 == Scheduler changes ==
 {{{
 global vars
-        have_cpu_app_versions
-        have_cuda_app_versions
+   have_cpu_app_versions
+   have_cuda_app_versions
 per-req vars
-        bool coproc_request
-        ncpu_jobs_sending
-        ncuda_jobs_sending
-        ncpu_seconds_to_fill
-        ncuda_seconds_to_fill
-        seconds_to_fill
-                (backwards compat; used if !coproc_request)
+   bool coproc_request
+   ncpu_jobs_sending
+   ncuda_jobs_sending
+   ncpu_seconds_to_fill
+   ncuda_seconds_to_fill
+   seconds_to_fill
+      (backwards compat; used if !coproc_request)
 overall startup
-        scan app versions, set have_x vars
+   scan app versions, set have_x vars
 req startup
-        if send_only_cpu and no CPU app versions, don't send work
-        if send_only_cuda and no CUDA app versions, don't send work
+   if send_only_cpu and no CPU app versions, don't send work
+   if send_only_cuda and no CUDA app versions, don't send work
 work_needed()
-        need_more_cpu_jobs =
-                n_cpu_jobs_sending < ninstances_cpu
-                or cpu_seconds_to_fill > 0
-        same for cuda
-        return false if don't need more CPU or more CUDA
+   need_more_cpu_jobs =
+      n_cpu_jobs_sending < ninstances_cpu
+      or cpu_seconds_to_fill > 0
+   same for cuda
+   return false if don't need more CPU or more CUDA
 get_app_version
-        if send_only_cpu, ignore CUDA versions
-        if send_only_cuda, ignore CPU versions
+   if send_only_cpu, ignore CUDA versions
+   if send_only_cuda, ignore CPU versions
 when commit a job
-        update n*_jobs_sending,
-                n*_seconds_to_fill,
-                seconds_to_fill
-}}}
+   update n*_jobs_sending,
+      n*_seconds_to_fill,
+      seconds_to_fill
+}}}