Changes between Version 15 and Version 16 of AppCoprocessor

Timestamp:

Aug 15, 2008, 8:08:50 AM (16 years ago)

Author:

davea

Comment:

--

AppCoprocessor

@@ -22 +22 @@
 To deploy it:
 
- * Choose a "planning class" name for the program, say "cuda_1.1" (see below).
- * Create an [UpdateVersions app version].  Include a file '''app_plan''' containing "cuda_1.1".
+ * Choose a "planning class" name for the program, say "cuda" (see below).
+ * Create an [UpdateVersions app version].  Include a file '''app_plan''' containing "cuda".
  * Link the following function into your scheduler:
 {{{
-bool app_plan(SCHEDULER_REQUEST& sreq, const char* plan_class, HOST_USAGE& hu) {
-    // clients before 6.1.11 don't understand plan_class
-    //
-    int v = sreq.core_client_major_version*10000
-        + sreq.core_client_minor_version*100
-        + sreq.core_client_release;
-    if (v < 60111) return false;
+bool app_plan(SCHEDULER_REQUEST& sreq, char* plan_class, HOST_USAGE& hu) {
+    if (!strcmp(plan_class, "mt")) {
+        // the following is for an app that can use anywhere
+        // from 1 to 64 threads, can control this exactly,
+        // and whose speedup is .95N
+        // (so on a uniprocessor, we'll use a sequential app
+        // if one is available)
+        //
+        int ncpus, nthreads;
+        bool bounded;
 
-    if (!strcmp(plan_class, "cuda_1.1")) {
-         // the following is for an app that uses a CUDA GPU
+        get_ncpus(sreq, ncpus, bounded);
+        nthreads = ncpus;
+        if (nthreads > 64) nthreads = 64;
+        hu.avg_ncpus = nthreads;
+        hu.max_ncpus = nthreads;
+        sprintf(hu.cmdline, "--nthreads %d", nthreads);
+        hu.flops = 0.95*sreq.host.p_fpops*nthreads;
+        return true;
+    } else if (!strcmp(plan_class, "cuda")) {
+        // the following is for an app that uses a CUDA GPU
         // and some CPU also, and gets 50 GFLOPS total
         //
         for (unsigned int i=0; i<sreq.coprocs.coprocs.size(); i++) {
             COPROC* cp = sreq.coprocs.coprocs[i];
-            if (!strcmp(cp->name, "CUDA")) {
-                COPROC* cu = new COPROC;
-                strcpy(cu->name, cp->name);
+            if (!strcmp(cp->type, "CUDA")) {
+                COPROC* cu = new COPROC (cp->type);
                 cu->count = 1;
                 hu.coprocs.coprocs.push_back(cu);
@@ -53 +63 @@
             }
         }
+        if (config.debug_version_select) {
+            log_messages.printf(MSG_DEBUG,
+                "Host lacks CUDA coprocessor for plan class %s\n", plan_class
+            );
+        }
         return false;
     }
+    log_messages.printf(MSG_CRITICAL,
+        "Unknown plan class: %s\n", plan_class
+    );
     return false;
 }
+
 }}}
 == Questions ==