1 | /* |
---|
2 | * alarm.h - timer based kernel alarm specification |
---|
3 | * |
---|
4 | * Author Alain Greiner (2016,2017,2018,2019,2020) |
---|
5 | * |
---|
6 | * Copyright (c) UPMC Sorbonne Universites |
---|
7 | * |
---|
8 | * This file is part of ALMOS-MKH. |
---|
9 | * |
---|
10 | * ALMOS-MKH is free software; you can redistribute it and/or modify it |
---|
11 | * under the terms of the GNU General Public License as published by |
---|
12 | * the Free Software Foundation; version 2.0 of the License. |
---|
13 | * |
---|
14 | * ALMOS-MKH is distributed in the hope that it will be useful, but |
---|
15 | * WITHOUT ANY WARRANTY; without even the implied warranty of |
---|
16 | * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU |
---|
17 | * General Public License for more details. |
---|
18 | * |
---|
19 | * You should have received a copy of the GNU General Public License |
---|
20 | * along with ALMOS-MKH; if not, write to the Free Software Foundation, |
---|
21 | * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA |
---|
22 | */ |
---|
23 | |
---|
24 | |
---|
25 | #ifndef _ALARM_H_ |
---|
26 | #define _ALARM_H_ |
---|
27 | |
---|
28 | #include <hal_kernel_types.h> |
---|
29 | #include <list.h> |
---|
30 | |
---|
31 | /**** Forward declarations ****/ |
---|
32 | |
---|
33 | struct thread_s; |
---|
34 | |
---|
35 | /****************************************************************************************** |
---|
36 | * This structure defines a generic, timer based, kernel alarm. |
---|
37 | * |
---|
38 | * - An alarm is attached to a given thread, and the alarm descriptor is embedded in the |
---|
39 | * thread descriptor. A client thread can use the alarm_start() function to dynamically |
---|
40 | * activate the alarm. It can use the alarm_stop() function to desactivate this alarm. |
---|
41 | * - This kernel alarm is generic, as the alarm handler (executed when the alarm rings), |
---|
42 | * and the handler arguments are defined by two pointers: <func_ptr> and <args_xp>. |
---|
43 | * - When an alarm is created by a client thread, it is registered in the list of alarms |
---|
44 | * rooted in the core running the client thread. When it is stopped, the alarm is simply |
---|
45 | * removed from this list. |
---|
46 | * - When creating an alarm with the alarm_start() function, the client thread must define |
---|
47 | * an absolute date (in cycles), the func_ptr pointer, and the args_xp extended pointer. |
---|
48 | * - The list of alarms is ordered by increasing dates. At each TICK received by a core, |
---|
49 | * the date of the first registered alarm is compared to the current date (in the |
---|
50 | * core_clock() function). The alarm handler is executed when current_date >= alarm_date. |
---|
51 | * - It is the handler responsability to stop and delete a ringing alarm using the |
---|
52 | * alarm_stop() function, or update the alarm date using the alarm_update() function. |
---|
53 | * - The three alarm_start(), alarm_stop(), and alarm_update() access functions use |
---|
54 | * the lock protecting the alarms list to handle concurrent accesses. These functions |
---|
55 | * use extended pointers to access the alarm list, and can be called by a thread |
---|
56 | * running in any cluster. |
---|
57 | * |
---|
58 | * This embedded alarm mechanism is used by: |
---|
59 | * 1. the socket_accept(), socket_connect(), socket_send(), socket_close() functions, |
---|
60 | * to implement the TCP retransmission machanism. |
---|
61 | * 2. the sys_thread_sleep() function, to implement the "sleep" mechanism. |
---|
62 | ******************************************************************************************/ |
---|
63 | |
---|
64 | typedef struct alarm_s |
---|
65 | { |
---|
66 | bool_t linked; /*! active when true (i.e linked to the core list) */ |
---|
67 | cycle_t date; /*! absolute date for handler execution */ |
---|
68 | void * func_ptr; /*! local pointer on alarm handler function */ |
---|
69 | xptr_t args_xp; /*! local pointer on handler arguments */ |
---|
70 | list_entry_t list; /*! set of active alarms attached to the same core */ |
---|
71 | } |
---|
72 | alarm_t; |
---|
73 | |
---|
74 | /******************************************************************************************* |
---|
75 | * This defines the generic prototype for an alarm handler. |
---|
76 | ******************************************************************************************/ |
---|
77 | |
---|
78 | typedef void (alarm_handler_t) ( xptr_t args_xp ); |
---|
79 | |
---|
80 | /******************************************************************************************* |
---|
81 | * This function initialises the alarm state to "inactive". |
---|
82 | ******************************************************************************************* |
---|
83 | * @ alarm : local pointer on alarm. |
---|
84 | ******************************************************************************************/ |
---|
85 | void alarm_init( alarm_t * alarm ); |
---|
86 | |
---|
87 | /******************************************************************************************* |
---|
88 | * This function initializes the alarm descriptor embedded in the thread identified by the |
---|
89 | * <thread_xp> argument from the <date>, <func_ptr>, <args_ptr> arguments, and registers |
---|
90 | * this alarm in the ordered list rooted in the core running this thread. |
---|
91 | * It takes the lock protecting the alarms list against concurrent accesses. |
---|
92 | ******************************************************************************************* |
---|
93 | * @ thread_xp : extended pointer on the target thread. |
---|
94 | * @ date : absolute date (in cycles). |
---|
95 | * @ func_ptr : local pointer on the handler to execute when the alarm rings. |
---|
96 | * @ args_xp : extended pointer on the handler arguments. |
---|
97 | ******************************************************************************************/ |
---|
98 | void alarm_start( xptr_t thread_xp, |
---|
99 | cycle_t date, |
---|
100 | void * func_ptr, |
---|
101 | xptr_t args_xp ); |
---|
102 | |
---|
103 | /******************************************************************************************* |
---|
104 | * This function updates the date of the alarm attached to the thread identified by the |
---|
105 | * <thread> argument. The list of alarms rooted in the core running the client thread |
---|
106 | * is modified to respect the absolute dates ordering. |
---|
107 | * It takes the lock protecting the alarms list against concurrent accesses. |
---|
108 | ******************************************************************************************* |
---|
109 | * @ thread_xp : extended pointer on the target thread. |
---|
110 | * @ new_date : absolute new date (in cycles). |
---|
111 | ******************************************************************************************/ |
---|
112 | void alarm_update( xptr_t thread_xp, |
---|
113 | cycle_t new_date ); |
---|
114 | |
---|
115 | /******************************************************************************************* |
---|
116 | * This function unlink an alarm identified by the <thread> argument from the list of |
---|
117 | * alarms rooted in the core descriptor. |
---|
118 | * It takes the lock protecting the alarms list against concurrent accesses. |
---|
119 | ******************************************************************************************* |
---|
120 | * @ thread_xp : extended pointer on the target thread. |
---|
121 | ******************************************************************************************/ |
---|
122 | void alarm_stop( xptr_t thread_xp ); |
---|
123 | |
---|
124 | |
---|
125 | #endif /* _ALARM_H_ */ |
---|