Changeset 641 for trunk/kernel/libk/user_dir.c

Timestamp:

Oct 10, 2019, 1:42:04 PM (5 years ago)

Author:

alain

Message:

• Fix several bugs.
• Introduce the "stat" command in KSH.

This almos-mkh version sucessfully executed the FFT application
(65536 complex points) on the TSAR architecture from 1 to 64 cores.

File:

• trunk/kernel/libk/user_dir.c (modified) (8 diffs)

trunk/kernel/libk/user_dir.c

@@ -145 +145 @@
     }
 
-    // Build an initialize the dirent array as a list of pages.
+    // Build and initialize the dirent array as a list of pages.
     // For each iteration in this while loop:
     // - allocate one physical 4 Kbytes (64 dirent slots)
@@ -174 +174 @@
         }
 
-        // call the relevant FS specific function to copy up to 64 dirents in page
+        // call the relevant FS specific function to copy dirents in page
         error = vfs_fs_get_user_dir( inode,
                                      base,
@@ -210 +210 @@
 #endif
 
-    // compute required vseg size for a 64 bytes dirent
+    // compute required vseg size
     vseg_size = total_dirents << 6;
 
@@ -254 +254 @@
 // check vseg size
 assert( (total_pages == hal_remote_l32( XPTR( ref_cxy , &vseg->vpn_size ) ) ),
-"unconsistent vseg size for dirent array" );
+"unconsistent vseg size for dirent array " );
 
     // build extended pointer on reference process GPT
@@ -294 +294 @@
 
             // delete the vseg
-            if( ref_cxy == local_cxy)  vmm_remove_vseg( ref_ptr, vseg );
-            else                       rpc_vmm_remove_vseg_client( ref_cxy, ref_ptr, vseg );
+            intptr_t base = (intptr_t)hal_remote_lpt( XPTR( ref_cxy , &vseg->min ) );
+            rpc_vmm_remove_vseg_client( ref_cxy, ref_pid, base );
          
             // release the user_dir descriptor
@@ -434 +434 @@
     // to wait all RPC responses, and will be unblocked by the last RPC server thread.
     // It allocates a - shared - RPC descriptor in the stack,  because all parallel
-    // server threads use the same input arguments, and the same response field.
+    // server threads use the same input arguments, and there is no out argument.
 
     // get owner cluster identifier and process lpid
@@ -454 +454 @@
 
     // initialize a shared RPC descriptor
-    // can be shared, because no out arguments
     rpc.rsp       = &responses;
-    rpc.blocking  = false;
+    rpc.blocking  = false;                  // non blocking behaviour for rpc_send()
     rpc.index     = RPC_VMM_REMOVE_VSEG;
     rpc.thread    = this;
@@ -476 +475 @@
         hal_atomic_add( &responses , 1 );
 
+#if (DEBUG_USER_DIR & 1)
+uint32_t cycle = (uint32_t)hal_get_cycles();
+if( cycle > DEBUG_USER_DIR )
+printk("\n[%s] thread[%x,%x] register RPC request in cluster %x\n",
+__FUNCTION__, this->process->pid, this->trdid, process_cxy );
+#endif
+
         // send RPC to target cluster  
         rpc_send( process_cxy , &rpc );