Changeset 1c6e1ec for libcfa/src

Timestamp:

Mar 22, 2021, 5:28:35 PM (4 years ago)

Author:

Thierry Delisle <tdelisle@…>

Branches:

ADT, arm-eh, ast-experimental, enum, forall-pointer-decay, jacob/cs343-translation, master, new-ast-unique-expr, pthread-emulation, qualifiedEnum

Children:

357fae8

Parents:

304de00

Message:

Cforall now uses CFA_DEFAULT_PREEMPTION environment variable to override the default preemption.

File:

• libcfa/src/concurrency/preemption.cfa (modified) (3 diffs)

libcfa/src/concurrency/preemption.cfa

@@ -15 +15 @@
 
 #define __cforall_thread__
+// #define __CFA_DEBUG_PRINT_PREEMPTION__
 
 #include "preemption.hfa"
@@ -28 +29 @@
 #include "kernel_private.hfa"
 
+
 #if !defined(__CFA_DEFAULT_PREEMPTION__)
 #define __CFA_DEFAULT_PREEMPTION__ 10`ms
 #endif
 
-Duration default_preemption() __attribute__((weak)) {
-        return __CFA_DEFAULT_PREEMPTION__;
+__attribute__((weak)) Duration default_preemption() {
+        const char * preempt_rate_s = getenv("CFA_DEFAULT_PROCESSORS");
+        if(!preempt_rate_s) {
+                __cfadbg_print_safe(preemption, "No CFA_DEFAULT_PROCESSORS in ENV\n");
+                return __CFA_DEFAULT_PREEMPTION__;
+        }
+
+        char * endptr = 0p;
+        long int preempt_rate_l = strtol(preempt_rate_s, &endptr, 10);
+        if(preempt_rate_l < 0 || preempt_rate_l > 65535) {
+                __cfadbg_print_safe(preemption, "CFA_DEFAULT_PROCESSORS out of range : %ld\n", preempt_rate_l);
+                return __CFA_DEFAULT_PREEMPTION__;
+        }
+        if('\0' != *endptr) {
+                __cfadbg_print_safe(preemption, "CFA_DEFAULT_PROCESSORS not a decimal number : %s\n", preempt_rate_s);
+                return __CFA_DEFAULT_PREEMPTION__;
+        }
+
+        return preempt_rate_l`ms;
 }
 
@@ -125 +144 @@
         // If there are still alarms pending, reset the timer
         if( & (*alarms)`first ) {
-                __cfadbg_print_buffer_decl(preemption, " KERNEL: @%ju(%ju) resetting alarm to %ju.\n", currtime.tv, __kernel_get_time().tv, (alarms->head->alarm - currtime).tv);
                 Duration delta = (*alarms)`first.alarm - currtime;
                 Duration capped = max(delta, 50`us);
-                // itimerval tim  = { caped };
-                // __cfaabi_dbg_print_buffer_local( "    Values are %lu, %lu, %lu %lu.\n", delta.tv, caped.tv, tim.it_value.tv_sec, tim.it_value.tv_usec);
-
                 __kernel_set_timer( capped );
         }