Changes in src/libcfa/concurrency/alarm.c [c81ebf9:82ff5845]

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() );
                 }
         }