| [1] | 1 | /* |
|---|
| [23] | 2 | * sys_barrier.c - Access a POSIX barrier. |
|---|
| [1] | 3 | * |
|---|
| [23] | 4 | * authors Alain Greiner (2016,2017) |
|---|
| [1] | 5 | * |
|---|
| [23] | 6 | * Copyright (c) UPMC Sorbonne Universites |
|---|
| [1] | 7 | * |
|---|
| [23] | 8 | * This file is part of ALMOS-MKH. |
|---|
| 9 | * |
|---|
| 10 | * ALMOS-MKH is free software; you can redistribute it and/or modify it |
|---|
| [1] | 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 | * |
|---|
| [23] | 14 | * ALMOS-MKH is distributed in the hope that it will be useful, but |
|---|
| [1] | 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 |
|---|
| [23] | 20 | * along with ALMOS-MKH; if not, write to the Free Software Foundation, |
|---|
| [1] | 21 | * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA |
|---|
| 22 | */ |
|---|
| 23 | |
|---|
| [23] | 24 | #include <hal_types.h> |
|---|
| 25 | #include <hal_special.h> |
|---|
| [1] | 26 | #include <errno.h> |
|---|
| 27 | #include <thread.h> |
|---|
| [23] | 28 | #include <printk.h> |
|---|
| [1] | 29 | #include <vmm.h> |
|---|
| [23] | 30 | #include <syscalls.h> |
|---|
| 31 | #include <remote_barrier.h> |
|---|
| [1] | 32 | |
|---|
| [23] | 33 | ////////////////////////////////// |
|---|
| 34 | int sys_barrier( void * vaddr, |
|---|
| 35 | uint32_t operation, |
|---|
| 36 | uint32_t count ) |
|---|
| [1] | 37 | { |
|---|
| [23] | 38 | error_t error; |
|---|
| 39 | paddr_t paddr; |
|---|
| [1] | 40 | |
|---|
| [23] | 41 | thread_t * this = CURRENT_THREAD; |
|---|
| [1] | 42 | |
|---|
| [23] | 43 | // check vaddr in user vspace |
|---|
| 44 | error = vmm_v2p_translate( false , vaddr , &paddr ); |
|---|
| 45 | if( error ) |
|---|
| 46 | { |
|---|
| 47 | printk("\n[ERROR] in %s : illegal barrier virtual address = %x\n", |
|---|
| 48 | __FUNCTION__ , (intptr_t)vaddr ); |
|---|
| 49 | this->errno = error; |
|---|
| 50 | return -1; |
|---|
| 51 | } |
|---|
| [1] | 52 | |
|---|
| [23] | 53 | // execute requested operation |
|---|
| 54 | switch( operation ) |
|---|
| [1] | 55 | { |
|---|
| [23] | 56 | ////////////////// |
|---|
| 57 | case BARRIER_INIT: |
|---|
| 58 | { |
|---|
| 59 | error = remote_barrier_create( (intptr_t)vaddr , count ); |
|---|
| [1] | 60 | |
|---|
| [23] | 61 | if( error ) |
|---|
| 62 | { |
|---|
| 63 | printk("\n[ERROR] in %s : cannot create barrier = %x\n", |
|---|
| 64 | __FUNCTION__ , (intptr_t)vaddr ); |
|---|
| 65 | this->errno = error; |
|---|
| 66 | return -1; |
|---|
| 67 | } |
|---|
| [1] | 68 | break; |
|---|
| [23] | 69 | } |
|---|
| 70 | ////////////////// |
|---|
| 71 | case BARRIER_WAIT: |
|---|
| 72 | { |
|---|
| 73 | xptr_t barrier_xp = remote_barrier_from_ident( (intptr_t)vaddr ); |
|---|
| [1] | 74 | |
|---|
| [23] | 75 | if( barrier_xp == XPTR_NULL ) // user error |
|---|
| 76 | { |
|---|
| 77 | printk("\n[ERROR] in %s : barrier %x not registered\n", |
|---|
| 78 | __FUNCTION__ , (intptr_t)vaddr ); |
|---|
| 79 | this->errno = EINVAL; |
|---|
| 80 | return -1; |
|---|
| 81 | } |
|---|
| 82 | else // success |
|---|
| 83 | { |
|---|
| 84 | remote_barrier_wait( barrier_xp ); |
|---|
| 85 | } |
|---|
| 86 | break; |
|---|
| 87 | } |
|---|
| 88 | ///////////////////// |
|---|
| 89 | case BARRIER_DESTROY: |
|---|
| 90 | { |
|---|
| 91 | xptr_t barrier_xp = remote_barrier_from_ident( (intptr_t)vaddr ); |
|---|
| [1] | 92 | |
|---|
| [23] | 93 | if( barrier_xp == XPTR_NULL ) // user error |
|---|
| 94 | { |
|---|
| 95 | printk("\n[ERROR] in %s : barrier %x not registered\n", |
|---|
| 96 | __FUNCTION__ , (intptr_t)vaddr ); |
|---|
| 97 | this->errno = EINVAL; |
|---|
| 98 | return -1; |
|---|
| 99 | } |
|---|
| 100 | else // success |
|---|
| 101 | { |
|---|
| 102 | remote_barrier_destroy( barrier_xp ); |
|---|
| 103 | } |
|---|
| 104 | break; |
|---|
| 105 | } |
|---|
| 106 | //////// |
|---|
| 107 | default: |
|---|
| 108 | { |
|---|
| 109 | printk("\n[PANIC] in %s : illegal operation type\n", __FUNCTION__ ); |
|---|
| 110 | hal_core_sleep(); |
|---|
| 111 | } |
|---|
| 112 | } // end switch |
|---|
| [1] | 113 | |
|---|
| [23] | 114 | return 0; |
|---|
| [1] | 115 | |
|---|
| [23] | 116 | } // end sys_barrier() |
|---|
| [1] | 117 | |
|---|
