Changeset 635 for trunk/kernel/kern/process.c

Timestamp:

Jun 26, 2019, 11:42:37 AM (5 years ago)

Author:

alain

Message:

This version is a major evolution: The physical memory allocators,
defined in the kmem.c, ppm.c, and kcm.c files have been modified
to support remote accesses. The RPCs that were previously user
to allocate physical memory in a remote cluster have been removed.
This has been done to cure a dead-lock in case of concurrent page-faults.

This version 2.2 has been tested on a (4 clusters / 2 cores per cluster)
TSAR architecture, for both the "sort" and the "fft" applications.

File:

• trunk/kernel/kern/process.c (modified) (27 diffs)

trunk/kernel/kern/process.c

@@ -72 +72 @@
 process_t * process_alloc( void )
 {
-        kmem_req_t   req;
-
-    req.type  = KMEM_PROCESS;
-        req.size  = sizeof(process_t);
+        kmem_req_t req;
+
+    req.type  = KMEM_KCM;
+        req.order = bits_log2( sizeof(process_t) );
         req.flags = AF_KERNEL;
 
-    return (process_t *)kmem_alloc( &req );
+    return kmem_alloc( &req );
 }
 
@@ -86 +86 @@
     kmem_req_t  req;
 
-        req.type = KMEM_PROCESS;
+        req.type = KMEM_KCM;
         req.ptr  = process;
         kmem_free( &req );
@@ -166 +166 @@
 #endif
 
-    // initialize VSL locks
+    // initialize VSL lock
         remote_rwlock_init( XPTR( local_cxy , &vmm->vsl_lock ) , LOCK_VMM_VSL );
 
-    // register kernel vsegs in VMM as required by the architecture
+    // register kernel vsegs in user process VMM as required by the architecture
     error = hal_vmm_kernel_update( process );
     if( error ) 
@@ -179 +179 @@
 #if (DEBUG_PROCESS_REFERENCE_INIT & 1)
 if( DEBUG_PROCESS_REFERENCE_INIT < cycle )
-printk("\n[%s] thread[%x,%x] registered kernel vsegs for process %x\n",
+printk("\n[%s] thread[%x,%x] registered kernel vsegs in VSL for process %x\n",
 __FUNCTION__, parent_pid, this->trdid, pid );
 #endif
@@ -374 +374 @@
 printk("\n[%s] thread[%x,%x] exit for process %x / cycle %d\n", 
 __FUNCTION__, parent_pid, this->trdid, pid, cycle );
+#endif
+
+#if (DEBUG_PROCESS_REFERENCE_INIT & 1)
+hal_vmm_display( parent_xp , false );
+hal_vmm_display( XPTR( local_cxy , process ) , false );
 #endif
 
@@ -1088 +1093 @@
     }
 }
