Changeset 428 for trunk/kernel/kern/rpc.c

Timestamp:

Jan 29, 2018, 6:08:07 PM (6 years ago)

Author:

alain

Message:

blip

File:

• trunk/kernel/kern/rpc.c (modified) (6 diffs)

trunk/kernel/kern/rpc.c

@@ -79 +79 @@
     &rpc_sched_display_server,          // 27
     &rpc_vmm_set_cow_server,            // 28
-    &rpc_undefined,                     // 29
+    &rpc_vmm_display_server,            // 29
 };
 
@@ -85 +85 @@
 void __attribute__((noinline)) rpc_undefined()
 {
-        panic("called in cluster %x", local_cxy );
+        assert( false , __FUNCTION__ , "called in cluster %x", local_cxy );
 }
 
@@ -1036 +1036 @@
 
     // call relevant kernel function
-    if      (action == DELETE_ALL_THREADS  ) process_delete ( process , client_xp ); 
-    else if (action == BLOCK_ALL_THREADS   ) process_block  ( process , client_xp ); 
-    else if (action == UNBLOCK_ALL_THREADS ) process_unblock( process             );
+    if      (action == DELETE_ALL_THREADS  ) process_delete_threads ( process , client_xp ); 
+    else if (action == BLOCK_ALL_THREADS   ) process_block_threads  ( process , client_xp ); 
+    else if (action == UNBLOCK_ALL_THREADS ) process_unblock_threads( process             );
 
     // decrement the responses counter in RPC descriptor,
@@ -2266 +2266 @@
 
     // get input arguments from client RPC descriptor
-    lid_t lid = (lid_t)hal_remote_lw( XPTR(cxy , &desc->args[0]));
+    lid_t lid = (lid_t)hal_remote_lwd( XPTR(cxy , &desc->args[0]));
     
     // call local kernel function
@@ -2321 +2321 @@
 
     // get input arguments from client RPC descriptor
-    process = (process_t *)(intptr_t)hal_remote_lpt( XPTR(cxy , &desc->args[0]));
+    process = (process_t *)(intptr_t)hal_remote_lwd( XPTR(cxy , &desc->args[0]));
     
     // call local kernel function
@@ -2331 +2331 @@
 }
 
-
+/////////////////////////////////////////////////////////////////////////////////////////
+// [29]          Marshaling functions attached to RPC_VMM_DISPLAY (blocking)
+/////////////////////////////////////////////////////////////////////////////////////////
+
+/////////////////////////////////////////////
+void rpc_vmm_display_client( cxy_t       cxy,
+                             process_t * process,
+                             bool_t      detailed )
+{
+    rpc_dmsg("\n[DBG] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
+    __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
+    CURRENT_THREAD->core->lid , hal_time_stamp() );
+
+    assert( (cxy != local_cxy) , __FUNCTION__ , "target cluster is not remote\n");
+
+    // initialise RPC descriptor header 
+    rpc_desc_t  rpc;
+    rpc.index    = RPC_VMM_DISPLAY;
+    rpc.response = 1;
+    rpc.blocking = true;
+
+    // set input arguments in RPC descriptor 
+    rpc.args[0] = (uint64_t)(intptr_t)process;
+    rpc.args[1] = (uint64_t)detailed;
+
+    // register RPC request in remote RPC fifo (blocking function)
+    rpc_send( cxy , &rpc );
+
+    rpc_dmsg("\n[DBG] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
+    __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
+    CURRENT_THREAD->core->lid , hal_time_stamp() );
+}
+
+////////////////////////////////////////
+void rpc_vmm_display_server( xptr_t xp )
+{
+    rpc_dmsg("\n[DBG] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
+    __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
+    CURRENT_THREAD->core->lid , hal_time_stamp() );
+
+    process_t * process;
+    bool_t      detailed;
+
+    // get client cluster identifier and pointer on RPC descriptor
+    cxy_t        cxy  = (cxy_t)GET_CXY( xp );
+    rpc_desc_t * desc = (rpc_desc_t *)GET_PTR( xp );
+
+    // get input arguments from client RPC descriptor
+    process  = (process_t *)(intptr_t)hal_remote_lwd( XPTR(cxy , &desc->args[0]));
+    detailed = (bool_t)               hal_remote_lwd( XPTR(cxy , &desc->args[1]));
+    
+    // call local kernel function
+    vmm_display( process , detailed );
+
+    rpc_dmsg("\n[DBG] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
+    __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
+    CURRENT_THREAD->core->lid , hal_time_stamp() );
+}
+
+