Changeset 82ff5845 for src/libcfa/concurrency/alarm.c

Timestamp:

Jun 8, 2017, 1:48:12 PM (7 years ago)

Author:

Thierry Delisle <tdelisle@…>

Branches:

ADT, aaron-thesis, arm-eh, ast-experimental, cleanup-dtors, deferred_resn, demangler, enum, forall-pointer-decay, jacob/cs343-translation, jenkins-sandbox, master, new-ast, new-ast-unique-expr, new-env, no_list, persistent-indexer, pthread-emulation, qualifiedEnum, resolv-new, with_gc

Children:

a724ac1

Parents:

8b8152e

Message:

First implementation of preemption, does not appear to work with scheduling

File:

• src/libcfa/concurrency/alarm.c (modified) (4 diffs)

src/libcfa/concurrency/alarm.c

@@ -16 +16 @@
 
 extern "C" {
+#include <errno.h>
+#include <stdio.h>
+#include <string.h>
 #include <time.h>
+#include <unistd.h>
 #include <sys/time.h>
 }
@@ -22 +26 @@
 #include "alarm.h"
 #include "kernel_private.h"
+#include "libhdr.h"
 #include "preemption.h"
 
@@ -31 +36 @@
         timespec curr;
         clock_gettime( CLOCK_REALTIME, &curr );
-        return ((__cfa_time_t)curr.tv_sec * TIMEGRAN) + curr.tv_nsec;
+        __cfa_time_t curr_time = ((__cfa_time_t)curr.tv_sec * TIMEGRAN) + curr.tv_nsec;
+        LIB_DEBUG_DO(
+                char text[256];
+                __attribute__((unused)) int len = snprintf( text, 256, "Kernel : current time is %lu\n", curr_time );
+                LIB_DEBUG_WRITE( STDERR_FILENO, text, len );
+        );
+        return curr_time;
 }
 
 void __kernel_set_timer( __cfa_time_t alarm ) {
+
+        LIB_DEBUG_DO(
+                char text[256];
+                __attribute__((unused)) int len = snprintf( text, 256, "Kernel : set timer to %lu\n", (__cfa_time_t)alarm );
+                LIB_DEBUG_WRITE( STDERR_FILENO, text, len );
+        );
+
         itimerval val;
         val.it_value.tv_sec = alarm / TIMEGRAN;                 // seconds
@@ -128 +146 @@
         lock( &systemProcessor->alarm_lock );
         {
+                bool first = !systemProcessor->alarms.head;
+
                 insert( &systemProcessor->alarms, this );
                 if( systemProcessor->pending_alarm ) {
                         tick_preemption();
+                }
+                if( first ) {
+                        __kernel_set_timer( systemProcessor->alarms.head->alarm - __kernel_get_time() );
                 }
         }