source: libcfa/src/concurrency/alarm.cfa @ c457dc4

arm-ehjacob/cs343-translationnew-ast-unique-expr
Last change on this file since c457dc4 was c457dc4, checked in by Thierry Delisle <tdelisle@…>, 9 months ago

Fix sequential handling of timers

  • Property mode set to 100644
File size: 3.9 KB
Line 
1//
2// Cforall Version 1.0.0 Copyright (C) 2016 University of Waterloo
3//
4// The contents of this file are covered under the licence agreement in the
5// file "LICENCE" distributed with Cforall.
6//
7// alarm.c --
8//
9// Author           : Thierry Delisle
10// Created On       : Fri Jun 2 11:31:25 2017
11// Last Modified By : Peter A. Buhr
12// Last Modified On : Wed Jun 17 16:11:35 2020
13// Update Count     : 75
14//
15
16#define __cforall_thread__
17// #define __CFA_DEBUG_PRINT_PREEMPTION__
18
19#include <errno.h>
20#include <stdio.h>
21#include <unistd.h>
22#include <string.h>
23#include <sys/time.h>
24
25#include "alarm.hfa"
26#include "kernel/fwd.hfa"
27#include "preemption.hfa"
28
29//=============================================================================================
30// Clock logic
31//=============================================================================================
32
33Time __kernel_get_time() {
34        timespec curr;
35        clock_gettime( CLOCK_MONOTONIC_RAW, &curr );            // CLOCK_REALTIME
36        return (Time){ curr };
37}
38
39void __kernel_set_timer( Duration alarm ) {
40        alarm = max(alarm, 1`us);
41        itimerval otv @= { 0 };
42        getitimer( ITIMER_REAL, &otv );
43        Duration od = { otv.it_value };
44        if(od == 0 || od > alarm) {
45                setitimer( ITIMER_REAL, &(itimerval){ alarm }, 0p );
46        }
47}
48
49//=============================================================================================
50// Alarm logic
51//=============================================================================================
52
53void ?{}( alarm_node_t & this, $thread * thrd, Duration alarm, Duration period) with( this ) {
54        this.initial = alarm;
55        this.period  = period;
56        this.thrd = thrd;
57        set = false;
58        type = User;
59}
60
61void ?{}( alarm_node_t & this, processor * proc, Duration alarm, Duration period ) with( this ) {
62        this.initial = alarm;
63        this.period  = period;
64        this.proc = proc;
65        set = false;
66        type = Kernel;
67}
68void ?{}( alarm_node_t & this, Alarm_Callback callback, Duration alarm, Duration period ) with( this ) {
69        this.initial = alarm;
70        this.period  = period;
71        this.callback = callback;
72        set = false;
73        type = Callback;
74}
75
76void ^?{}( alarm_node_t & this ) {
77        if( this.set ) {
78                unregister_self( &this );
79        }
80}
81
82void insert( alarm_list_t * this, alarm_node_t * n ) {
83        alarm_node_t * it = & (*this)`first;
84        while( it && (n->timeval > it->timeval) ) {
85                it = & (*it)`next;
86        }
87        if ( it ) {
88                insert_before( *it, *n );
89        } else {
90                insert_last(*this, *n);
91        }
92
93        verify( validate( *this ) );
94}
95
96alarm_node_t * pop( alarm_list_t * this ) {
97        verify( validate( *this ) );
98        alarm_node_t * head = & (*this)`first;
99        if( head ) {
100                remove(*head);
101        }
102        verify( validate( *this ) );
103        return head;
104}
105
106void register_self( alarm_node_t * this ) {
107        alarm_list_t & alarms = event_kernel->alarms;
108
109        disable_interrupts();
110        lock( event_kernel->lock __cfaabi_dbg_ctx2 );
111        {
112                Time curr = __kernel_get_time();
113                this->timeval = curr + this->initial;
114
115                /* paranoid */ verify( validate( alarms ) );
116
117                __cfadbg_print_safe( preemption, " KERNEL: alarm inserting %p (%lu -> %lu).\n", this, curr.tn, this->timeval.tn );
118                insert( &alarms, this );
119                __kernel_set_timer( this->initial );
120        }
121        unlock( event_kernel->lock );
122        this->set = true;
123        enable_interrupts();
124}
125
126void unregister_self( alarm_node_t * this ) {
127        disable_interrupts();
128        lock( event_kernel->lock __cfaabi_dbg_ctx2 );
129        {
130                verify( validate( event_kernel->alarms ) );
131                remove( *this );
132        }
133        unlock( event_kernel->lock );
134        enable_interrupts();
135        this->set = false;
136}
137
138//=============================================================================================
139// Utilities
140//=============================================================================================
141
142void sleep( Duration duration ) {
143        alarm_node_t node = { active_thread(), duration, 0`s };
144
145        register_self( &node );
146        park();
147
148        /* paranoid */ verify( !node.set );
149        /* paranoid */ verify( & node`next == 0p );
150        /* paranoid */ verify( & node`prev == 0p );
151}
152
153// Local Variables: //
154// mode: c //
155// tab-width: 4 //
156// End: //
Note: See TracBrowser for help on using the repository browser.