source: trunk/kernel/syscalls/sys_condvar.c @ 508

Last change on this file since 508 was 508, checked in by viala@…, 3 years ago

[syscall] Use assert instead of printk+hal_core_sleep.

File size: 5.3 KB
Line 
1/*
2 * sys_condvar.c - Access a POSIX condvar.
3 *
4 * Author    Alain Greiner  (2016,2017,2018)
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#include <hal_kernel_types.h>
25#include <hal_special.h>
26#include <errno.h>
27#include <thread.h>
28#include <printk.h>
29#include <vmm.h>
30#include <syscalls.h>
31#include <remote_condvar.h>
32#include <remote_mutex.h>
33
34////////////////////////////////////////
35int sys_condvar( void         * condvar,
36                 uint32_t       operation,
37                 void         * mutex )
38{
39        error_t     error;
40    vseg_t    * vseg;
41 
42    thread_t  * this    = CURRENT_THREAD;
43    process_t * process = this->process;
44
45    // check condvar in user vspace
46        error = vmm_get_vseg( process , (intptr_t)condvar , &vseg );
47
48        if( error )
49    {
50
51#if DEBUG_SYSCALLS_ERROR
52printk("\n[ERROR] in %s : unmapped condvar %x / thread %x / process %x\n",
53__FUNCTION__ , (intptr_t)condvar , this->trdid , process->pid );
54vmm_display( process , false );
55#endif
56        this->errno = error;
57        return -1;
58    }
59
60    // execute requested operation
61        switch( operation )
62        {
63        //////////////////
64        case CONDVAR_INIT:
65        {
66            error = remote_condvar_create( (intptr_t)condvar );
67   
68                    if( error )
69            {
70
71#if DEBUG_SYSCALLS_ERROR
72printk("\n[ERROR] in %s : cannot create condvar %x / thread %x / process %x\n",
73__FUNCTION__ , (intptr_t)condvar , this->trdid , process->pid );
74#endif
75                this->errno = error;
76                return -1;
77            }
78                    break;
79        }
80        //////////////////
81            case CONDVAR_WAIT:
82        {
83            // check mutex in user vspace
84                error = vmm_get_vseg( process , (intptr_t)mutex , &vseg );
85
86                if( error )
87            {
88
89#if DEBUG_SYSCALLS_ERROR
90printk("\n[ERROR] in %s : unmapped mutex %x / thread %x / process %x\n",
91__FUNCTION__ , (intptr_t)mutex , this->trdid , process->pid );
92#endif
93                this->errno = error;
94                return -1;
95            }
96
97            xptr_t condvar_xp = remote_condvar_from_ident( (intptr_t)condvar );
98
99            if( condvar_xp == XPTR_NULL )     // user error
100            {
101
102#if DEBUG_SYSCALLS_ERROR
103printk("\n[ERROR] in %s : condvar %x not registered / thread %x / process %x\n",
104__FUNCTION__ , (intptr_t)condvar , this->trdid , process->pid );
105#endif
106                this->errno = EINVAL;
107                return -1;
108            }
109   
110            xptr_t mutex_xp = remote_mutex_from_ident( (intptr_t)mutex );
111
112            if( mutex_xp == XPTR_NULL )     // user error
113            {
114
115#if DEBUG_SYSCALLS_ERROR
116printk("\n[ERROR] in %s : mutex %x not registered / thread %x / process %x\n",
117__FUNCTION__ , (intptr_t)mutex , this->trdid , process->pid );
118#endif
119                this->errno = EINVAL;
120                return -1;
121            }
122
123            remote_condvar_wait( condvar_xp , mutex_xp );
124
125            break;
126        }
127        ////////////////////
128            case CONDVAR_SIGNAL:
129        {
130            xptr_t condvar_xp = remote_condvar_from_ident( (intptr_t)condvar );
131
132            if( condvar_xp == XPTR_NULL )     // user error
133            {
134
135#if DEBUG_SYSCALLS_ERROR
136printk("\n[ERROR] in %s : condvar %x not registered / thread %x / process %x\n",
137__FUNCTION__ , (intptr_t)condvar , this->trdid , process->pid );
138#endif
139                this->errno = EINVAL;
140                return -1;
141            }
142
143            remote_condvar_signal( condvar_xp ); 
144           
145            break;
146        }
147        ///////////////////////
148            case CONDVAR_BROADCAST:
149        {
150            xptr_t condvar_xp = remote_condvar_from_ident( (intptr_t)condvar );
151
152            if( condvar_xp == XPTR_NULL )     // user error
153            {
154
155#if DEBUG_SYSCALLS_ERROR
156printk("\n[ERROR] in %s : condvar %x not registered / thread %x / process %x\n",
157__FUNCTION__ , (intptr_t)condvar , this->trdid , process->pid );
158#endif
159                this->errno = EINVAL;
160                return -1;
161            }
162
163            remote_condvar_broadcast( condvar_xp );
164
165            break;
166        }
167        /////////////////////
168            case CONDVAR_DESTROY:
169        {
170            xptr_t condvar_xp = remote_condvar_from_ident( (intptr_t)condvar );
171
172            if( condvar_xp == XPTR_NULL )     // user error
173            {
174
175#if DEBUG_SYSCALLS_ERROR
176printk("\n[ERROR] in %s : condvar %x not registered / thread %x / process %x\n",
177__FUNCTION__ , (intptr_t)condvar , this->trdid , process->pid );
178#endif
179                this->errno = EINVAL;
180                return -1;
181            }
182
183            remote_condvar_destroy( condvar_xp ); 
184
185            break;
186                }
187        /////////
188        default: {
189            assert ( false, "illegal operation type <%x>\n", operation );
190        }
191        }   // end switch
192
193        return 0;
194
195}  // enc sys_condvar()
196
Note: See TracBrowser for help on using the repository browser.