xref: /Kernel-v10.6.2/portable/ThirdParty/GCC/Posix/utils/wait_for_event.c (revision ef7b253b56c9788077f5ecd6c9deb4021923d646) 
1 /*
2  * FreeRTOS Kernel V10.6.2
3  * Copyright (C) 2021 Amazon.com, Inc. or its affiliates.  All Rights Reserved.
4  *
5  * SPDX-License-Identifier: MIT
6  *
7  * Permission is hereby granted, free of charge, to any person obtaining a copy of
8  * this software and associated documentation files (the "Software"), to deal in
9  * the Software without restriction, including without limitation the rights to
10  * use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of
11  * the Software, and to permit persons to whom the Software is furnished to do so,
12  * subject to the following conditions:
13  *
14  * The above copyright notice and this permission notice shall be included in all
15  * copies or substantial portions of the Software.
16  *
17  * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
18  * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS
19  * FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR
20  * COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER
21  * IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
22  * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
23  *
24  * https://www.FreeRTOS.org
25  * https://github.com/FreeRTOS
26  *
27  */
28 
29 #include <pthread.h>
30 #include <stdlib.h>
31 #include <errno.h>
32 
33 #include "wait_for_event.h"
34 
35 struct event
36 {
37     pthread_mutex_t mutex;
38     pthread_cond_t cond;
39     bool event_triggered;
40 };
41 
event_create(void)42 struct event * event_create( void )
43 {
44     struct event * ev = malloc( sizeof( struct event ) );
45 
46     ev->event_triggered = false;
47     pthread_mutex_init( &ev->mutex, NULL );
48     pthread_cond_init( &ev->cond, NULL );
49     return ev;
50 }
51 
event_delete(struct event * ev)52 void event_delete( struct event * ev )
53 {
54     pthread_mutex_destroy( &ev->mutex );
55     pthread_cond_destroy( &ev->cond );
56     free( ev );
57 }
58 
event_wait(struct event * ev)59 bool event_wait( struct event * ev )
60 {
61     pthread_mutex_lock( &ev->mutex );
62 
63     while( ev->event_triggered == false )
64     {
65         pthread_cond_wait( &ev->cond, &ev->mutex );
66     }
67 
68     ev->event_triggered = false;
69     pthread_mutex_unlock( &ev->mutex );
70     return true;
71 }
event_wait_timed(struct event * ev,time_t ms)72 bool event_wait_timed( struct event * ev,
73                        time_t ms )
74 {
75     struct timespec ts;
76     int ret = 0;
77 
78     clock_gettime( CLOCK_REALTIME, &ts );
79     ts.tv_sec += ms / 1000;
80     ts.tv_nsec += ((ms % 1000) * 1000000);
81     pthread_mutex_lock( &ev->mutex );
82 
83     while( (ev->event_triggered == false) && (ret == 0) )
84     {
85         ret = pthread_cond_timedwait( &ev->cond, &ev->mutex, &ts );
86 
87         if( ( ret == -1 ) && ( errno == ETIMEDOUT ) )
88         {
89             return false;
90         }
91     }
92 
93     ev->event_triggered = false;
94     pthread_mutex_unlock( &ev->mutex );
95     return true;
96 }
97 
event_signal(struct event * ev)98 void event_signal( struct event * ev )
99 {
100     pthread_mutex_lock( &ev->mutex );
101     ev->event_triggered = true;
102     pthread_cond_signal( &ev->cond );
103     pthread_mutex_unlock( &ev->mutex );
104 }
105