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

Timestamp:

Feb 14, 2018, 3:40:19 PM (6 years ago)

Author:

alain

Message:

blip

File:

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

trunk/kernel/kern/cluster.c

@@ -89 +89 @@
         spinlock_init( &cluster->kcm_lock );
 
-cluster_dmsg("\n[DBG] %s for cluster %x enters\n",
-__FUNCTION__ , local_cxy );
+#if CONFIG_DEBUG_CLUSTER_INIT
+uint32_t cycle = (uint32_t)hal_get_cycles();
+if( CONFIG_DEBUG_CLUSTER_INIT < cycle )
+printk("\n[DBG] %s enters for cluster %x / cycle %d\n",
+__FUNCTION__ , local_cxy , cycle );
+#endif
 
     // initialises DQDT
@@ -109 +113 @@
     }
 
-cluster_dmsg("\n[DBG] %s : PPM initialized in cluster %x at cycle %d\n",
-__FUNCTION__ , local_cxy , hal_get_cycles() );
+#if CONFIG_DEBUG_CLUSTER_INIT
+cycle = (uint32_t)hal_get_cycles();
+if( CONFIG_DEBUG_CLUSTER_INIT < cycle )
+cluster_dmsg("\n[DBG] %s : PPM initialized in cluster %x / cycle %d\n",
+__FUNCTION__ , local_cxy , cycle );
+#endif
 
     // initialises embedded KHM
@@ -132 +140 @@
         }
 
-cluster_dmsg("\n[DBG] %s : cores initialized in cluster %x at cycle %d\n",
-__FUNCTION__ , local_cxy , hal_get_cycles() );
+#if CONFIG_DEBUG_CLUSTER_INIT
+cycle = (uint32_t)hal_get_cycles();
+if( CONFIG_DEBUG_CLUSTER_INIT < cycle )
+cluster_dmsg("\n[DBG] %s : cores initialized in cluster %x / cycle %d\n",
+__FUNCTION__ , local_cxy , cycle );
+#endif
 
     // initialises RPC fifo
@@ -164 +176 @@
     }
 
-cluster_dmsg("\n[DBG] %s Process Manager initialized in cluster %x at cycle %d\n",
-__FUNCTION__ , local_cxy , hal_get_cycles() );
+#if CONFIG_DEBUG_CLUSTER_INIT
+cycle = (uint32_t)hal_get_cycles();
+if( CONFIG_DEBUG_CLUSTER_INIT < cycle )
+cluster_dmsg("\n[DBG] %s Process Manager initialized in cluster %x / cycle %d\n",
+__FUNCTION__ , local_cxy , cycle );
+#endif
 
     hal_fence();
@@ -215 +231 @@
 //  Process related functions
 ////////////////////////////////////////////////////////////////////////////////////
+
+
+//////////////////////////////////////////////////////
+xptr_t cluster_get_owner_process_from_pid( pid_t pid )
+{
+    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      iter_xp;       // iterator
+    xptr_t      current_xp;    // xptr on current process descriptor
+    process_t * current_ptr;   // local pointer on current process
+    pid_t       current_pid;   // current process identifier
+    bool_t      found;
+
+    cluster_t * cluster = LOCAL_CLUSTER;
+
+    // get owner cluster and lpid
+    cxy_t  owner_cxy = CXY_FROM_PID( pid );
+
+    // get lock & root of list of process in owner cluster
+    root_xp = XPTR( owner_cxy , &cluster->pmgr.local_root );
+    lock_xp = XPTR( owner_cxy , &cluster->pmgr.local_lock );
+
+    // take the lock protecting the list of processes
+    remote_spinlock_lock( lock_xp );
+
+    // scan list of processes in owner cluster
+    found = false;
+    XLIST_FOREACH( root_xp , iter_xp )
+    {
+        current_xp  = XLIST_ELEMENT( iter_xp , process_t , local_list );
+        current_ptr = GET_PTR( current_xp );
+        current_pid = hal_remote_lw( XPTR( owner_cxy , &current_ptr->pid ) );
+
+        if( current_pid == pid )
+        {
+            found = true;
+            break;
+        }
+    }
+
+    // release the lock protecting the list of processes
+    remote_spinlock_unlock( lock_xp );
+
+    // return extended pointer on process descriptor in owner cluster
+    if( found ) return current_xp;
+    else        return XPTR_NULL;
+}
 
 //////////////////////////////////////////////////////////
@@ -442 +505 @@
 
     // skip one line
-    printk("\n");
+    printk("\n***** processes in cluster %x / cycle %d\n", cxy , (uint32_t)hal_get_cycles() );
 
     // loop on all reference processes in cluster cxy