Changes between Version 33 and Version 34 of CreditNew

Timestamp:

Mar 26, 2010, 4:59:13 PM (15 years ago)

Author:

davea

Comment:

--

CreditNew

@@ -347 +347 @@
 
 {{{
- pfc = peak FLOP count(J)
- approx = true;
- if pfc > wu.fpops_bound
-   host_app_version.scale_probation = true
-   host_app_version.error_rate = initial value  // replicate for a while
-   if app.min_avg_pfc is defined
-     F = app.min_avg_pfc * wu.fpops_est
-   else
-     F = wu.fpops_est
- else
-   if job is anonymous platform
-     if app.min_avg_pfc is defined
-       if host_app_version.pfc_avg is above sample threshold
-            and not host_app_version.scale_probation
-         F = app.min_avg_pfc / host_app_version.pfc_avg
-         approx = false
-       else
-         F = app.min_avg_pfc * wu.fpops_est
-     else
-       F = wu.fpops_est
-   else
-     F = pfc;
-         host_scale = 0
-     if host_app_version.pfc_avg is above sample threshold
-          and not host_app_version.scale_probation
-           host_scale = min(10, app_version.pfc_avg / host_app_version.pfc_avg)
-     if app_version.pfc_scale is defined
-       F *= app_version.pfc_scale
-           if host_scale
-         F *= host_scale
-         approx = false
-     else
-           if host_scale
-         F *= host_scale
-         app_version.pfc_avg.update(F)
-         host_app_version.pfc_avg.update(F)
+double claimed_pfc(J, double& f, bool& approx):
+        pfc = peak FLOP count(J)
+        approx = true;
+        if no app version info (relic of old scheduler)
+                F = wu.fpops_est
+                return
+        if pfc > wu.fpops_bound
+                host_app_version.scale_probation = true
+                host_app_version.error_rate = initial value     // replicate for a while
+                if app.min_avg_pfc is defined
+                        F = app.min_avg_pfc * wu.fpops_est
+                else
+                        F = wu.fpops_est
+        else
+                if job is anonymous platform
+                        if app.min_avg_pfc is defined
+                                if host_app_version.pfc_avg is above sample threshold
+                                                 and not host_app_version.scale_probation
+                                        F *= app.min_avg_pfc / host_app_version.pfc_avg
+                                        approx = false
+                                else
+                                        F = app.min_avg_pfc * wu.fpops_est
+                        else
+                                F = wu.fpops_est
+                else
+                        F = pfc;
+                        host_scale = 0
+                        if host_app_version.pfc_avg is above sample threshold
+                                        and app_version.pfc is above sample threshold
+                                        and not host_app_version.scale_probation
+                                        and host_app_version.pfc_avg <> 0
+                                host_scale = app_version.pfc_avg / host_app_version.pfc_avg
+                                if (host_scale) > 10
+                                        host_scale = 10
+                        if app_version.pfc_scale is defined
+                                F *= app_version.pfc_scale
+                                if host_scale
+                                        F *= host_scale
+                                        approx = false
+                        else
+                                if host_scale
+                                        F *= host_scale
+                        app_version.pfc_avg.update(pfc)
+                host_app_version.pfc_avg.update(pfc)
+                (host_app_version.et.update(elapsed time))
+                (host_app_version.turnaround.update(turnaround time))
 }}}
 
@@ -400 +410 @@
 
 {{{
- if app.min_avg_pfc is defined
-   C = app.min_avg_pfc*wu.fpops_est*cobblestone_scale
- else
-   C = wu.fpops_est * cobblestone_scale
+if app.min_avg_pfc is defined
+        C = app.min_avg_pfc*wu.fpops_est*cobblestone_scale
+else
+        C = wu.fpops_est * cobblestone_scale
 }}}
 
@@ -555 +565 @@
 
 Unrelated to the credit proposal, but in a similar spirit.
-The server will maintain ET^mean^(H, V), the statistics of
+The server will maintain host_app_version.et,
+the statistics (mean and variance) of
 job runtimes (normalized by wu.fpops_est) per
 host and application version.
@@ -561 +572 @@
 The server's estimate of a job's runtime is then
 
- R(J, H) = wu.fpops_est * ET^mean^(H, V)
+ R(J, H) = wu.fpops_est * host_app_version.et.avg
 
 == Implementation ==