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

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

Changed enable interrupts:

  • no longer save the caller for debugging
  • now polls based on parameter passed in
  • Property mode set to 100644
File size: 3.8 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        verifyf(alarm >= 1`us || alarm == 0, "Setting timer to < 1us (%jins)", alarm`ns);
41        setitimer( ITIMER_REAL, &(itimerval){ alarm }, 0p );
42}
43
44//=============================================================================================
45// Alarm logic
46//=============================================================================================
47
48void ?{}( alarm_node_t & this, $thread * thrd, Time alarm, Duration period) with( this ) {
49        this.thrd = thrd;
50        this.alarm = alarm;
51        this.period = period;
52        set = false;
53        type = User;
54}
55
56void ?{}( alarm_node_t & this, processor * proc, Time alarm, Duration period ) with( this ) {
57        this.proc = proc;
58        this.alarm = alarm;
59        this.period = period;
60        set = false;
61        type = Kernel;
62}
63void ?{}( alarm_node_t & this, Alarm_Callback callback, Time alarm, Duration period ) with( this ) {
64        this.alarm = alarm;
65        this.period = period;
66        this.callback = callback;
67        set = false;
68        type = Callback;
69}
70
71void ^?{}( alarm_node_t & this ) {
72        if( this.set ) {
73                unregister_self( &this );
74        }
75}
76
77void insert( alarm_list_t * this, alarm_node_t * n ) {
78        alarm_node_t * it = & (*this)`first;
79        while( it && (n->alarm > it->alarm) ) {
80                it = & (*it)`next;
81        }
82        if ( it ) {
83                insert_before( *it, *n );
84        } else {
85                insert_last(*this, *n);
86        }
87
88        verify( validate( *this ) );
89}
90
91alarm_node_t * pop( alarm_list_t * this ) {
92        verify( validate( *this ) );
93        alarm_node_t * head = & (*this)`first;
94        if( head ) {
95                remove(*head);
96        }
97        verify( validate( *this ) );
98        return head;
99}
100
101void register_self( alarm_node_t * this ) {
102        alarm_list_t & alarms = event_kernel->alarms;
103
104        disable_interrupts();
105        lock( event_kernel->lock __cfaabi_dbg_ctx2 );
106        {
107                verify( validate( alarms ) );
108                bool first = ! & alarms`first;
109
110                __cfadbg_print_safe( preemption, " KERNEL: alarm inserting %p (%lu).\n", this, this->alarm.tn );
111                insert( &alarms, this );
112                if( first ) {
113                        __kernel_set_timer( alarms`first.alarm - __kernel_get_time() );
114                }
115        }
116        unlock( event_kernel->lock );
117        this->set = true;
118        enable_interrupts();
119}
120
121void unregister_self( alarm_node_t * this ) {
122        disable_interrupts();
123        lock( event_kernel->lock __cfaabi_dbg_ctx2 );
124        {
125                verify( validate( event_kernel->alarms ) );
126                remove( *this );
127        }
128        unlock( event_kernel->lock );
129        enable_interrupts();
130        this->set = false;
131}
132
133//=============================================================================================
134// Utilities
135//=============================================================================================
136
137void sleep( Duration duration ) {
138        alarm_node_t node = { active_thread(), __kernel_get_time() + duration, 0`s };
139
140        register_self( &node );
141        park();
142
143        /* paranoid */ verify( !node.set );
144        /* paranoid */ verify( & node`next == 0p );
145        /* paranoid */ verify( & node`prev == 0p );
146}
147
148// Local Variables: //
149// mode: c //
150// tab-width: 4 //
151// End: //
Note: See TracBrowser for help on using the repository browser.