[6cff9f3] | 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 |
---|
[6b0b624] | 11 | // Last Modified By : Peter A. Buhr |
---|
[c1ee231] | 12 | // Last Modified On : Wed Jun 17 16:11:35 2020 |
---|
| 13 | // Update Count : 75 |
---|
[6cff9f3] | 14 | // |
---|
| 15 | |
---|
[2026bb6] | 16 | #define __cforall_thread__ |
---|
| 17 | |
---|
[82ff5845] | 18 | #include <errno.h> |
---|
| 19 | #include <stdio.h> |
---|
| 20 | #include <unistd.h> |
---|
[c1ee231] | 21 | #include <string.h> |
---|
[c81ebf9] | 22 | #include <sys/time.h> |
---|
| 23 | |
---|
[73abe95] | 24 | #include "alarm.hfa" |
---|
[e660761] | 25 | #include "kernel/fwd.hfa" |
---|
[73abe95] | 26 | #include "preemption.hfa" |
---|
[6cff9f3] | 27 | |
---|
[c81ebf9] | 28 | //============================================================================================= |
---|
| 29 | // Clock logic |
---|
| 30 | //============================================================================================= |
---|
| 31 | |
---|
[2a84d06d] | 32 | Time __kernel_get_time() { |
---|
[c81ebf9] | 33 | timespec curr; |
---|
[2a84d06d] | 34 | clock_gettime( CLOCK_MONOTONIC_RAW, &curr ); // CLOCK_REALTIME |
---|
| 35 | return (Time){ curr }; |
---|
[c81ebf9] | 36 | } |
---|
| 37 | |
---|
[2a84d06d] | 38 | void __kernel_set_timer( Duration alarm ) { |
---|
[e0c235c] | 39 | verifyf(alarm >= 1`us || alarm == 0, "Setting timer to < 1us (%jins)", alarm`ns); |
---|
[121be3e] | 40 | setitimer( ITIMER_REAL, &(itimerval){ alarm }, 0p ); |
---|
[6cff9f3] | 41 | } |
---|
| 42 | |
---|
[c81ebf9] | 43 | //============================================================================================= |
---|
| 44 | // Alarm logic |
---|
| 45 | //============================================================================================= |
---|
| 46 | |
---|
[ac2b598] | 47 | void ?{}( alarm_node_t & this, $thread * thrd, Time alarm, Duration period ) with( this ) { |
---|
[242a902] | 48 | this.thrd = thrd; |
---|
| 49 | this.alarm = alarm; |
---|
| 50 | this.period = period; |
---|
[c40e7c5] | 51 | set = false; |
---|
| 52 | kernel_alarm = false; |
---|
[6cff9f3] | 53 | } |
---|
| 54 | |
---|
[c1ee231] | 55 | void ?{}( alarm_node_t & this, processor * proc, Time alarm, Duration period ) with( this ) { |
---|
[242a902] | 56 | this.proc = proc; |
---|
| 57 | this.alarm = alarm; |
---|
| 58 | this.period = period; |
---|
[c40e7c5] | 59 | set = false; |
---|
| 60 | kernel_alarm = true; |
---|
[c81ebf9] | 61 | } |
---|
[6cff9f3] | 62 | |
---|
[242a902] | 63 | void ^?{}( alarm_node_t & this ) { |
---|
| 64 | if( this.set ) { |
---|
| 65 | unregister_self( &this ); |
---|
[c81ebf9] | 66 | } |
---|
[6cff9f3] | 67 | } |
---|
| 68 | |
---|
| 69 | void insert( alarm_list_t * this, alarm_node_t * n ) { |
---|
[d3ab183] | 70 | alarm_node_t * it = & (*this)`first; |
---|
| 71 | while( it && (n->alarm > it->alarm) ) { |
---|
| 72 | it = & (*it)`next; |
---|
| 73 | } |
---|
| 74 | if ( it ) { |
---|
| 75 | insert_before( *it, *n ); |
---|
| 76 | } else { |
---|
| 77 | insert_last(*this, *n); |
---|
[6cff9f3] | 78 | } |
---|
| 79 | |
---|
[d3ab183] | 80 | verify( validate( *this ) ); |
---|
[6cff9f3] | 81 | } |
---|
| 82 | |
---|
[c81ebf9] | 83 | alarm_node_t * pop( alarm_list_t * this ) { |
---|
[d3ab183] | 84 | verify( validate( *this ) ); |
---|
| 85 | alarm_node_t * head = & (*this)`first; |
---|
[6cff9f3] | 86 | if( head ) { |
---|
[d3ab183] | 87 | remove(*head); |
---|
[6cff9f3] | 88 | } |
---|
[d3ab183] | 89 | verify( validate( *this ) ); |
---|
[6cff9f3] | 90 | return head; |
---|
[c81ebf9] | 91 | } |
---|
| 92 | |
---|
| 93 | void register_self( alarm_node_t * this ) { |
---|
[d3ab183] | 94 | alarm_list_t & alarms = event_kernel->alarms; |
---|
[e60e0dc] | 95 | |
---|
[c81ebf9] | 96 | disable_interrupts(); |
---|
[36982fc] | 97 | lock( event_kernel->lock __cfaabi_dbg_ctx2 ); |
---|
[c81ebf9] | 98 | { |
---|
[e60e0dc] | 99 | verify( validate( alarms ) ); |
---|
[d3ab183] | 100 | bool first = ! & alarms`first; |
---|
[82ff5845] | 101 | |
---|
[d3ab183] | 102 | insert( &alarms, this ); |
---|
[82ff5845] | 103 | if( first ) { |
---|
[d3ab183] | 104 | __kernel_set_timer( alarms`first.alarm - __kernel_get_time() ); |
---|
[82ff5845] | 105 | } |
---|
[c81ebf9] | 106 | } |
---|
[ea7d2b0] | 107 | unlock( event_kernel->lock ); |
---|
[c81ebf9] | 108 | this->set = true; |
---|
[36982fc] | 109 | enable_interrupts( __cfaabi_dbg_ctx ); |
---|
[c81ebf9] | 110 | } |
---|
| 111 | |
---|
| 112 | void unregister_self( alarm_node_t * this ) { |
---|
| 113 | disable_interrupts(); |
---|
[36982fc] | 114 | lock( event_kernel->lock __cfaabi_dbg_ctx2 ); |
---|
[0b33412] | 115 | { |
---|
[d3ab183] | 116 | verify( validate( event_kernel->alarms ) ); |
---|
| 117 | remove( *this ); |
---|
[0b33412] | 118 | } |
---|
[ea7d2b0] | 119 | unlock( event_kernel->lock ); |
---|
[36982fc] | 120 | enable_interrupts( __cfaabi_dbg_ctx ); |
---|
[c81ebf9] | 121 | this->set = false; |
---|
[4aa2fb2] | 122 | } |
---|
[6b0b624] | 123 | |
---|
[2d8f7b0] | 124 | //============================================================================================= |
---|
| 125 | // Utilities |
---|
| 126 | //============================================================================================= |
---|
| 127 | |
---|
| 128 | void sleep( Duration duration ) { |
---|
| 129 | alarm_node_t node = { active_thread(), __kernel_get_time() + duration, 0`s }; |
---|
| 130 | |
---|
| 131 | register_self( &node ); |
---|
| 132 | park( __cfaabi_dbg_ctx ); |
---|
| 133 | |
---|
| 134 | /* paranoid */ verify( !node.set ); |
---|
[d3ab183] | 135 | /* paranoid */ verify( & node`next == 0p ); |
---|
| 136 | /* paranoid */ verify( & node`prev == 0p ); |
---|
[2d8f7b0] | 137 | } |
---|
| 138 | |
---|
[6b0b624] | 139 | // Local Variables: // |
---|
| 140 | // mode: c // |
---|
| 141 | // tab-width: 4 // |
---|
| 142 | // End: // |
---|