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

Timestamp:

Apr 10, 2019, 10:09:39 AM (5 years ago)

Author:

alain

Message:

Fix a bug in the vmm_remove_vseg() function: the physical pages
associated to an user DATA vseg were released to the kernel when
the target process descriptor was in the reference cluster.
This physical pages release should be done only when the page
forks counter value is zero.
All other modifications are cosmetic.

File:

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

trunk/kernel/kern/rpc.c

@@ -24 +24 @@
 #include <kernel_config.h>
 #include <hal_kernel_types.h>
+#include <hal_vmm.h>
 #include <hal_atomic.h>
 #include <hal_remote.h>
@@ -52 +53 @@
     &rpc_pmem_get_pages_server,            // 0
     &rpc_pmem_release_pages_server,        // 1
-    &rpc_undefined,                        // 2    unused slot
+    &rpc_ppm_display_server,               // 2
     &rpc_process_make_fork_server,         // 3
     &rpc_user_dir_create_server,           // 4
@@ -81 +82 @@
     &rpc_vmm_create_vseg_server,           // 27
     &rpc_vmm_set_cow_server,               // 28
-    &rpc_hal_vmm_display_server,               // 29
+    &rpc_hal_vmm_display_server,           // 29
 };
 
@@ -88 +89 @@
     "PMEM_GET_PAGES",            // 0
     "PMEM_RELEASE_PAGES",        // 1
-    "undefined",                 // 2
+    "PPM_DISPLAY",               // 2
     "PROCESS_MAKE_FORK",         // 3
     "USER_DIR_CREATE",           // 4
@@ -566 +567 @@
 
 /////////////////////////////////////////////////////////////////////////////////////////
-// [2]      undefined slot
-/////////////////////////////////////////////////////////////////////////////////////////
+// [2]            Marshaling functions attached to RPC_PPM_DISPLAY    
+/////////////////////////////////////////////////////////////////////////////////////////
+
+/////////////////////////////////////////
+void rpc_ppm_display_client( cxy_t  cxy )
+{
+#if DEBUG_RPC_PPM_DISPLAY
+thread_t * this = CURRENT_THREAD;
+uint32_t cycle = (uint32_t)hal_get_cycles();
+if( cycle > DEBUG_RPC_PPM_DISPLAY )
+printk("\n[%s] thread[%x,%x] on core %d enter / cycle %d\n",
+__FUNCTION__, this->process->pid, this->trdid, this->core->lid , cycle );
+#endif
+
+    uint32_t responses = 1;
+
+    // initialise RPC descriptor header 
+    rpc_desc_t  rpc;
+    rpc.index    = RPC_PPM_DISPLAY;
+    rpc.blocking = true;
+    rpc.rsp      = &responses;
+
+    // register RPC request in remote RPC fifo
+    rpc_send( cxy , &rpc );
+
+#if DEBUG_RPC_PPM_DISPLAY
+cycle = (uint32_t)hal_get_cycles();
+if( cycle > DEBUG_RPC_PPM_DISPLAY )
+printk("\n[%s] thread[%x,%x] on core %d exit / cycle %d\n",
+__FUNCTION__, this->process->pid, this->trdid, this->core->lid, cycle );
+#endif
+}
+
+////////////////////////////////////////////////////////////////////
+void rpc_ppm_display_server( xptr_t __attribute__((__unused__)) xp )
+{
+#if DEBUG_RPC_PPM_DISPLAY
+thread_t * this = CURRENT_THREAD;
+uint32_t cycle = (uint32_t)hal_get_cycles();
+if( cycle > DEBUG_RPC_PPM_DISPLAY )
+printk("\n[%s] thread[%x,%x] on core %d enter / cycle %d\n",
+__FUNCTION__, this->process->pid, this->trdid, this->core->lid , cycle );
+#endif
+
+    // call local kernel function
+    ppm_display();
+
+#if DEBUG_RPC_PPM_DISPLAY
+cycle = (uint32_t)hal_get_cycles();
+if( cycle > DEBUG_RPC_PPM_DISPLAY )
+printk("\n[%s] thread[%x,%x] on core %d exit / cycle %d\n",
+__FUNCTION__, this->process->pid, this->trdid, this->core->lid, cycle );
+#endif
+}
 
 /////////////////////////////////////////////////////////////////////////////////////////