Changes between Version 13 and Version 14 of GpuWorkFetch

Timestamp:

Dec 26, 2008, 12:56:00 PM (15 years ago)

Author:

davea

Comment:

--

GpuWorkFetch

@@ -96 +96 @@
 shortfall += dt*(nidle_now)
 for each project p not backed off for this PRSC
-    add_proj_shortfall(p, dt)
-}}}
-------------
-'''prepare()''': called before exists_fetchable_project().
-sees if there's project to req from for this resource, and caches it
-
-'''bool exists_fetchable_project()''':
-there's a project we can ask for work for this resource
-
-'''select_project(priority, char buf)''':
-if the importance of getting work for this resource is P,
-chooses and returns a PROJECT to request work from,
-and a string to put in the request message
-Choose the project for which LTD + expected payoff is largest
-
-Values for priority:
- * DONT_NEED: no shortfalls
- * NEED: a shortfall, but no idle devices right now
- * NEED_NOW: idle devices right now
-
-'''runnable_resource_share()''': total resource share of projects with
-runnable jobs for this resource.
-
-'''get_priority()'''
-
-'''bool count_towards_share(PROJECT p)''':
-whether to count p's resource share in the total for this rsc
-== whether we've got a job of this type in last 30 days
-
-'''add_shortfall(PROJECT, dt)''':
-add x to this project's shortfall,
-where x = dt*(share - instances used)
-
-'''double total_share()''':
-total resource share of projects we're counting
+    p->PRSC_PROJECT_DATA.accumulate_shortfall(dt)
+}}}
+
+'''select_project()''':
+select the best project to request this type of work from.
+It's the project not backed off for this PRSC,
+and for which LTD + this->shortfall is largest
 
 '''accumulate_debt(dt)''':
@@ -160 +132 @@
 '''double shortfall'''
 
+'''accumulate_shortfall(dt)'''
+{{{
+shortfall += dt*(share - instances_used)
+}}}
+
 === debt accounting ===
 {{{
@@ -185 +162 @@
 
 {{{
-send_req(p)
-        switch cpu_work_fetch.priority
-                case DONT_NEED
-                        set no_cpu in req message
-                case NEED, NEED_NOW:
-                        work_req_sec = p.cpu_shortfall
-                        ncpus_idle = p.max_idle_cpus
-        switch cuda_work_fetch.priority
-                case DONT_NEED
-                        set no_cuda in the req message
-                case NEED, NEED_NOW:
+if cuda_work_fetch.nidle
+   cpu_work_fetch.shortfall = 0
+   p = cuda_work_fetch.select_project()
+   if p
+      send_req(p)
+      return
+if cpu_work_fetch.nidle
+   cuda_work_fetch.shortfall = 0
+   p = cpu_work_fetch.select_project()
+   if p
+      send_req(p)
+      return
+if cuda_work_fetch.shortfall
+   p = cuda_work_fetch.select_project()
+   if p
+      send_req(p)
+      return
+if cpu_work_fetch.shortfall
+   p = cpu_work_fetch.select_project()
+   if p
+      send_req(p)
+      return
+
+void send_req(p)
+   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