Changeset 23 for trunk/kernel/syscalls/sys_thread_wakeup.c

Timestamp:

Jun 18, 2017, 10:06:41 PM (7 years ago)

Author:

alain

Message:

Introduce syscalls.

File:

• trunk/kernel/syscalls/sys_thread_wakeup.c (modified) (2 diffs)

trunk/kernel/syscalls/sys_thread_wakeup.c

@@ -1 +1 @@
 /*
- * kern/sys_thread_wakeup.c - wakeup all indicated threads
+ * sys_thread_wakeup.c - wakeup all indicated threads
  * 
- * Copyright (c) 2008,2009,2010,2011,2012 Ghassan Almaless
- * Copyright (c) 2011,2012 UPMC Sorbonne Universites
+ * Author    Alain Greiner (2016,2017)
  *
- * This file is part of ALMOS-kernel.
+ * Copyright (c) UPMC Sorbonne Universites
  *
- * ALMOS-kernel is free software; you can redistribute it and/or modify it
+ * This file is part of ALMOS-MKH.
+ *
+ * ALMOS-MKH is free software; you can redistribute it and/or modify it
  * under the terms of the GNU General Public License as published by
  * the Free Software Foundation; version 2.0 of the License.
  *
- * ALMOS-kernel is distributed in the hope that it will be useful, but
+ * ALMOS-MKH is distributed in the hope that it will be useful, but
  * WITHOUT ANY WARRANTY; without even the implied warranty of
  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
@@ -17 +18 @@
  *
  * You should have received a copy of the GNU General Public License
- * along with ALMOS-kernel; if not, write to the Free Software Foundation,
+ * along with ALMOS-MKH; if not, write to the Free Software Foundation,
  * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
  */
 
+#include <hal_types.h>
+#include <thread.h>
+#include <printk.h>
+#include <process.h>
 #include <errno.h>
-#include <kmagics.h>
-#include <cpu.h>
-#include <kdmsg.h>
-#include <cluster.h>
-#include <task.h>
-#include <scheduler.h>
-#include <thread.h>
 
-/* 
- * FIXME: define spinlock_rdlock() so all locking on task->th_lock 
- * becoms rdlock but on join/detach/destroy 
- */
-int sys_thread_wakeup(pthread_t tid, pthread_t *tid_tbl, uint_t count)
+//////////////////////////////////////
+int sys_thread_wakeup( trdid_t trdid )
 {
-        struct task_s *task;
-        struct thread_s *this;
-        struct thread_s *target;
-        pthread_t tbl[100];
-        void *listner;
-        uint_t event;
-        sint_t i;
-        error_t err;
+        thread_t  * this    = CURRENT_THREAD;
+    process_t * process = this->process;
 
-        this = current_thread;
-        task = this->task;
-        i = -1;
+    // get target thread ltid and cxy
+    ltid_t   target_ltid = LTID_FROM_TRDID( trdid );
+    cxy_t    target_cxy  = CXY_FROM_TRDID( trdid );
 
-        if(tid_tbl != NULL)
+    // check trdid argument
+        if( (target_ltid >= CONFIG_THREAD_MAX_PER_CLUSTER) || cluster_is_undefined( target_cxy ) )  
         {
-                if((NOT_IN_USPACE((uint_t)tid_tbl + (count*sizeof(pthread_t)))) || 
-                   (count == 0) || (count > 100))
-                {
-                        err = -1;
-                        goto fail_tid_tbl;
-                }
-
-                if((err = cpu_copy_from_uspace(&tbl[0], tid_tbl, sizeof(pthread_t*) * count))) 
-                        goto fail_usapce;
-
-                if(tbl[0] != tid)
-                {
-                        err = -2;
-                        goto fail_first_tid;
-                }
-        }
-        else
-        {
-                count = 1;
-                tbl[0] = tid;
+        printk("\n[ERROR] in %s : illegal trdid argument\n", __FUNCTION__ );
+                this->errno = EINVAL;
+                return -1;
         }
 
-        for(i = 0; i < count; i++)
-        {
-                tid = tbl[i];
+    // get extended pointer on target thread
+    xptr_t thread_xp = thread_get_xptr( process->pid , trdid );
 
-                if(tid > task->max_order)
-                {
-                        err = -3;
-                        goto fail_tid;
-                }
+    if( thread_xp == XPTR_NULL )
+    {
+        printk("\n[ERROR] in %s : cannot find thread %x in process %x/n",
+               __FUNCTION__ , trdid , CURRENT_THREAD->process->pid );
+        CURRENT_THREAD->errno = EINVAL;
+        return -1;
+    }
 
-                target = task->th_tbl[tid];
-   
-                if((target == NULL) || (target->signature != THREAD_ID))
-                {
-                        err = -4;
-                        goto fail_target;
-                }
+    // unblock target thread
+    thread_unblock( thread_xp , THREAD_BLOCKED_GLOBAL );
 
-                listner = sched_get_listner(target, SCHED_OP_UWAKEUP);
-                event = sched_event_make(target,SCHED_OP_UWAKEUP);
-    
-                if(this->info.isTraced == true)
-                {
-                        printk(INFO,"%s: tid %d --> tid %d [%d][%d]\n", 
-                               __FUNCTION__, 
-                               this->info.order, 
-                               tid, 
-                               cpu_time_stamp(),
-                               i);
-                }
-
-                sched_event_send(listner,event);
-                cpu_wbflush();
-        }
-
-        return 0;
-
-fail_target:
-fail_tid:
-fail_first_tid:
-fail_usapce:
-fail_tid_tbl:
-
-        printk(INFO, "%s: cpu %d, pid %d, tid %x, i %d, count %d, ttid %x, request has failed with err %d [%d]\n",
-               __FUNCTION__,
-               cpu_get_id(),
-               task->pid,
-               this,
-               i,
-               count,
-               tid,
-               err,
-               cpu_time_stamp());
-  
-        this->info.errno = EINVAL;
-        return -1;
-}
+    return 0;
+}  // end sys_thread_wakeup()