Changeset 5 for trunk/kernel/kern/rpc.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/rpc.c (modified) (10 diffs)

trunk/kernel/kern/rpc.c

@@ -33 +33 @@
 #include <core.h>
 #include <mapper.h>
-#include <device.h>
+#include <chdev.h>
 #include <bits.h>
 #include <thread.h>
@@ -55 +55 @@
     &rpc_thread_user_create_server,     // 4
     &rpc_thread_kernel_create_server,   // 5
-    &rpc_icu_wti_alloc_server,          // 6                       
-    &rpc_device_alloc_server,           // 7
+    &rpc_undefined,                     // 6                       
+    &rpc_undefined,                     // 7
     &rpc_undefined,                     // 8
     &rpc_undefined,                     // 9
@@ -1018 +1018 @@
 
 /////////////////////////////////////////////////////////////////////////////////////////
-//               Marshaling functions attached to RPC_ICU_WTI_ALLOC 
-/////////////////////////////////////////////////////////////////////////////////////////
-
-//////////////////////////////////////////////
-void rpc_icu_wti_alloc_client( cxy_t      cxy,
-                               uint32_t * wti_id )    // out
-{
-    // RPC must be remote
-    if( cxy == local_cxy ) 
-    {
-        printk("PANIC in %s : target is not remote\n", __FUNCTION__ );
-        hal_core_sleep();
-    }
-
-    // initialise RPC descriptor header 
-    rpc_desc_t  rpc;
-    rpc.index    = RPC_ICU_WTI_ALLOC;
-    rpc.response = 1;
-
-    // register RPC request in remote RPC fifo 
-    rpc_send_sync( cxy , &rpc );
-
-    // get output argument from rpc descriptor
-    *wti_id = (uint32_t)rpc.args[0];
-}
-
-//////////////////////////////////////////
-void rpc_icu_wti_alloc_server( xptr_t xp )
-{
-    uint32_t      wti_id;
-
-    // get client cluster identifier and pointer on RPC descriptor
-    cxy_t        client_cxy  = (cxy_t)GET_CXY( xp );
-    rpc_desc_t * desc = (rpc_desc_t *)GET_PTR( xp );
-
-    // call icu_wti_alloc() function
-    wti_id = dev_icu_wti_alloc();
-
-    // set output argument
-    hal_remote_swd( XPTR( client_cxy , &desc->args[0] ) , (uint64_t)wti_id);
-}
-
-/////////////////////////////////////////////////////////////////////////////////////////
-//               Marshaling functions attached to RPC_DEVICE_ALLOC 
-/////////////////////////////////////////////////////////////////////////////////////////
-
-/////////////////////////////////////////////
-void rpc_device_alloc_client( cxy_t     cxy,
-                              xptr_t  * dev_xp,      // out
-                              error_t * error )      // out
-{
-    // RPC must be remote
-    if( cxy == local_cxy ) 
-    {
-        printk("PANIC in %s : target is not remote\n", __FUNCTION__ );
-        hal_core_sleep();
-    }
-
-    // initialise RPC descriptor header 
-    rpc_desc_t  rpc;
-    rpc.index    = RPC_DEVICE_ALLOC;
-    rpc.response = 1;
-
-    // register RPC request in remote RPC fifo 
-    rpc_send_sync( cxy , &rpc );
-
-    // get output argument from rpc descriptor
-    *dev_xp = (xptr_t)rpc.args[0];
-    *error  = (error_t)rpc.args[1];
-}    
-
-/////////////////////////////////////////
-void rpc_device_alloc_server( xptr_t xp )
-{
-    error_t      error;
-    kmem_req_t   req;
-    device_t   * dev_ptr;  
-    xptr_t       dev_xp;
-
-    // get client cluster identifier and pointer on RPC descriptor
-    cxy_t        client_cxy  = (cxy_t)GET_CXY( xp );
-    rpc_desc_t * desc = (rpc_desc_t *)GET_PTR( xp );
-
-    // allocate memory for a device descriptor
-    req.type   = KMEM_DEVICE;
-    req.flags  = AF_ZERO;
-    dev_ptr    = (device_t *)kmem_alloc( &req );
-
-    // set output arguments
-    error  = ( dev_ptr == NULL );
-    dev_xp = XPTR( local_cxy , dev_ptr );
-    hal_remote_swd( XPTR( client_cxy , &desc->args[0] ) , (uint64_t)dev_xp );
-    hal_remote_swd( XPTR( client_cxy , &desc->args[1] ) , (uint64_t)error );
-}
-
-
-/////////////////////////////////////////////////////////////////////////////////////////
 //               Marshaling functions attached to RPC_FATFS_GET_CLUSTER 
 /////////////////////////////////////////////////////////////////////////////////////////
@@ -1190 +1093 @@
     bool_t     first;
     reg_t      sr_save;
+
+printk("\n@@@ coucou 0\n");
 
     // get client CPU and cluster coordinates
@@ -1220 +1125 @@
     while( error );
  
+printk("\n@@@ coucou 1\n");
+
     rpc_dmsg("\n[INFO] %s on core %d in cluster %x sent RPC %p to cluster %x\n", 
               __FUNCTION__ , client_lid , client_cxy , rpc , server_cxy );
@@ -1240 +1147 @@
         }
 
+printk("\n@@@ coucou 2\n");
+
         // activate preemption to allow incoming RPC and avoid deadlock
         if( this->type == THREAD_RPC ) hal_enable_irq( &sr_save );
@@ -1248 +1157 @@
         if( rpc->response == 0 ) break;
     }
+
+printk("\n@@@ coucou 3\n");
 
     // restore preemption
@@ -1425 +1336 @@
     error_t      error;
 
-    // do nothing if light lock already taken or FIFO empty  
+    // calling thread does nothing if light lock already taken or FIFO empty  
         if( (rpc_fifo->owner != 0) || (local_fifo_is_empty( &rpc_fifo->fifo )) )
     {
@@ -1431 +1342 @@
     }
 
-        // The calling thread try to take the light lock,
-    // and activate an RPC thread if success
+        // calling thread tries to take the light lock,
+    // and activates an RPC thread if success
     if( hal_atomic_test_set( &rpc_fifo->owner , this->trdid ) )
         {
@@ -1452 +1363 @@
         return false;
     }
-} // end __rpc_check()
+} // end rpc_check()