Changeset 5 for trunk/kernel/kern/signal.c

Timestamp:

Apr 26, 2017, 2:11:56 PM (7 years ago)

Author:

alain

Message:

Introduce the chdev_t structure in place of the device_t structure.

File:

• trunk/kernel/kern/signal.c (modified) (4 diffs)

trunk/kernel/kern/signal.c

@@ -2 +2 @@
  * signal.c - signal-management related operations implementation
  * 
- * Author  Ghassan Almaless (2008,2009,2010,2011,2012)
- *         Mohamed Lamine Karaoui (2015)
- *         Alain Greiner    (2016)
+ * Author  Alain Greiner    (2016,2017)
  *
  * Copyright (c) UPMC Sorbonne Universites
@@ -55 +53 @@
 }
 
-////////////////////////////////////////
-error_t signal_init( thread_t * thread )
-{
-        thread->info.sig_state = 0;
-        thread->info.sig_mask  = CURRENT_THREAD->info.sig_mask;
-        return 0;
-}
-
-////////////////////////////////////////////////////
-static error_t signal_rise_all( process_t * process, 
-                                uint32_t    sig )
+//////////////////////////////////////
+void signal_rise( process_t * process, 
+                  uint32_t    sig )
 {
         thread_t     * thread;
@@ -83 +73 @@
                         __FUNCTION__, process->th_nr , process->pid );
 
-        return 0;
-}
-
-////////////////////////////////////////////////////
-static error_t signal_rise_one( process_t * process,
-                                uint32_t    sig )
-{
-        thread_t * thread;
-
-        spinlock_lock( &process->th_lock );
-
-//mdify to current_thread, not the one pointed by the sig_mgr ?
-        if(process->sig_mgr.handler == NULL)
-                thread = list_first(&process->th_root, struct thread_s, rope);
-        else
-                thread = process->sig_mgr.handler;
-
-        spinlock_lock( &thread->lock );
-        thread->info.sig_state |= (1 << sig);
-        spinlock_unlock( &thread->lock );
-
-        spinlock_unlock( &process->th_lock );
-
-    sig_dmsg("\n[INFO] %s : Thread %u of process %u has received signal %u. sig_state = %x\n",        \
-                        __FUNCTION__, thread_current_cpu(thread)->gid,                          \
-                        process->pid, sig, thread->info.sig_state);
-
-        return 0;
-}
-
+}  // end signal_rise()
+
+///////////////////////////////////////////
 RPC_DECLARE( __signal_rise,                             \
                 RPC_RET( RPC_RET_PTR(error_t, err)),    \
@@ -183 +146 @@
 }
 
-//////////////////////////////////
-error_t signal_rise( pid_t    pid, 
-                     cxy_t    location, 
-                     uint32_t sig)
-{
-        error_t err;
-
-        /* Check location error */
-        if ( location == CID_NULL )
-        {
-                err = ESRCH;
-                printk(WARNING, "%s: there is no process with pid %u\n", \
-                                __FUNCTION__, pid);
-                return err;
-        }
-
-        err = EAGAIN;
-        RCPC( location, RPC_PRIO_SIG_RISE, __signal_rise,       \
-                        RPC_RECV( RPC_RECV_OBJ(err) ),          \
-                        RPC_SEND( RPC_SEND_OBJ(pid),            \
-                                  RPC_SEND_OBJ(sig))            \
-            );
-
-        return err;
+///////////////////////////////
+error_t sys_kill( pid_t    pid, 
+                  uint32_t sig)
+{
+    cxy_t       owner_cxy;    // process owner cluster
+    lpid_t      owner_lpid;   // local process identifier 
+    xptr_t      root_xp;      // extended pointer on root of xlist of process copies
+    xptr_t      lock_xp;      // extended pointer on remote_spinlock protecting this list
+    xptr_t      iter_xp;      // iterator for process copies list
+    xptr_t      process_xp;   // local pointer on process copy 
+    cxy_t       process_cxy;  // cluster of process copy
+    process_t * process_ptr;  // local pointer on process copy 
+        error_t     error;
+
+    // get local pointer on local cluster manager
+    cluster_t * cluster = LOCAL_CLUSTER;
+
+    // get owner process cluster and lpid
+    owner_cxy  = CXY_FROM_PID( pid );
+    owner_lpid = LPID_FROM_PID( pid );
+
+    // get extended pointers on copies root and lock
+    root_xp = XPTR( owner_cxy , &cluster->copies_root[lpid] );
+    lock_xp = XPTR( owner_cxy , &cluster->copies_lock[lpid] );
+
+    // take the lock protecting the copies
+    remote_spinlock_lock( lock_xp );
+
+    // TODO the loop below sequencialize the RPCs
+    // they could be pipelined...
+ 
+    // traverse the list of copies
+    XLIST_FOREACH( root_xp , iter_xp )
+    {
+        process_xp  = XLIST_ELEMENT( iter_xp , process_t , copies_list );
+        process_cxy = GET_CXY( process_xp );
+        process_ptr = (process_t *)GET_PTR( process_xp );
+
+        if( process_xy == local_cxy )   // process copy is local
+        {
+            error = signal_rise( process_ptr , sig );
+        }
+        else                           // process copy is remote
+        {
+            rpc_signal_rise_client( process_cxy , process_ptr , sig );
+        }
+    }
+
+        return 0;
 }