Changeset 436 for trunk/kernel/kern/cluster.c

Timestamp:

Mar 7, 2018, 9:02:03 AM (7 years ago)

Author:

alain

Message:

1) improve the threads and process destruction mechanism.
2) introduce FIFOs in the soclib_tty driver.

File:

• trunk/kernel/kern/cluster.c (modified) (9 diffs)

trunk/kernel/kern/cluster.c

@@ -237 +237 @@
 {
     xptr_t      root_xp;       // xptr on root of list of processes in owner cluster
-    xptr_t      lock_xp;       // xptrr on lock protecting this list
+    xptr_t      lock_xp;       // xptr on lock protecting this list
     xptr_t      iter_xp;       // iterator
     xptr_t      current_xp;    // xptr on current process descriptor
@@ -277 +277 @@
     if( found ) return current_xp;
     else        return XPTR_NULL;
-}
+
+}  // end cluster_get_owner_process_from_pid()
 
 //////////////////////////////////////////////////////////
@@ -440 +441 @@
 void cluster_process_copies_link( process_t * process )
 {
-    uint32_t irq_state;
+    reg_t    irq_state;
     pmgr_t * pm = &LOCAL_CLUSTER->pmgr;
+
+#if CONFIG_DEBUG_CLUSTER_PROCESS_COPIES
+uint32_t cycle = (uint32_t)hal_get_cycles();
+if( CONFIG_DEBUG_CLUSTER_PROCESS_COPIES < cycle )
+printk("\n[DBG] %s enters / cluster %x / process %x / cycle %d\n",
+__FUNCTION__ , local_cxy , process , cycle );
+#endif
 
     // get owner cluster identifier CXY and process LPID
@@ -460 +468 @@
     remote_spinlock_lock_busy( copies_lock , &irq_state );
 
+    // add copy to copies_list
     xlist_add_first( copies_root , copies_entry );
     hal_remote_atomic_add( XPTR( owner_cxy , &pm->copies_nr[lpid] ) , 1 );
@@ -465 +474 @@
     // release lock protecting copies_list[lpid]
     remote_spinlock_unlock_busy( copies_lock , irq_state );
-}
+
+#if CONFIG_DEBUG_CLUSTER_PROCESS_COPIES
+cycle = (uint32_t)hal_get_cycles();
+if( CONFIG_DEBUG_CLUSTER_PROCESS_COPIES < cycle )
+printk("\n[DBG] %s exit / cluster %x / process %x / cycle %d\n",
+__FUNCTION__ , local_cxy , process , cycle );
+#endif
+
+}  // end cluster_process_copies_link()
 
 /////////////////////////////////////////////////////////
@@ -472 +489 @@
     uint32_t irq_state;
     pmgr_t * pm = &LOCAL_CLUSTER->pmgr;
+
+#if CONFIG_DEBUG_CLUSTER_PROCESS_COPIES
+uint32_t cycle = (uint32_t)hal_get_cycles();
+if( CONFIG_DEBUG_CLUSTER_PROCESS_COPIES < cycle )
+printk("\n[DBG] %s enters / cluster %x / process %x / cycle %d\n",
+__FUNCTION__ , local_cxy , process , cycle );
+#endif
 
     // get owner cluster identifier CXY and process LPID
@@ -479 +503 @@
 
     // get extended pointer on lock protecting copies_list[lpid]
-    xptr_t copies_lock  = hal_remote_lwd( XPTR( owner_cxy , &pm->copies_lock[lpid] ) );
+    xptr_t copies_lock  = XPTR( owner_cxy , &pm->copies_lock[lpid] );
 
     // get extended pointer on the local copies_list entry
@@ -487 +511 @@
     remote_spinlock_lock_busy( copies_lock , &irq_state );
 
+    // remove copy from copies_list
     xlist_unlink( copies_entry );
     hal_remote_atomic_add( XPTR( owner_cxy , &pm->copies_nr[lpid] ) , -1 );
@@ -492 +517 @@
     // release lock protecting copies_list[lpid]
     remote_spinlock_unlock_busy( copies_lock , irq_state );
-}
+
+#if CONFIG_DEBUG_CLUSTER_PROCESS_COPIES
+cycle = (uint32_t)hal_get_cycles();
+if( CONFIG_DEBUG_CLUSTER_PROCESS_COPIES < cycle )
+printk("\n[DBG] %s exit / cluster %x / process %x / cycle %d\n",
+__FUNCTION__ , local_cxy , process , cycle );
+#endif
+
+}  // end cluster_process_copies_unlink()
 
 ///////////////////////////////////////////