First fixes in order to comply with the Phase-2 API

[frescor/fosa.git] / src_aquosa / fosa_threads_and_signals.c

diff --git a/src_aquosa/fosa_threads_and_signals.c b/src_aquosa/fosa_threads_and_signals.c
index 32e1442c91aeb1e0a00e3274c258cfcb712fc25d..d83b7a21e58e2fcd8d3413a9b86140468403181d 100644 (file)
--- a/src_aquosa/fosa_threads_and_signals.c
+++ b/src_aquosa/fosa_threads_and_signals.c
@@ -65,7 +65,7 @@
  * Thread identification
  *************************/ 
 
-bool fosa_thread_equal(frsh_thread_id_t t1, frsh_thread_id_t t2)
+bool fosa_thread_equal(fosa_thread_id_t t1, fosa_thread_id_t t2)
 {
        if ( pthread_equal(t1.pthread_id, t2.pthread_id &&
                        t1.linux_pid == t2.linux_pid    &&
@@ -75,13 +75,13 @@ bool fosa_thread_equal(frsh_thread_id_t t1, frsh_thread_id_t t2)
        return false;
 }
 
-frsh_thread_id_t fosa_thread_self()
+fosa_thread_id_t fosa_thread_self()
 {
-       frsh_thread_id_t thread_self;
+       fosa_thread_id_t thread_self;
        /* 
         * Fill the user pointer with appropriate data for the calling thread
         * NB. Remember:
-        *  frsh_thread_id_t => struct {
+        *  fosa_thread_id_t => struct {
         *                       pthread_t pthread_id;
         *                       pid_t linux_pid;
         *                       tid_t linux_tid;
@@ -98,9 +98,9 @@ frsh_thread_id_t fosa_thread_self()
  * Thread creation and termination
  *************************/ 
 
-int fosa_thread_create(frsh_thread_id_t *tid,
-       const frsh_thread_attr_t *attr,
-       frsh_thread_code_t code,
+int fosa_thread_create(fosa_thread_id_t *tid,
+       const fosa_thread_attr_t *attr,
+       fosa_thread_code_t code,
        void *arg)
 {
        pthread_t tmp_tid;
@@ -121,7 +121,7 @@ int fosa_thread_create(frsh_thread_id_t *tid,
  **************************************************/ 
 
 int fosa_thread_set_specific_data(int key,
-       frsh_thread_id_t tid,
+       fosa_thread_id_t tid,
        const void *value)
 {
        //if ((key > 0) && (key < (FOSA_MAX_KEYS-1))) {
@@ -135,7 +135,7 @@ int fosa_thread_set_specific_data(int key,
 }
 
 int fosa_thread_get_specific_data(int key,
-       frsh_thread_id_t tid,
+       fosa_thread_id_t tid,
        void **value)
 {
        //if ((key > 0) && (key < (FOSA_MAX_KEYS-1))) {
@@ -169,7 +169,7 @@ int fosa_get_priority_min() {
        return sched_get_priority_min(0);
 }
 
-int fosa_thread_attr_set_prio(frsh_thread_attr_t *attr, int prio)
+int fosa_thread_attr_set_prio(fosa_thread_attr_t *attr, int prio)
 {
        //if ((sched_get_priority_min(0)<=prio) || (prio<=sched_get_priority_min(0))) {
        //      attr->sched_param.sched_priority = prio;
@@ -181,7 +181,7 @@ int fosa_thread_attr_set_prio(frsh_thread_attr_t *attr, int prio)
        return -1;
 }
 
-int fosa_thread_attr_get_prio (const frsh_thread_attr_t *attr, int *prio)
+int fosa_thread_attr_get_prio (const fosa_thread_attr_t *attr, int *prio)
 {
        //*prio = attr->sched_param.sched_priority;
        //return 0;
@@ -190,7 +190,7 @@ int fosa_thread_attr_get_prio (const frsh_thread_attr_t *attr, int *prio)
        return -1;
 }
 
-int fosa_thread_set_prio(frsh_thread_id_t tid, int prio)
+int fosa_thread_set_prio(fosa_thread_id_t tid, int prio)
 {
        //if ((sched_get_priority_min(0)<=prio) || (prio<=sched_get_priority_min(0))) {
        //      pthread_setschedprio(tid.pthread_id,prio);
@@ -201,7 +201,7 @@ int fosa_thread_set_prio(frsh_thread_id_t tid, int prio)
        return -1;
 }
 
-int fosa_thread_get_prio (frsh_thread_id_t tid, int *prio)
+int fosa_thread_get_prio (fosa_thread_id_t tid, int *prio)
 {
        //*prio = tid.pthread_id->sched_param.sched_priority;
        //return 0;
@@ -218,7 +218,7 @@ int fosa_thread_get_prio (frsh_thread_id_t tid, int *prio)
  * synchronously wait. Signals carry an associated piece of
  * information (an integer or a pointer) and are queued until they are
  * accepted.  Signals are identified by an integer signal number (of
- * the type frsh_signal_t) in the range FOSA_SIGNAL_MIN,
+ * the type fosa_signal_t) in the range FOSA_SIGNAL_MIN,
  * FOSA_SIGNAL_MAX.  This range is required to have at least <tbd>
  * values.
  *******************************************************************/
@@ -227,7 +227,7 @@ int fosa_thread_get_prio (frsh_thread_id_t tid, int *prio)
  * We need to change the API if we want such a feature!!*/
 sigset_t original_mask;
 
-int fosa_set_accepted_signals(frsh_signal_t set[], int size)
+int fosa_set_accepted_signals(fosa_signal_t set[], int size)
 {
        int x;
        sigset_t new_mask;
@@ -243,9 +243,9 @@ int fosa_set_accepted_signals(frsh_signal_t set[], int size)
        return pthread_sigmask(SIG_SETMASK, &new_mask, &original_mask);
 }
 
-int fosa_signal_queue(frsh_signal_t signal,
-       frsh_signal_info_t info,
-       frsh_thread_id_t receiver)
+int fosa_signal_queue(fosa_signal_t signal,
+       fosa_signal_info_t info,
+       fosa_thread_id_t receiver)
 {
        union sigval siginfo;
 
@@ -253,10 +253,10 @@ int fosa_signal_queue(frsh_signal_t signal,
        return sigqueue(receiver.linux_pid, signal, siginfo);
 }
 
-int fosa_signal_wait (frsh_signal_t set[],
+int fosa_signal_wait (fosa_signal_t set[],
        int size,
-       frsh_signal_t *signal_received,
-       frsh_signal_info_t *info)
+       fosa_signal_t *signal_received,
+       fosa_signal_info_t *info)
 {
        int x;
        sigset_t wait_mask;
@@ -278,10 +278,10 @@ int fosa_signal_wait (frsh_signal_t set[],
        return 0;
 }
 
-int fosa_signal_timedwait(frsh_signal_t set[],
+int fosa_signal_timedwait(fosa_signal_t set[],
        int size,
-       frsh_signal_t *signal_received,
-       frsh_signal_info_t *info,
+       fosa_signal_t *signal_received,
+       fosa_signal_info_t *info,
        const struct timespec *timeout)
 {
        int x;