+
 ////////////////////////////////////////////////////
 error_t process_fd_register( xptr_t      process_xp,
@@ -1356 +1362 @@
 
 #if DEBUG_PROCESS_MAKE_FORK
-uint32_t cycle   = (uint32_t)hal_get_cycles();
+uint32_t   cycle;
 thread_t * this  = CURRENT_THREAD;
 trdid_t    trdid = this->trdid;
 pid_t      pid   = this->process->pid;
+#endif
+
+#if( DEBUG_PROCESS_MAKE_FORK & 1 )
+cycle   = (uint32_t)hal_get_cycles();
 if( DEBUG_PROCESS_MAKE_FORK < cycle )
 printk("\n[%s] thread[%x,%x] enter / cluster %x / cycle %d\n",
@@ -1367 +1377 @@
     // allocate a process descriptor
     process = process_alloc();
+
     if( process == NULL )
     {
@@ -1427 +1438 @@
 printk("\n[%s] thread[%x,%x] copied VMM from parent to child / cycle %d\n",
 __FUNCTION__, pid, trdid, cycle );
+hal_vmm_display( XPTR( local_cxy , process ) , true );
 #endif
 
@@ -1438 +1450 @@
 cycle = (uint32_t)hal_get_cycles();
 if( DEBUG_PROCESS_MAKE_FORK < cycle )
-printk("\n[%s] thread[%x,%x] / child takes TXT ownership / cycle %d\n",
-__FUNCTION__ , pid, trdid, cycle );
+printk("\n[%s] thread[%x,%x] / child_process %x takes TXT ownership / cycle %d\n",
+__FUNCTION__ , pid, trdid, new_pid, cycle );
 #endif
 
@@ -1471 +1483 @@
 #endif
 
-    // set COW flag in DATA, ANON, REMOTE vsegs for parent process VMM
+    // set COW flag in DATA, ANON, REMOTE vsegs in parent process VMM
     // this includes all parent process copies in all clusters
     if( parent_process_cxy == local_cxy )   // reference is local
@@ -1489 +1501 @@
 cycle = (uint32_t)hal_get_cycles();
 if( DEBUG_PROCESS_MAKE_FORK < cycle )
-printk("\n[%s] thread[%x,%x] set COW in parent and child / cycle %d\n",
+printk("\n[%s] thread[%x,%x] set COW in DATA / ANON / REMOTE for parent and child / cycle %d\n",
 __FUNCTION__, pid, trdid, cycle );
 #endif
@@ -1546 +1558 @@
 #if DEBUG_PROCESS_MAKE_EXEC
 uint32_t cycle = (uint32_t)hal_get_cycles();
-if( local_cxy == 0x11 )
+if( DEBUG_PROCESS_MAKE_EXEC < cycle )
 printk("\n[%s] thread[%x,%x] enters for %s / cycle %d\n",
 __FUNCTION__, pid, thread->trdid, path, cycle );
@@ -1569 +1581 @@
 #if (DEBUG_PROCESS_MAKE_EXEC & 1)
 cycle = (uint32_t)hal_get_cycles();
-if( local_cxy == 0x11 )
+if( DEBUG_PROCESS_MAKE_EXEC < cycle )
 printk("\n[%s] thread[%x,%x] opened file <%s> / cycle %d\n",
 __FUNCTION__, pid, thread->trdid, path, cycle );
@@ -1579 +1591 @@
 #if (DEBUG_PROCESS_MAKE_EXEC & 1)
 cycle = (uint32_t)hal_get_cycles();
-if( local_cxy == 0x11 )
+if( DEBUG_PROCESS_MAKE_EXEC < cycle )
 printk("\n[%s] thread[%x,%x] deleted existing threads / cycle %d\n",
 __FUNCTION__, pid, thread->trdid, cycle );
@@ -1589 +1601 @@
 #if( DEBUG_PROCESS_MAKE_EXEC & 1 )
 cycle = (uint32_t)hal_get_cycles();
-if( local_cxy == 0x11 )
+if( DEBUG_PROCESS_MAKE_EXEC < cycle )
 printk("\n[%s] thread[%x,%x] completed VMM reset / cycle %d\n",
 __FUNCTION__, pid, thread->trdid, cycle );
@@ -1606 +1618 @@
 #if( DEBUG_PROCESS_MAKE_EXEC & 1 )
 cycle = (uint32_t)hal_get_cycles();
-if( local_cxy == 0x11 )
+if( DEBUG_PROCESS_MAKE_EXEC < cycle )
 printk("\n[%s] thread[%x,%x] registered args/envs vsegs / cycle %d\n",
 __FUNCTION__, pid, thread->trdid, cycle );
@@ -1624 +1636 @@
 #if( DEBUG_PROCESS_MAKE_EXEC & 1 )
 cycle = (uint32_t)hal_get_cycles();
-if( local_cxy == 0x11 )
+if( DEBUG_PROCESS_MAKE_EXEC < cycle )
 printk("\n[%s] thread[%x,%x] registered code/data vsegs / cycle %d\n",
 __FUNCTION__, pid, thread->trdid, cycle );
@@ -1674 +1686 @@
         hal_core_sleep();
     }
+
+#if (DEBUG_PROCESS_ZERO_CREATE & 1)
+if( DEBUG_PROCESS_ZERO_CREATE < cycle )
+printk("\n[%s] allocated pid %x in cluster %x\n", __FUNCTION__, pid, local_cxy );
+#endif
 
     // initialize PID, REF_XP, PARENT_XP, and STATE
@@ -1684 +1701 @@
     process->term_state = 0;
 
-    // initilise VSL as empty
+    // initialize VSL as empty
     vmm->vsegs_nr = 0;
         xlist_root_init( XPTR( local_cxy , &vmm->vsegs_root ) );
 
-    // initialise GPT as empty
+#if (DEBUG_PROCESS_ZERO_CREATE & 1)
+if( DEBUG_PROCESS_ZERO_CREATE < cycle )
+printk("\n[%s] initialized VSL empty in cluster %x\n", __FUNCTION__, local_cxy );
+#endif
+
+    // initialize GPT as empty
     error = hal_gpt_create( &vmm->gpt );
+
     if( error ) 
     {
@@ -1695 +1718 @@
         hal_core_sleep();
     }
+
+#if (DEBUG_PROCESS_ZERO_CREATE & 1)
+if( DEBUG_PROCESS_ZERO_CREATE < cycle )
+printk("\n[%s] initialized GPT empty in cluster %x\n", __FUNCTION__, local_cxy );
+#endif
 
     // initialize VSL and GPT locks
@@ -1701 +1729 @@
     // create kernel vsegs in GPT and VSL, as required by the hardware architecture
     error = hal_vmm_kernel_init( info );
+
     if( error ) 
     {
@@ -1706 +1735 @@
         hal_core_sleep();
     }
+
+#if (DEBUG_PROCESS_ZERO_CREATE & 1)
+if( DEBUG_PROCESS_ZERO_CREATE < cycle )
+printk("\n[%s] initialized hal specific VMM in cluster%x\n", __FUNCTION__, local_cxy );
+#endif
 
     // reset th_tbl[] array and associated fields
@@ -1716 +1750 @@
     rwlock_init( &process->th_lock , LOCK_PROCESS_THTBL );
 
+#if (DEBUG_PROCESS_ZERO_CREATE & 1)
+if( DEBUG_PROCESS_ZERO_CREATE < cycle )
+printk("\n[%s] initialized th_tbl[] in cluster%x\n", __FUNCTION__, local_cxy );
+#endif
 
     // reset children list as empty
@@ -1722 +1760 @@
     remote_queuelock_init( XPTR( local_cxy , &process->children_lock ),
                            LOCK_PROCESS_CHILDREN );
+
+#if (DEBUG_PROCESS_ZERO_CREATE & 1)
+if( DEBUG_PROCESS_ZERO_CREATE < cycle )
+printk("\n[%s] initialized children list in cluster%x\n", __FUNCTION__, local_cxy );
+#endif
 
     // register kernel process in cluster manager local_list
@@ -1759 +1802 @@
     // allocates memory for process descriptor from local cluster
         process = process_alloc(); 
+
+
     if( process == NULL )
     {
@@ -1840 +1885 @@
 
 #if (DEBUG_PROCESS_INIT_CREATE & 1)
-hal_vmm_display( process , true );
+hal_vmm_display( XPTR( local_cxy , process ) , true );
 #endif