Changes in libcfa/src/concurrency/alarm.cfa [afd7faf:a3821fa]

File:

• libcfa/src/concurrency/alarm.cfa (modified) (6 diffs)

libcfa/src/concurrency/alarm.cfa

@@ -38 +38 @@
 
 void __kernel_set_timer( Duration alarm ) {
-        alarm = max(alarm, 1`us);
-        itimerval otv @= { 0 };
-        getitimer( ITIMER_REAL, &otv );
-        Duration od = { otv.it_value };
-        if(od == 0 || od > alarm) {
-                setitimer( ITIMER_REAL, &(itimerval){ alarm }, 0p );
-        }
+        verifyf(alarm >= 1`us || alarm == 0, "Setting timer to < 1us (%jins)", alarm`ns);
+        setitimer( ITIMER_REAL, &(itimerval){ alarm }, 0p );
 }
 
@@ -51 +46 @@
 //=============================================================================================
 
-void ?{}( alarm_node_t & this, $thread * thrd, Duration alarm, Duration period) with( this ) {
-        this.initial = alarm;
-        this.period  = period;
+void ?{}( alarm_node_t & this, $thread * thrd, Time alarm, Duration period) with( this ) {
         this.thrd = thrd;
+        this.alarm = alarm;
+        this.period = period;
         set = false;
         type = User;
 }
 
-void ?{}( alarm_node_t & this, processor * proc, Duration alarm, Duration period ) with( this ) {
-        this.initial = alarm;
-        this.period  = period;
+void ?{}( alarm_node_t & this, processor * proc, Time alarm, Duration period ) with( this ) {
         this.proc = proc;
+        this.alarm = alarm;
+        this.period = period;
         set = false;
         type = Kernel;
 }
-void ?{}( alarm_node_t & this, Alarm_Callback callback, Duration alarm, Duration period ) with( this ) {
-        this.initial = alarm;
-        this.period  = period;
+void ?{}( alarm_node_t & this, Alarm_Callback callback, Time alarm, Duration period ) with( this ) {
+        this.alarm = alarm;
+        this.period = period;
         this.callback = callback;
         set = false;
@@ -82 +77 @@
 void insert( alarm_list_t * this, alarm_node_t * n ) {
         alarm_node_t * it = & (*this)`first;
-        while( it && (n->timeval > it->timeval) ) {
+        while( it && (n->alarm > it->alarm) ) {
                 it = & (*it)`next;
         }
@@ -110 +105 @@
         lock( event_kernel->lock __cfaabi_dbg_ctx2 );
         {
-                Time curr = __kernel_get_time();
-                this->timeval = curr + this->initial;
+                verify( validate( alarms ) );
+                bool first = ! & alarms`first;
 
-                /* paranoid */ verify( validate( alarms ) );
-
-                __cfadbg_print_safe( preemption, " KERNEL: alarm inserting %p (%lu -> %lu).\n", this, curr.tn, this->timeval.tn );
+                __cfadbg_print_safe( preemption, " KERNEL: alarm inserting %p (%lu).\n", this, this->alarm.tn );
                 insert( &alarms, this );
-                __kernel_set_timer( this->initial );
-                this->set = true;
+                if( first ) {
+                        __kernel_set_timer( alarms`first.alarm - __kernel_get_time() );
+                }
         }
         unlock( event_kernel->lock );
+        this->set = true;
         enable_interrupts();
 }
@@ -129 +124 @@
         {
                 verify( validate( event_kernel->alarms ) );
-                if (this->set) remove( *this );
-                this->set = false;
+                remove( *this );
         }
         unlock( event_kernel->lock );
         enable_interrupts();
+        this->set = false;
 }
 
@@ -141 +136 @@
 
 void sleep( Duration duration ) {
-        alarm_node_t node = { active_thread(), duration, 0`s };
+        alarm_node_t node = { active_thread(), __kernel_get_time() + duration, 0`s };
 
         register_self( &node );