Changeset 406 for trunk/kernel

Timestamp:

Aug 29, 2017, 12:03:37 PM (7 years ago)

Author:

alain

Message:

This version executed successfully the user "init" process on a mono-processor TSAR architecture.

Location:

trunk/kernel

Files:

• devices/dev_dma.c (modified) (2 diffs)
• devices/dev_fbf.c (modified) (1 diff)
• devices/dev_ioc.c (modified) (4 diffs)
• devices/dev_mmc.c (modified) (4 diffs)
• devices/dev_nic.c (modified) (4 diffs)
• devices/dev_pic.c (modified) (6 diffs)
• devices/dev_pic.h (modified) (1 diff)
• devices/dev_txt.c (modified) (2 diffs)
• kern/cluster.c (modified) (7 diffs)
• kern/core.c (modified) (1 diff)
• kern/do_syscall.c (modified) (1 diff)
• kern/dqdt.c (modified) (2 diffs)
• kern/kernel_init.c (modified) (18 diffs)
• kern/printk.c (modified) (2 diffs)
• kern/printk.h (modified) (27 diffs)
• kern/process.c (modified) (14 diffs)
• kern/rpc.c (modified) (104 diffs)
• kern/scheduler.c (modified) (9 diffs)
• kern/signal.c (modified) (2 diffs)
• kern/thread.c (modified) (10 diffs)
• kern/thread.h (modified) (3 diffs)
• libk/elf.c (modified) (11 diffs)
• libk/grdxt.c (modified) (2 diffs)
• libk/grdxt.h (modified) (3 diffs)
• mm/kcm.c (modified) (5 diffs)
• mm/kmem.c (modified) (6 diffs)
• mm/mapper.c (modified) (13 diffs)
• mm/ppm.c (modified) (3 diffs)
• mm/vmm.c (modified) (32 diffs)
• mm/vmm.h (modified) (7 diffs)
• mm/vseg.c (modified) (3 diffs)
• mm/vseg.h (modified) (1 diff)
• syscalls/sys_exec.c (modified) (3 diffs)
• syscalls/sys_fork.c (modified) (7 diffs)
• syscalls/sys_signal.c (modified) (1 diff)
• syscalls/sys_thread_create.c (modified) (1 diff)
• syscalls/sys_thread_sleep.c (modified) (2 diffs)
• syscalls/sys_trace.c (modified) (2 diffs)
• vfs/devfs.c (modified) (3 diffs)
• vfs/fatfs.c (modified) (19 diffs)
• vfs/fatfs.h (modified) (1 diff)
• vfs/vfs.c (modified) (2 diffs)

trunk/kernel/devices/dev_dma.c

@@ -88 +88 @@
     thread_t * this = CURRENT_THREAD;
 
-    dma_dmsg("\n[INFO] %s : enters for thread %x / dst = %l /src = %l / size = %x\n",
+    dma_dmsg("\n[DMSG] %s : enters for thread %x / dst = %l /src = %l / size = %x\n",
               __FUNCTION__ , this->trdid , dst_xp , src_xp , size );
 
@@ -110 +110 @@
     chdev_register_command( dev_xp , this );
 
-    dma_dmsg("\n[INFO] %s : completes for thread %x / error = %d\n", 
+    dma_dmsg("\n[DMSG] %s : completes for thread %x / error = %d\n", 
              __FUNCTION__ ,  this->trdid , this->dma_cmd.error );
 

trunk/kernel/devices/dev_fbf.c

@@ -143 +143 @@
     }
 
-    fbf_dmsg("\n[INFO] %s : thread %x in process %x / vaddr = %p / paddr = %l\n", 
+    fbf_dmsg("\n[DMSG] %s : thread %x in process %x / vaddr = %p / paddr = %l\n", 
              __FUNCTION__ , this->trdid , this->process->pid , buffer , buf_paddr );
 

trunk/kernel/devices/dev_ioc.c

@@ -99 +99 @@
     thread_t * this = CURRENT_THREAD;              // pointer on client thread
 
-    ioc_dmsg("\n[INFO] %s : thread %x in process %x"
+    ioc_dmsg("\n[DMSG] %s : thread %x in process %x"
              " for lba = %x / buffer = %x / at cycle %d\n",
              __FUNCTION__ , this->trdid , this->process->pid ,
@@ -128 +128 @@
     chdev_register_command( dev_xp , this );
 
-    ioc_dmsg("\n[INFO] in %s : thread %x in process %x"
+    ioc_dmsg("\n[DMSG] in %s : thread %x in process %x"
              " completes / error = %d / at cycle %d\n",
              __FUNCTION__ , this->trdid , this->process->pid ,
@@ -162 +162 @@
     thread_t * this = CURRENT_THREAD;
 
-    ioc_dmsg("\n[INFO] %s : core[%x,%d] enter for %d blocks / lba = %x / cycle %d\n",
+    ioc_dmsg("\n[DMSG] %s : core[%x,%d] enter for %d blocks / lba = %x / cycle %d\n",
     __FUNCTION__ , local_cxy , this->core->lid , count , lba , hal_time_stamp() );
 
@@ -199 +199 @@
     dev_pic_enable_irq( lid , ioc_xp );
 
-    ioc_dmsg("\n[INFO] %s : core[%x,%d] exit / error = %d / cycle %d\n",
+    ioc_dmsg("\n[DMSG] %s : core[%x,%d] exit / error = %d / cycle %d\n",
     __FUNCTION__ , local_cxy , this->core->lid , this->ioc_cmd.error , hal_time_stamp() );
 

trunk/kernel/devices/dev_mmc.c

@@ -99 +99 @@
     thread_t * this = CURRENT_THREAD;
 
-    mmc_dmsg("\n[INFO] %s enters for thread %x in process %x / buf_xp = %l\n", 
+    mmc_dmsg("\n[DMSG] %s enters for thread %x in process %x / buf_xp = %l\n", 
                  __FUNCTION__ , this->trdid , this->process->pid , buf_xp );
 
@@ -124 +124 @@
     error = dev_mmc_access( this );
 
-    mmc_dmsg("\n[INFO] %s completes for thread %x in process %x / error = %d\n", 
+    mmc_dmsg("\n[DMSG] %s completes for thread %x in process %x / error = %d\n", 
              __FUNCTION__ , this->trdid , this->process->pid , error );
 
@@ -139 +139 @@
     thread_t * this = CURRENT_THREAD;
 
-    mmc_dmsg("\n[INFO] %s enters for thread %x in process %x / buf_xp = %l\n", 
+    mmc_dmsg("\n[DMSG] %s enters for thread %x in process %x / buf_xp = %l\n", 
                  __FUNCTION__ , this->trdid , this->process->pid , buf_xp );
 
@@ -164 +164 @@
     error = dev_mmc_access( this );
 
-    mmc_dmsg("\n[INFO] %s completes for thread %x in process %x / error = %d\n", 
+    mmc_dmsg("\n[DMSG] %s completes for thread %x in process %x / error = %d\n", 
                  __FUNCTION__ , this->trdid , this->process->pid , error );
 

trunk/kernel/devices/dev_nic.c

@@ -97 +97 @@
     core_t * core = thread_ptr->core;
 
-    nic_dmsg("\n[INFO] %s enters for NIC-RX thread on core %d in cluster %x\n", 
+    nic_dmsg("\n[DMSG] %s enters for NIC-RX thread on core %d in cluster %x\n", 
                  __FUNCTION__ , core->lid , local_cxy );
 
@@ -147 +147 @@
     pkd->length = thread_ptr->nic_cmd.length;
 
-    nic_dmsg("\n[INFO] %s exit for NIC-RX thread on core %d in cluster %x\n", 
+    nic_dmsg("\n[DMSG] %s exit for NIC-RX thread on core %d in cluster %x\n", 
              __FUNCTION__ , core->lid , local_cxy );
 
@@ -167 +167 @@
     core_t * core = thread_ptr->core;
 
-    nic_dmsg("\n[INFO] %s enters for NIC-RX thread on core %d in cluster %x\n", 
+    nic_dmsg("\n[DMSG] %s enters for NIC-RX thread on core %d in cluster %x\n", 
                  __FUNCTION__ , core->lid , local_cxy );
 
@@ -215 +215 @@
     if( error ) return error;
 
-    nic_dmsg("\n[INFO] %s exit for NIC-TX thread on core %d in cluster %x\n", 
+    nic_dmsg("\n[DMSG] %s exit for NIC-TX thread on core %d in cluster %x\n", 
              __FUNCTION__ , core->lid , local_cxy );
 

trunk/kernel/devices/dev_pic.c

@@ -83 +83 @@
                          xptr_t  src_chdev_xp )
 {
-    irq_dmsg("\n[INFO] %s : core = [%x,%d] / source_chdev_xp = %l\n",
-             __FUNCTION__ , local_cxy , lid , src_chdev_xp );
+    irq_dmsg("\n[DMSG] %s : core = [%x,%d] / src_chdev_cxy = %x / src_chdev_ptr = %x\n",
+    __FUNCTION__ , local_cxy , lid , GET_CXY(src_chdev_xp) , GET_PTR(src_chdev_xp) );
 
     // get pointer on PIC chdev
@@ -101 +101 @@
                           xptr_t  src_chdev_xp )
 {
-    irq_dmsg("\n[INFO] %s : core = [%x,%d] / source_chdev_xp = %l\n",
-             __FUNCTION__ , local_cxy , lid , src_chdev_xp );
+    irq_dmsg("\n[DMSG] %s : core = [%x,%d] / src_chdev_cxy = %x / src_chdev_ptr = %x\n",
+    __FUNCTION__ , local_cxy , lid , GET_CXY(src_chdev_xp) , GET_PTR(src_chdev_xp) );
 
     // get pointer on PIC chdev
@@ -118 +118 @@
 void dev_pic_enable_timer( uint32_t period )
 {
-    irq_dmsg("\n[INFO] %s : core = [%x,%d] / period = %d\n",
-             __FUNCTION__ , local_cxy , CURRENT_THREAD->core->lid , period );
+    irq_dmsg("\n[DMSG] %s : core = [%x,%d] / period = %d\n",
+    __FUNCTION__ , local_cxy , CURRENT_THREAD->core->lid , period );
 
     // get pointer on PIC chdev
@@ -135 +135 @@
 void dev_pic_enable_ipi()
 {
-    irq_dmsg("\n[INFO] %s : core = [%x,?]\n",
-             __FUNCTION__ , local_cxy );
+    irq_dmsg("\n[DMSG] %s : core = [%x,%d]\n",
+    __FUNCTION__ , local_cxy , CURRENT_THREAD->core->lid );
 
     // get pointer on PIC chdev
@@ -153 +153 @@
                        lid_t  lid )
 {
-    irq_dmsg("\n[INFO] %s : enter / src_core = [%x,%d] / dst_core = [%x,%d] / cycle %d\n",
-             __FUNCTION__, local_cxy, CURRENT_THREAD->core->lid, cxy, lid, hal_time_stamp() );
+    irq_dmsg("\n[DMSG] %s : enter / src_core = [%x,%d] / dst_core = [%x,%d] / cycle %d\n",
+    __FUNCTION__, local_cxy, CURRENT_THREAD->core->lid, cxy, lid, hal_time_stamp() );
 
     // get pointer on PIC chdev
@@ -166 +166 @@
     f( cxy , lid );
 
-    irq_dmsg("\n[INFO] %s : exit / src_core = [%x,%d] / dst_core = [%x,%d] / cycle %d\n",
-             __FUNCTION__, local_cxy, CURRENT_THREAD->core->lid, cxy, lid, hal_time_stamp() );
+    irq_dmsg("\n[DMSG] %s : exit / src_core = [%x,%d] / dst_core = [%x,%d] / cycle %d\n",
+    __FUNCTION__, local_cxy, CURRENT_THREAD->core->lid, cxy, lid, hal_time_stamp() );
 }
 

trunk/kernel/devices/dev_pic.h

@@ -212 +212 @@
 /*****************************************************************************************
  * This function activates the TIM_IRQ for the calling core.
- * The <period> argument define the number of cycles between twoo successive IRQs.
- *****************************************************************************************
- * @ period      : number of cycles between IRQs.
+ * The <period> argument is a number of milli-seconds between two successive IRQs.
+ * It is converted to a number of cycles by the PIC driver implementation.
+ *****************************************************************************************
+ * @ period      : number of milliseconds.
  ****************************************************************************************/
 void dev_pic_enable_timer( uint32_t period );

trunk/kernel/devices/dev_txt.c

@@ -101 +101 @@
     thread_t * this = CURRENT_THREAD;
 
-    txt_dmsg("\n[INFO] in %s : thread %x in process %x enters\n",
+    txt_dmsg("\n[DMSG] in %s : thread %x in process %x enters\n",
                  __FUNCTION__ , this->trdid , this->process->pid );
 
@@ -123 +123 @@
     chdev_register_command( dev_xp , this );
 
-    txt_dmsg("\n[INFO] in %s : thread %x in process %x completes / error = %d\n",
+    txt_dmsg("\n[DMSG] in %s : thread %x in process %x completes / error = %d\n",
              __FUNCTION__ , this->trdid , this->process->pid , this->txt_cmd.error );
 

trunk/kernel/kern/cluster.c

@@ -82 +82 @@
         spinlock_init( &cluster->kcm_lock );
 
-    cluster_dmsg("\n[INFO] %s for cluster %x enters\n",
+    cluster_dmsg("\n[DMSG] %s for cluster %x enters\n",
                  __FUNCTION__ , local_cxy );
 
@@ -102 +102 @@
     }
 
-    cluster_dmsg("\n[INFO] %s : PPM initialized in cluster %x at cycle %d\n",
+    cluster_dmsg("\n[DMSG] %s : PPM initialized in cluster %x at cycle %d\n",
                  __FUNCTION__ , local_cxy , hal_get_cycles() );
 
@@ -108 +108 @@
         khm_init( &cluster->khm );
 
-    cluster_dmsg("\n[INFO] %s : KHM initialized in cluster %x at cycle %d\n",
+    cluster_dmsg("\n[DMSG] %s : KHM initialized in cluster %x at cycle %d\n",
                  __FUNCTION__ , local_cxy , hal_get_cycles() );
 
@@ -114 +114 @@
         kcm_init( &cluster->kcm , KMEM_KCM );
 
-    cluster_dmsg("\n[INFO] %s : KCM initialized in cluster %x at cycle %d\n",
+    cluster_dmsg("\n[DMSG] %s : KCM initialized in cluster %x at cycle %d\n",
                  __FUNCTION__ , local_cxy , hal_get_cycles() );
 
@@ -125 +125 @@
         }
 
-    cluster_dmsg("\n[INFO] %s : cores initialized in cluster %x at cycle %d\n",
+    cluster_dmsg("\n[DMSG] %s : cores initialized in cluster %x at cycle %d\n",
                  __FUNCTION__ , local_cxy , hal_get_cycles() );
 
@@ -132 +132 @@
     cluster->rpc_threads = 0;
 
-    cluster_dmsg("\n[INFO] %s : RPC fifo inialized in cluster %x at cycle %d\n",
+    cluster_dmsg("\n[DMSG] %s : RPC fifo inialized in cluster %x at cycle %d\n",
                  __FUNCTION__ , local_cxy , hal_get_cycles() );
 
@@ -157 +157 @@
     }
 
-    cluster_dmsg("\n[INFO] %s Process Manager initialized in cluster %x at cycle %d\n",
+    cluster_dmsg("\n[DMSG] %s Process Manager initialized in cluster %x at cycle %d\n",
                  __FUNCTION__ , local_cxy , hal_get_cycles() );
 

trunk/kernel/kern/core.c

@@ -113 +113 @@
         if( (ticks % CONFIG_SCHED_TICKS_PER_QUANTUM) == 0 ) sched_yield( NULL );
 
-        // update DQDT TODO  This update should depend on the cluster identifier,
-        // to avoid simultaneous updates from various clusters ... AG
+        // update DQDT 
         if( ((ticks % CONFIG_DQDT_TICKS_PER_QUANTUM) == 0) && (core->lid == 0) )
         dqdt_global_update();

trunk/kernel/kern/do_syscall.c

@@ -116 +116 @@
         }
 
-        syscall_dmsg("\n[INFO] %s : pid = %x / trdid = %x / service #%d\n"
+        syscall_dmsg("\n[DMSG] %s : pid = %x / trdid = %x / service #%d\n"
                  "         arg0 = %x / arg1 = %x / arg2 = %x / arg3 = %x\n",
                          __FUNCTION__ , this->process->pid , this->trdid , service_num ,

trunk/kernel/kern/dqdt.c

@@ -60 +60 @@
         for ( i = 0 ; i < 4 ; i++ )
         {
-            if ( local_node.children[i] != XPTR_NULL ) dqdt_global_print( local_node.children[i] );
+            if ( local_node.children[i] != XPTR_NULL ) 
+                dqdt_global_print( local_node.children[i] );
         }
     }
@@ -70 +71 @@
                     uint32_t y_width )
 {
-    if( (x_size > 32) || (y_size > 32) )
-    {
-        panic("illegal mesh size for DQDT support");
-    }
+    assert( ((x_size <= 32) && (y_size <= 32)) , __FUNCTION__ , "illegal mesh size\n");
 
         dqdt_node_t * node;

trunk/kernel/kern/kernel_init.c

@@ -137 +137 @@
            "    /_/        \\_\\ |______| |_|    |_|   \\_____/  |______/        |_|    |_|  |_|  \\_\\ |_|   |_|  \n"
            "\n\n\t\t Advanced Locality Management Operating System / Multi Kernel Hybrid\n"
-           "\n\n\t\t\t Version 0.0 : %d cluster(s)   /   %d core(s) per cluster\n\n", nclusters , ncores );
+           "\n\n\t\t\t Version 0.0 / %d cluster(s) / %d core(s) per cluster\n\n", nclusters , ncores );
 }
 
@@ -274 +274 @@
 
 #if( CONFIG_KINIT_DEBUG > 1 )
-printk("\n[INFO] %s : created MMC in cluster %x / chdev = %x\n",
+printk("\n[DMSG] %s : created MMC in cluster %x / chdev = %x\n",
 __FUNCTION__ , channel , local_cxy , chdev_ptr );
 #endif
@@ -302 +302 @@
 
 #if( CONFIG_KINIT_DEBUG > 1 )
-printk("\n[INFO] %s : created DMA[%d] in cluster %x / chdev = %x\n",
+printk("\n[DMSG] %s : created DMA[%d] in cluster %x / chdev = %x\n",
 __FUNCTION__ , channel , local_cxy , chdev_ptr );
 #endif
@@ -436 +436 @@
 
 #if( CONFIG_KINIT_DEBUG > 1 )
-printk("\n[INFO] %s : create chdev %s[%d] in cluster %x / chdev = %x\n",
+printk("\n[DMSG] %s : create chdev %s[%d] in cluster %x / chdev = %x\n",
 __FUNCTION__ , chdev_func_str( func ), channel , local_cxy , chdev );
 #endif
@@ -554 +554 @@
 
 #if( CONFIG_KINIT_DEBUG > 1 )
-printk("\n[INFO] %s created PIC chdev in cluster %x at cycle %d\n",
+printk("\n[DMSG] %s created PIC chdev in cluster %x at cycle %d\n",
 __FUNCTION__ , local_cxy , (uint32_t)hal_time_stamp() );
 #endif
@@ -728 +728 @@
 
     if( (core_lid ==  0) && (local_cxy == 0) ) 
-    kinit_dmsg("\n[INFO] %s : exit barrier 0 : TXT0 initialized / cycle %d\n",
+    printk("\n[KINIT] %s : exit barrier 0 : TXT0 initialized / cycle %d\n",
     __FUNCTION__, hal_time_stamp() );
 
@@ -762 +762 @@
 
     if( (core_lid ==  0) && (local_cxy == 0) ) 
-    kinit_dmsg("\n[INFO] %s : exit barrier 1 : clusters initialised / cycle %d\n",
+    printk("\n[KINIT] %s : exit barrier 1 : clusters initialised / cycle %d\n",
     __FUNCTION__, hal_time_stamp() );
 
@@ -787 +787 @@
 
     if( (core_lid ==  0) && (local_cxy == 0) ) 
-    kinit_dmsg("\n[INFO] %s : exit barrier 2 : PIC initialised / cycle %d\n",
+    printk("\n[KINIT] %s : exit barrier 2 : PIC initialised / cycle %d\n",
     __FUNCTION__, hal_time_stamp() );
 
@@ -818 +818 @@
 
     if( (core_lid ==  0) && (local_cxy == 0) ) 
-    kinit_dmsg("\n[INFO] %s : exit barrier 3 : all chdev initialised / cycle %d\n",
+    printk("\n[KINIT] %s : exit barrier 3 : all chdev initialised / cycle %d\n",
                __FUNCTION__, hal_time_stamp());
 
@@ -829 +829 @@
     /////////////////////////////////////////////////////////////////////////////////
 
-#if( CONFIG_KINIT_DEBUG > 1 )
+#if CONFIG_KINIT_DEBUG 
 chdev_dir_display();
 #endif
@@ -856 +856 @@
     core->scheduler.idle = thread;
 
-#if( CONFIG_KINIT_DEBUG > 1 )
+#if CONFIG_KINIT_DEBUG
 sched_display();
 #endif
@@ -928 +928 @@
 
     if( (core_lid ==  0) && (local_cxy == 0) ) 
-    kinit_dmsg("\n[INFO] %s : exit barrier 4 : VFS_root = %l in cluster 0 / cycle %d\n",
+    printk("\n[KINIT] %s : exit barrier 4 : VFS_root = %l in cluster 0 / cycle %d\n",
                __FUNCTION__, vfs_root_inode_xp , hal_time_stamp());
 
@@ -987 +987 @@
 
     if( (core_lid ==  0) && (local_cxy == 0) ) 
-    kinit_dmsg("\n[INFO] %s : exit barrier 5 : VFS_root = %l in cluster IO / cycle %d\n",
+    printk("\n[KINIT] %s : exit barrier 5 : VFS_root = %l in cluster IO / cycle %d\n",
     __FUNCTION__, vfs_root_inode_xp , hal_time_stamp() );
 
@@ -1020 +1020 @@
 
     if( (core_lid ==  0) && (local_cxy == 0) ) 
-    kinit_dmsg("\n[INFO] %s : exit barrier 6 : dev_root = %l in cluster IO / cycle %d\n",
+    printk("\n[KINIT] %s : exit barrier 6 : dev_root = %l in cluster IO / cycle %d\n",
     __FUNCTION__, devfs_dev_inode_xp , hal_time_stamp() );
 
@@ -1057 +1057 @@
 
     if( (core_lid ==  0) && (local_cxy == 0) ) 
-    kinit_dmsg("\n[INFO] %s : exit barrier 7 : dev_root = %l in cluster 0 / cycle %d\n",
+    printk("\n[KINIT] %s : exit barrier 7 : dev_root = %l in cluster 0 / cycle %d\n",
     __FUNCTION__, devfs_dev_inode_xp , hal_time_stamp() );
 
@@ -1076 +1076 @@
 
     if( (core_lid ==  0) && (local_cxy == 0) ) 
-    kinit_dmsg("\n[INFO] %s : exit barrier 8 : process init created / cycle %d\n", 
+    printk("\n[KINIT] %s : exit barrier 8 : process init created / cycle %d\n", 
     __FUNCTION__ , hal_time_stamp() );
 
@@ -1087 +1087 @@
         print_banner( (info->x_size * info->y_size) , info->cores_nr );
 
+#if CONFIG_KINIT_DEBUG
+
         vfs_display( vfs_root_inode_xp );
-        
-        kinit_dmsg("\n\n***** memory fooprint for main kernel objects\n\n"
+
+        printk("\n\n***** memory fooprint for main kernel objects\n\n"
                    " - thread descriptor  : %d bytes\n"
                    " - process descriptor : %d bytes\n"
@@ -1130 +1132 @@
                    sizeof( rwlock_t          ),
                    sizeof( remote_rwlock_t   ));
+#endif
+
     }
 

trunk/kernel/kern/printk.c

@@ -327 +327 @@
             case ('l'):            /* 64 bits hexadecimal unsigned */
             {
-                uint64_t val = va_arg( *args , uint64_t );
+                unsigned long long val = va_arg( *args , unsigned long long );
                 txt_write( channel, busy, "0x" , 2 );
                 for(i = 0; i < 16; i++) 
@@ -340 +340 @@
             case ('L'):           /* 64 bits hexadecimal unsigned on 18 char */ 
             {
-                uint64_t val = va_arg( *args , uint64_t );
+                unsigned long long val = va_arg( *args , unsigned long long );
                 txt_write( channel, busy, "0x" , 2 );
                 for(i = 0; i < 16; i++) 

trunk/kernel/kern/printk.h

@@ -109 +109 @@
 
 #if CONFIG_CLUSTER_DEBUG
-#define cluster_dmsg(...)   printk(__VA_ARGS__)
+#define cluster_dmsg(...)   if(hal_time_stamp() > CONFIG_CLUSTER_DEBUG) printk(__VA_ARGS__)
 #else
 #define cluster_dmsg(...)
@@ -115 +115 @@
 
 #if CONFIG_CONTEXT_DEBUG
-#define context_dmsg(...)   printk(__VA_ARGS__)
+#define context_dmsg(...)   if(hal_time_stamp() > CONFIG_CONTEXT_DEBUG) printk(__VA_ARGS__)
 #else
 #define context_dmsg(...)
@@ -121 +121 @@
 
 #if CONFIG_CORE_DEBUG
-#define core_dmsg(...)   printk(__VA_ARGS__)
+#define core_dmsg(...)   if(hal_time_stamp() > CONFIG_CORE_DEBUG) printk(__VA_ARGS__)
 #else
 #define core_dmsg(...)
@@ -127 +127 @@
 
 #if CONFIG_DEVFS_DEBUG
-#define devfs_dmsg(...)   printk(__VA_ARGS__)
+#define devfs_dmsg(...)   if(hal_time_stamp() > CONFIG_DEVFS_DEBUG) printk(__VA_ARGS__)
 #else
 #define devfs_dmsg(...)
@@ -133 +133 @@
 
 #if CONFIG_DMA_DEBUG
-#define dma_dmsg(...)   printk(__VA_ARGS__)
+#define dma_dmsg(...)   if(hal_time_stamp() > CONFIG_DMA_DEBUG) printk(__VA_ARGS__)
 #else
 #define dma_dmsg(...)
@@ -139 +139 @@
 
 #if CONFIG_DQDT_DEBUG
-#define dma_dmsg(...)   printk(__VA_ARGS__)
-#else
-#define dma_dmsg(...)
-#endif
-
-#if CONFIG_DQDT_DEBUG
-#define dqdt_dmsg(...)   printk(__VA_ARGS__)
+#define dqdt_dmsg(...)   if(hal_time_stamp() > CONFIG_DQDT_DEBUG) printk(__VA_ARGS__)
 #else
 #define dqdt_dmsg(...)
@@ -151 +145 @@
 
 #if CONFIG_ELF_DEBUG
-#define elf_dmsg(...)   printk(__VA_ARGS__)
+#define elf_dmsg(...)   if(hal_time_stamp() > CONFIG_ELF_DEBUG) printk(__VA_ARGS__)
 #else
 #define elf_dmsg(...)
@@ -157 +151 @@
 
 #if CONFIG_EXEC_DEBUG
-#define exec_dmsg(...)   printk(__VA_ARGS__)
+#define exec_dmsg(...)   if(hal_time_stamp() > CONFIG_EXEC_DEBUG) printk(__VA_ARGS__)
 #else
 #define exec_dmsg(...)
 #endif
 
+#if CONFIG_EXCP_DEBUG
+#define excp_dmsg(...)   if(hal_time_stamp() > CONFIG_EXCP_DEBUG) printk(__VA_ARGS__)
+#else
+#define excp_dmsg(...)
+#endif
+
 #if CONFIG_FATFS_DEBUG
-#define fatfs_dmsg(...)   printk(__VA_ARGS__)
+#define fatfs_dmsg(...)   if(hal_time_stamp() > CONFIG_FATFS_DEBUG) printk(__VA_ARGS__)
 #else
 #define fatfs_dmsg(...)
@@ -169 +169 @@
 
 #if CONFIG_FBF_DEBUG
-#define fbf_dmsg(...)   printk(__VA_ARGS__)
+#define fbf_dmsg(...)   if(hal_time_stamp() > CONFIG_FBF_DEBUG) printk(__VA_ARGS__)
 #else
 #define fbf_dmsg(...)
@@ -175 +175 @@
 
 #if CONFIG_FORK_DEBUG
-#define fork_dmsg(...)   printk(__VA_ARGS__)
+#define fork_dmsg(...)   if(hal_time_stamp() > CONFIG_FORK_DEBUG) printk(__VA_ARGS__)
 #else
 #define fork_dmsg(...)
 #endif
 
+#if CONFIG_GPT_DEBUG
+#define gpt_dmsg(...)   if(hal_time_stamp() > CONFIG_GPT_DEBUG) printk(__VA_ARGS__)
+#else
+#define gpt_dmsg(...)
+#endif
+
 #if CONFIG_IDLE_DEBUG
-#define idle_dmsg(...) printk(__VA_ARGS__)
+#define idle_dmsg(...)   if(hal_time_stamp() > CONFIG_IDLE_DEBUG) printk(__VA_ARGS__)
 #else
 #define idle_dmsg(...)
@@ -193 +199 @@
 
 #if CONFIG_IRQ_DEBUG
-#define irq_dmsg(...)   printk(__VA_ARGS__)
+#define irq_dmsg(...)   if(hal_time_stamp() > CONFIG_IRQ_DEBUG) printk(__VA_ARGS__)
 #else
 #define irq_dmsg(...)
@@ -199 +205 @@
 
 #if CONFIG_KCM_DEBUG
-#define kcm_dmsg(...) printk(__VA_ARGS__)
+#define kcm_dmsg(...)   if(hal_time_stamp() > CONFIG_KCM_DEBUG) printk(__VA_ARGS__)
 #else
 #define kcm_dmsg(...)
@@ -205 +211 @@
 
 #if CONFIG_KHM_DEBUG
-#define khm_dmsg(...) printk(__VA_ARGS__)
+#define khm_dmsg(...)   if(hal_time_stamp() > CONFIG_KHM_DEBUG) printk(__VA_ARGS__)
 #else
 #define khm_dmsg(...)
@@ -211 +217 @@
 
 #if CONFIG_KINIT_DEBUG
-#define kinit_dmsg(...) printk(__VA_ARGS__)
+#define kinit_dmsg(...)   if(hal_time_stamp() > CONFIG_KINIT_DEBUG) printk(__VA_ARGS__)
 #else
 #define kinit_dmsg(...)
@@ -217 +223 @@
 
 #if CONFIG_KMEM_DEBUG
-#define kmem_dmsg(...) printk(__VA_ARGS__)
+#define kmem_dmsg(...)   if(hal_time_stamp() > CONFIG_KMEM_DEBUG) printk(__VA_ARGS__)
 #else
 #define kmem_dmsg(...)
@@ -223 +229 @@
 
 #if CONFIG_MAPPER_DEBUG
-#define mapper_dmsg(...)   printk(__VA_ARGS__)
+#define mapper_dmsg(...)   if(hal_time_stamp() > CONFIG_MAPPER_DEBUG) printk(__VA_ARGS__)
 #else
 #define mapper_dmsg(...)
@@ -229 +235 @@
 
 #if CONFIG_MMC_DEBUG
-#define mmc_dmsg(...)   printk(__VA_ARGS__)
+#define mmc_dmsg(...)   if(hal_time_stamp() > CONFIG_MMC_DEBUG) printk(__VA_ARGS__)
 #else
 #define mmc_dmsg(...)
@@ -235 +241 @@
 
 #if CONFIG_NIC_DEBUG
-#define nic_dmsg(...)   printk(__VA_ARGS__)
+#define nic_dmsg(...)   if(hal_time_stamp() > CONFIG_NIC_DEBUG) printk(__VA_ARGS__)
 #else
 #define nic_dmsg(...)
@@ -241 +247 @@
 
 #if CONFIG_PIC_DEBUG
-#define pic_dmsg(...)   printk(__VA_ARGS__)
+#define pic_dmsg(...)   if(hal_time_stamp() > CONFIG_PIC_DEBUG) printk(__VA_ARGS__)
 #else
 #define pic_dmsg(...)
@@ -247 +253 @@
 
 #if CONFIG_PPM_DEBUG
-#define ppm_dmsg(...)   printk(__VA_ARGS__)
+#define ppm_dmsg(...)   if(hal_time_stamp() > CONFIG_PPM_DEBUG) printk(__VA_ARGS__)
 #else
 #define ppm_dmsg(...)
@@ -253 +259 @@
 
 #if CONFIG_PROCESS_DEBUG
-#define process_dmsg(...)   printk(__VA_ARGS__)
+#define process_dmsg(...)   if(hal_time_stamp() > CONFIG_PROCESS_DEBUG) printk(__VA_ARGS__)
 #else
 #define process_dmsg(...)
@@ -264 +270 @@
 #endif
 
-#if CONFIG_RPCG_DEBUG
-#define rpcg_dmsg(...)   printk(__VA_ARGS__)
-#else
-#define rpcg_dmsg(...)
-#endif
-
 #if CONFIG_SCHED_DEBUG
-#define sched_dmsg(...)   printk(__VA_ARGS__)
+#define sched_dmsg(...)   if(hal_time_stamp() > CONFIG_SCHED_DEBUG) printk(__VA_ARGS__)
 #else
 #define sched_dmsg(...)
@@ -277 +277 @@
 
 #if CONFIG_SIGNAL_DEBUG
-#define signal_dmsg(...)   printk(__VA_ARGS__)
+#define signal_dmsg(...)   if(hal_time_stamp() > CONFIG_SIGNAL_DEBUG) printk(__VA_ARGS__)
 #else
 #define signal_dmsg(...)
@@ -283 +283 @@
 
 #if CONFIG_SYSCALL_DEBUG
-#define syscall_dmsg(...)   printk(__VA_ARGS__)
+#define syscall_dmsg(...)   if(hal_time_stamp() > CONFIG_SYSCALL_DEBUG) printk(__VA_ARGS__)
 #else
 #define syscall_dmsg(...)
@@ -289 +289 @@
 
 #if CONFIG_THREAD_DEBUG
-#define thread_dmsg(...)   printk(__VA_ARGS__)
+#define thread_dmsg(...)   if(hal_time_stamp() > CONFIG_THREAD_DEBUG) printk(__VA_ARGS__)
 #else
 #define thread_dmsg(...)
@@ -295 +295 @@
 
 #if CONFIG_TXT_DEBUG
-#define txt_dmsg(...)   printk(__VA_ARGS__)
+#define txt_dmsg(...)   if(hal_time_stamp() > CONFIG_TXT_DEBUG) printk(__VA_ARGS__)
 #else
 #define txt_dmsg(...)
@@ -307 +307 @@
 
 #if CONFIG_VMM_DEBUG
-#define vmm_dmsg(...)   printk(__VA_ARGS__)
+#define vmm_dmsg(...)   if(hal_time_stamp() > CONFIG_VMM_DEBUG) printk(__VA_ARGS__)
 #else
 #define vmm_dmsg(...)

trunk/kernel/kern/process.c

@@ -90 +90 @@
     pid_t       parent_pid;
 
-    process_dmsg("\n[INFO] %s : enters for process %x in cluster %x\n",
-                 __FUNCTION__ , pid , local_cxy );
+    process_dmsg("\n[DMSG] %s : core[%x,%d] enters for process %x\n",
+    __FUNCTION__ , local_cxy , CURRENT_THREAD->core->lid , pid );
 
     // get parent process cluster, local pointer, and pid
@@ -116 +116 @@
     process->ppid  = parent_pid;
 
-    // reset reference process vmm (not for kernel process)
+    // initialize reference process vmm (not for kernel process)
     if( pid ) vmm_init( process );
 
@@ -169 +169 @@
         hal_fence();
 
-    process_dmsg("\n[INFO] %s : exit for process %x in cluster %x\n",
+    process_dmsg("\n[DMSG] %s : exit for process %x in cluster %x\n",
                  __FUNCTION__ , pid );
 
@@ -198 +198 @@
     local_process->ref_xp = reference_process_xp;
 
-    process_dmsg("\n[INFO] %s : enter for process %x in cluster %x\n",
+    process_dmsg("\n[DMSG] %s : enter for process %x in cluster %x\n",
                  __FUNCTION__ , local_process->pid );
 
@@ -233 +233 @@
         hal_fence();
 
-    process_dmsg("\n[INFO] %s : exit for process %x in cluster %x\n",
+    process_dmsg("\n[DMSG] %s : exit for process %x in cluster %x\n",
                  __FUNCTION__ , local_process->pid );
 
@@ -288 +288 @@
     vmm_destroy( process );
 
-        process_dmsg("\n[INFO] %s for pid %d / page_faults = %d\n",
+        process_dmsg("\n[DMSG] %s for pid %d / page_faults = %d\n",
                  __FUNCTION__ , process->pid, process->vmm.pgfault_nr );
 }
@@ -627 +627 @@
     parent_pid = hal_remote_lw( XPTR( parent_cxy , &parent_ptr->pid ) );
 
-    exec_dmsg("\n[INFO] %s : thread %x on core[%x,%d] enters for path = %s\n",
+    exec_dmsg("\n[DMSG] %s : thread %x on core[%x,%d] enters for path = %s\n",
     __FUNCTION__, CURRENT_THREAD->trdid, local_cxy, CURRENT_THREAD->core->lid , path );
 
@@ -654 +654 @@
     process_reference_init( process , pid , parent_xp );
 
-    exec_dmsg("\n[INFO] %s : thread %x on core[%x,%d] created process %x / path = %s\n",
+    exec_dmsg("\n[DMSG] %s : thread %x on core[%x,%d] created process %x / path = %s\n",
     __FUNCTION__, CURRENT_THREAD->trdid, local_cxy, CURRENT_THREAD->core->lid, pid, path );
 
@@ -670 +670 @@
                             XPTR( parent_cxy , &parent_ptr->fd_array) );
 
-    exec_dmsg("\n[INFO] %s : fd_array copied from process %x to process %x\n",
+    exec_dmsg("\n[DMSG] %s : fd_array copied from process %x to process %x\n",
     __FUNCTION__, parent_pid , pid );
 
@@ -688 +688 @@
         }
 
-    exec_dmsg("\n[INFO] %s : code and data vsegs registered for process %x / path = %s\n",
+    exec_dmsg("\n[DMSG] %s : code and data vsegs registered for process %x / path = %s\n",
     __FUNCTION__ , pid , path );
 
@@ -714 +714 @@
         }
 
-        exec_dmsg("\n[INFO] %s : thread created for process %x on core %d in cluster %x\n",
+        exec_dmsg("\n[DMSG] %s : thread created for process %x on core %d in cluster %x\n",
                __FUNCTION__ , pid , core->lid , local_cxy );
+
+#if CONFIG_EXEC_DEBUG
+if( hal_time_stamp() > CONFIG_EXEC_DEBUG )
+{
+    grdxt_print( &process->vmm.grdxt , GRDXT_TYPE_VSEG , process->pid );
+    hal_gpt_print( &process->vmm.gpt , process->pid ); 
+}
+#endif
 
     // update children list in parent process
@@ -725 +733 @@
         thread_unblock( XPTR( local_cxy , thread ) , THREAD_BLOCKED_GLOBAL );
 
-    exec_dmsg("\n[INFO] %s : exit for process %x\n",
+    exec_dmsg("\n[DMSG] %s : exit for process %x\n",
                 __FUNCTION__, process->pid );
 
@@ -747 +755 @@
     uint32_t  stderr_id;
 
-        process_dmsg("\n[INFO] %s : enters in cluster %x\n", __FUNCTION__ , local_cxy );
+        process_dmsg("\n[DMSG] %s : enters in cluster %x\n", __FUNCTION__ , local_cxy );
 
     // open stdin / stdout / stderr pseudo-files
@@ -771 +779 @@
         assert( (error1 == 0) , __FUNCTION__ , "cannot create process_init\n");
 
-        process_dmsg("\n[INFO] %s : exit in cluster %x\n", __FUNCTION__ , local_cxy );
+        process_dmsg("\n[DMSG] %s : exit in cluster %x\n", __FUNCTION__ , local_cxy );
                 
     hal_fence();

trunk/kernel/kern/rpc.c

@@ -97 +97 @@
                                 page_t  ** page )      // out 
 {
-    rpc_dmsg("\n[INFO] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -117 +117 @@
     *page    = (page_t *)(intptr_t)rpc.args[1];
 
-    rpc_dmsg("\n[INFO] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -125 +125 @@
 void rpc_pmem_get_pages_server( xptr_t xp )
 {
-    rpc_dmsg("\n[INFO] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -142 +142 @@
     hal_remote_swd( XPTR( cxy , &desc->args[1] ) , (uint64_t)(intptr_t)page );
 
-    rpc_dmsg("\n[INFO] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -157 +157 @@
                                    pid_t     * pid )     // out
 {
-    rpc_dmsg("\n[INFO] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -178 +178 @@
     *error  = (error_t)rpc.args[2];     
 
-    rpc_dmsg("\n[INFO] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -190 +190 @@
     pid_t       pid;       // output : process identifier
 
-    rpc_dmsg("\n[INFO] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -209 +209 @@
     hal_remote_sw( XPTR( client_cxy , &desc->args[1] ) , (uint64_t)pid );
 
-    rpc_dmsg("\n[INFO] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -224 +224 @@
                               error_t     * error )   // out
 {
-    rpc_dmsg("\n[INFO] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -244 +244 @@
     *error  = (error_t)rpc.args[1];     
 
-    rpc_dmsg("\n[INFO] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -256 +256 @@
     error_t       error;     // local error error status
 
-    rpc_dmsg("\n[INFO] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -278 +278 @@
     hal_remote_swd( XPTR( client_cxy , &desc->args[1] ) , (uint64_t)error );
 
-    rpc_dmsg("\n[INFO] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -291 +291 @@
 void rpc_process_kill_client( process_t * process ) 
 {
-    rpc_dmsg("\n[INFO] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -325 +325 @@
     }
 
-    rpc_dmsg("\n[INFO] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -336 +336 @@
     process_t * process;  
 
-    rpc_dmsg("\n[INFO] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -360 +360 @@
     }
 
-    rpc_dmsg("\n[INFO] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -379 +379 @@
                                     error_t        * error )      // out 
 {
-    rpc_dmsg("\n[INFO] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -403 +403 @@
     *error     = (error_t)rpc.args[5];
 
-    rpc_dmsg("\n[INFO] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -421 +421 @@
     error_t          error;
 
-    rpc_dmsg("\n[INFO] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -456 +456 @@
     hal_remote_swd( XPTR( client_cxy , &desc->args[2] ) , (uint64_t)thread_xp );
 
-    rpc_dmsg("\n[INFO] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -473 +473 @@
                                       error_t * error )      // out
 {
-    rpc_dmsg("\n[INFO] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -496 +496 @@
     *error     = (error_t)rpc.args[4];
 
-    rpc_dmsg("\n[INFO] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -509 +509 @@
     error_t          error;    
 
-    rpc_dmsg("\n[INFO] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -533 +533 @@
     hal_remote_swd( XPTR( client_cxy , &desc->args[2] ) , (uint64_t)thread_xp );
 
-    rpc_dmsg("\n[INFO] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -547 +547 @@
                              uint32_t    sig_id )    // in
 {
-    rpc_dmsg("\n[INFO] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -565 +565 @@
     rpc_send_sync( cxy , &rpc );
 
-    rpc_dmsg("\n[INFO] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -576 +576 @@
     uint32_t     sig_id;   // signal index
 
-    rpc_dmsg("\n[INFO] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -591 +591 @@
     signal_rise( process , sig_id );
 
-    rpc_dmsg("\n[INFO] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -613 +613 @@
                                   error_t      * error )     // out
 {
-    rpc_dmsg("\n[INFO] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -641 +641 @@
     *error    = (error_t)rpc.args[9];
 
-    rpc_dmsg("\n[INFO] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -660 +660 @@
     error_t          error;
 
-    rpc_dmsg("\n[INFO] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -693 +693 @@
     hal_remote_swd( XPTR( client_cxy , &desc->args[9] ) , (uint64_t)error );
 
-    rpc_dmsg("\n[INFO] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -706 +706 @@
                                    struct vfs_inode_s * inode )
 {
-    rpc_dmsg("\n[INFO] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -723 +723 @@
     rpc_send_sync( cxy , &rpc );
 
-    rpc_dmsg("\n[INFO] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -733 +733 @@
     vfs_inode_t * inode;
 
-    rpc_dmsg("\n[INFO] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -747 +747 @@
     vfs_inode_destroy( inode );
 
-    rpc_dmsg("\n[INFO] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -764 +764 @@
                                    error_t              * error )       // out
 {
-    rpc_dmsg("\n[INFO] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -787 +787 @@
     *error     = (error_t)rpc.args[4];
 
-    rpc_dmsg("\n[INFO] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -803 +803 @@
     char          name_copy[CONFIG_VFS_MAX_NAME_LENGTH];
 
-    rpc_dmsg("\n[INFO] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -829 +829 @@
     hal_remote_swd( XPTR( client_cxy , &desc->args[4] ) , (uint64_t)error );
 
-    rpc_dmsg("\n[INFO] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -843 +843 @@
                                     vfs_dentry_t * dentry )
 {
-    rpc_dmsg("\n[INFO] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -860 +860 @@
     rpc_send_sync( cxy , &rpc );
 
-    rpc_dmsg("\n[INFO] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -870 +870 @@
     vfs_dentry_t * dentry;
 
-    rpc_dmsg("\n[INFO] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -884 +884 @@
     vfs_dentry_destroy( dentry );
 
-    rpc_dmsg("\n[INFO] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -901 +901 @@
                                  error_t              * error )      // out
 {
-    rpc_dmsg("\n[INFO] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -923 +923 @@
     *error   = (error_t)rpc.args[3];
 
-    rpc_dmsg("\n[INFO] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -936 +936 @@
     error_t       error;
 
-    rpc_dmsg("\n[INFO] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -957 +957 @@
     hal_remote_swd( XPTR( client_cxy , &desc->args[3] ) , (uint64_t)error );
 
-    rpc_dmsg("\n[INFO] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -970 +970 @@
                                   vfs_file_t * file )
 {
-    rpc_dmsg("\n[INFO] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -987 +987 @@
     rpc_send_sync( cxy , &rpc );
 
-    rpc_dmsg("\n[INFO] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -997 +997 @@
     vfs_file_t * file;
 
-    rpc_dmsg("\n[INFO] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -1011 +1011 @@
     vfs_file_destroy( file );
 
-    rpc_dmsg("\n[INFO] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -1027 +1027 @@
                                 error_t     * error )          // out
 {
-    rpc_dmsg("\n[INFO] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -1049 +1049 @@
     *error   = (error_t)rpc.args[3];
 
-    rpc_dmsg("\n[INFO] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -1064 +1064 @@
     char          name_copy[CONFIG_VFS_MAX_NAME_LENGTH];
 
-    rpc_dmsg("\n[INFO] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -1087 +1087 @@
     hal_remote_swd( XPTR( client_cxy , &desc->args[3] ) , (uint64_t)error );
 
-    rpc_dmsg("\n[INFO] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -1101 +1101 @@
                                      error_t     * error )     // out
 {
-    rpc_dmsg("\n[INFO] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -1121 +1121 @@
     *error   = (error_t)rpc.args[1];
 
-    rpc_dmsg("\n[INFO] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -1132 +1132 @@
     vfs_inode_t * inode;
 
-    rpc_dmsg("\n[INFO] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -1149 +1149 @@
     hal_remote_swd( XPTR( client_cxy , &desc->args[1] ) , (uint64_t)error );
 
-    rpc_dmsg("\n[INFO] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -1166 +1166 @@
                                    error_t  * error )    // out
 {
-    rpc_dmsg("\n[INFO] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -1189 +1189 @@
     *error   = (error_t)rpc.args[4];
 
-    rpc_dmsg("\n[INFO] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -1203 +1203 @@
     error_t       error;
 
-    rpc_dmsg("\n[INFO] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -1223 +1223 @@
     hal_remote_swd( XPTR( client_cxy , &desc->args[4] ) , (uint64_t)error );
 
-    rpc_dmsg("\n[INFO] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -1239 +1239 @@
                               error_t   * error )      // out
 {
-    rpc_dmsg("\n[INFO] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -1261 +1261 @@
     *error   = (error_t)rpc.args[3];
 
-    rpc_dmsg("\n[INFO] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -1275 +1275 @@
     error_t       error;
 
-    rpc_dmsg("\n[INFO] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -1295 +1295 @@
     hal_remote_swd( XPTR( client_cxy , &desc->args[3] ) , (uint64_t)error );
 
-    rpc_dmsg("\n[INFO] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -1313 +1313 @@
                              error_t   * error )   // out 
 {
-    rpc_dmsg("\n[INFO] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -1336 +1336 @@
     *error = (error_t)rpc.args[4];
 
-    rpc_dmsg("\n[INFO] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -1350 +1350 @@
     error_t       error;
 
-    rpc_dmsg("\n[INFO] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -1370 +1370 @@
     hal_remote_swd( XPTR( client_cxy , &desc->args[4] ) , (uint64_t)error );
 
-    rpc_dmsg("\n[INFO] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -1384 +1384 @@
                            xptr_t *   buf_xp )     // out
 {
-    rpc_dmsg("\n[INFO] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -1404 +1404 @@
     *buf_xp = (xptr_t)rpc.args[1];
 
-    rpc_dmsg("\n[INFO] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -1412 +1412 @@
 void rpc_kcm_alloc_server( xptr_t xp )
 {
-    rpc_dmsg("\n[INFO] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -1433 +1433 @@
     hal_remote_swd( XPTR( client_cxy , &desc->args[1] ) , (uint64_t)buf_xp );
 
-    rpc_dmsg("\n[INFO] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -1447 +1447 @@
                           uint32_t   kmem_type )   // in
 {
-    rpc_dmsg("\n[INFO] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -1465 +1465 @@
     rpc_send_sync( cxy , &rpc );
 
-    rpc_dmsg("\n[INFO] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -1473 +1473 @@
 void rpc_kcm_free_server( xptr_t xp )
 {
-    rpc_dmsg("\n[INFO] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -1491 +1491 @@
     kmem_free( &req );
 
-    rpc_dmsg("\n[INFO] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -1510 +1510 @@
                                     error_t  * error )        // out
 {
-    rpc_dmsg("\n[INFO] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -1535 +1535 @@
     *error     = (error_t)rpc.args[6];
 
-    rpc_dmsg("\n[INFO] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -1552 +1552 @@
     error_t    error;
 
-    rpc_dmsg("\n[INFO] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -1592 +1592 @@
     hal_remote_swd( XPTR( client_cxy , &desc->args[6] ) , (uint64_t)error );
 
-    rpc_dmsg("\n[INFO] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -1607 +1607 @@
                                  page_t         ** page )      // out
 {
-    rpc_dmsg("\n[INFO] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -1628 +1628 @@
     *page = (page_t *)(intptr_t)rpc.args[2];
 
-    rpc_dmsg("\n[INFO] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -1636 +1636 @@
 void rpc_mapper_get_page_server( xptr_t xp )
 {
-    rpc_dmsg("\n[INFO] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -1654 +1654 @@
     hal_remote_swd( XPTR( cxy , &desc->args[1] ) , (uint64_t)(intptr_t)page );
 
-    rpc_dmsg("\n[INFO] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : exit / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , CURRENT_THREAD->trdid , local_cxy, 
     CURRENT_THREAD->core->lid , hal_time_stamp() );
@@ -1673 +1673 @@
     reg_t      sr_save;
 
-    rpcg_dmsg("\n[INFO] %s : enter / client_cxy = %x / server_cxy = %x / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : enter / client_cxy = %x / server_cxy = %x / cycle %d\n",
     __FUNCTION__ , local_cxy , server_cxy , hal_time_stamp() );
 
@@ -1700 +1700 @@
     while( error );
  
-    rpcg_dmsg("\n[INFO] %s : RPC %l registered / server_cxy = %x / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : RPC %l registered / server_cxy = %x / cycle %d\n",
     __FUNCTION__ , desc_xp , server_cxy , hal_time_stamp() );
         
@@ -1714 +1714 @@
                     dev_pic_send_ipi( server_cxy , 0 );
 
-                    rpcg_dmsg("\n[INFO] %s : IPI sent / client_cxy = %x / server_cxy = %x\n",
+                    rpc_dmsg("\n[DMSG] %s : IPI sent / client_cxy = %x / server_cxy = %x\n",
             __FUNCTION__, local_cxy , server_cxy );
         }
@@ -1729 +1729 @@
         hal_restore_irq( sr_save );
 
-    rpcg_dmsg("\n[INFO] %s : completed / client_cxy = %x / server_cxy = %x / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : completed / client_cxy = %x / server_cxy = %x / cycle %d\n",
     __FUNCTION__ , local_cxy , server_cxy , hal_time_stamp() );
 
@@ -1764 +1764 @@
         count = 0;
 
-    rpcg_dmsg("\n[INFO] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
     __FUNCTION__, this->trdid, local_cxy, core->lid , hal_time_stamp() );
  
@@ -1781 +1781 @@
                 index = hal_remote_lw( XPTR( client_cxy , &desc->index ) );
 
-            rpcg_dmsg("\n[INFO] %s : thread %x on core [%x,%d] / rpc = %d\n",
+            rpc_dmsg("\n[DMSG] %s : thread %x on core [%x,%d] / rpc = %d\n",
                      __FUNCTION__ , this->trdid , core->lid , local_cxy , index );
 
@@ -1850 +1850 @@
         thread->blocked = 0;
 
-        rpcg_dmsg("\n[INFO] %s : activate RPC thread %x on core [%x,%d] / cycle %d\n", 
+        rpc_dmsg("\n[DMSG] %s : activate RPC thread %x on core [%x,%d] / cycle %d\n", 
                           __FUNCTION__ , thread , core->gid , local_cxy , hal_time_stamp() );
     }
@@ -1875 +1875 @@
             hal_atomic_add( &LOCAL_CLUSTER->rpc_threads , 1 );
 
-        rpcg_dmsg("\n[INFO] %s : create RPC thread %x on core [%x,%d] / cycle %d\n", 
+        rpc_dmsg("\n[DMSG] %s : create RPC thread %x on core [%x,%d] / cycle %d\n", 
                           __FUNCTION__ , thread->trdid, local_cxy, core->lid, hal_time_stamp() );
     }
@@ -1900 +1900 @@
     error_t      error;
 
-    rpcg_dmsg("\n[INFO] %s : enter / thread %x / cluster %x / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : enter / thread %x / cluster %x / cycle %d\n",
              __FUNCTION__ , this->trdid , local_cxy , hal_time_stamp() );
 
@@ -1906 +1906 @@
         if( (rpc_fifo->owner != 0) || (local_fifo_is_empty( &rpc_fifo->fifo )) )
     {
-        rpcg_dmsg("\n[INFO] %s : exit do nothing / thread %x / cluster %x / cycle %d\n",
+        rpc_dmsg("\n[DMSG] %s : exit do nothing / thread %x / cluster %x / cycle %d\n",
                  __FUNCTION__ , this->trdid , local_cxy , hal_time_stamp() );
 
@@ -1926 +1926 @@
         }
 
-        rpcg_dmsg("\n[INFO] %s : exit after RPC thread activation / "
+        rpc_dmsg("\n[DMSG] %s : exit after RPC thread activation / "
                  "thread %x / cluster %x / cycle %d\n",
                  __FUNCTION__ , this->trdid , local_cxy , hal_time_stamp() );
@@ -1934 +1934 @@
     else  // light lock taken by another thread
     {
-        rpcg_dmsg("\n[INFO] %s : exit do nothing / thread %x / cluster %x / cycle %d\n",
+        rpc_dmsg("\n[DMSG] %s : exit do nothing / thread %x / cluster %x / cycle %d\n",
                  __FUNCTION__ , this->trdid , local_cxy , hal_time_stamp() );
 
@@ -1951 +1951 @@
         rpc_fifo_t * rpc_fifo = &LOCAL_CLUSTER->rpc_fifo;
 
-    rpcg_dmsg("\n[INFO] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
+    rpc_dmsg("\n[DMSG] %s : enter / thread %x on core[%x,%d] / cycle %d\n",
              __FUNCTION__, this->trdid, local_cxy, this->core->lid, hal_time_stamp() );
 
@@ -1975 +1975 @@
                 if( LOCAL_CLUSTER->rpc_threads >= CONFIG_RPC_THREADS_MAX ) 
                 {
-            rpcg_dmsg("\n[INFO] %s : RPC thread %x on core[%x,%d] suicide / cycle %d\n", 
+            rpc_dmsg("\n[DMSG] %s : RPC thread %x on core[%x,%d] suicide / cycle %d\n", 
                     __FUNCTION__, this->trdid, local_cxy, this->core->lid, hal_time_stamp() );
 
@@ -1986 +1986 @@
         else
         {
-            rpcg_dmsg("\n[INFO] %s : RPC thread %x on core[%x,%d] blocks / cycle %d\n", 
+            rpc_dmsg("\n[DMSG] %s : RPC thread %x on core[%x,%d] blocks / cycle %d\n", 
                         __FUNCTION__, this->trdid, local_cxy, this->core->lid, hal_time_stamp() ); 
 
@@ -1992 +1992 @@
             sched_yield( NULL );
 
-                    rpcg_dmsg("\n[INFO] %s : RPC thread %x wake up on core[%x,%d] / cycle %d\n", 
+                    rpc_dmsg("\n[DMSG] %s : RPC thread %x wake up on core[%x,%d] / cycle %d\n", 
                 __FUNCTION__, this->trdid, local_cxy, this->core->lid, hal_time_stamp() );
         }

trunk/kernel/kern/scheduler.c

@@ -154 +154 @@
     scheduler_t * sched = &core->scheduler;
 
-    sched_dmsg("\n[INFO] %s : enter core[%x,%d] / cycle %d\n",
+    sched_dmsg("\n[DMSG] %s : enter core[%x,%d] / cycle %d\n",
     __FUNCTION__ , local_cxy , core->lid , hal_time_stamp() );
 
@@ -185 +185 @@
                 spinlock_unlock( &sched->lock );
 
-                sched_dmsg("\n[INFO] %s : exit core[%x,%d] / k_thread = %x / cycle %d\n",
+                sched_dmsg("\n[DMSG] %s : exit core[%x,%d] / k_thread = %x / cycle %d\n",
                 __FUNCTION__ , local_cxy , core->lid , thread->trdid , hal_time_stamp() );
 
@@ -216 +216 @@
                 spinlock_unlock( &sched->lock );
 
-                sched_dmsg("\n[INFO] %s : exit core[%x,%d] / u_thread = %x / cycle %d\n",
+                sched_dmsg("\n[DMSG] %s : exit core[%x,%d] / u_thread = %x / cycle %d\n",
                 __FUNCTION__ , local_cxy , core->lid , thread->trdid , hal_time_stamp() );
                 return thread;
@@ -227 +227 @@
     spinlock_unlock( &sched->lock );
 
-    sched_dmsg("\n[INFO] %s : exit core[%x,%d] / idle = %x / cycle %d\n",
+    sched_dmsg("\n[DMSG] %s : exit core[%x,%d] / idle = %x / cycle %d\n",
     __FUNCTION__ , local_cxy , core->lid , sched->idle->trdid , hal_time_stamp() );
 
@@ -242 +242 @@
     scheduler_t  * sched = &core->scheduler;
 
-    sched_dmsg("\n[INFO] %s : enter / thread %x on core[%x,%d]\n",
+    sched_dmsg("\n[DMSG] %s : enter / thread %x on core[%x,%d]\n",
     __FUNCTION__, CURRENT_THREAD->trdid , local_cxy , core->lid );
 
@@ -265 +265 @@
     spinlock_unlock( &sched->lock );
 
-    sched_dmsg("\n[INFO] %s : exit / thread %x on core[%x,%d]\n",
+    sched_dmsg("\n[DMSG] %s : exit / thread %x on core[%x,%d]\n",
     __FUNCTION__, CURRENT_THREAD->trdid , local_cxy , core->lid );
 
@@ -279 +279 @@
     scheduler_t * sched   = &core->scheduler;
 
-    sched_dmsg("\n[INFO] %s : thread %x on core[%x,%d] enter / cycle %d\n",
+    sched_dmsg("\n[DMSG] %s : thread %x on core[%x,%d] enter / cycle %d\n",
     __FUNCTION__, current->trdid, local_cxy, core->lid, hal_time_stamp() );
 
@@ -304 +304 @@
         if( next != current )
     {
-        sched_dmsg("\n[INFO] %s : trd %x (%s) on core[%x,%d] => trd %x (%s) / cycle %d\n",
+        sched_dmsg("\n[DMSG] %s : trd %x (%s) on core[%x,%d] => trd %x (%s) / cycle %d\n",
         __FUNCTION__, current->trdid, thread_type_str(current->type), local_cxy, core->lid, 
         next->trdid, thread_type_str(next->type), hal_time_stamp() );
@@ -331 +331 @@
     else
     {
-        sched_dmsg("\n[INFO] %s : thread %x on core[%x,%d] continue / cycle %d\n",
+        sched_dmsg("\n[DMSG] %s : thread %x on core[%x,%d] continue / cycle %d\n",
         __FUNCTION__, current->trdid, local_cxy, core->lid, hal_time_stamp() );
     }

trunk/kernel/kern/signal.c

@@ -44 +44 @@
                 hal_atomic_or( &thread->signals , (1 << sig_id) );
 
-        signal_dmsg("\n[INFO] %s : thread %x in process %x received signal %d\n",
+        signal_dmsg("\n[DMSG] %s : thread %x in process %x received signal %d\n",
                     __FUNCTION__, thread->trdid , process->pid , sig_id );
         }
@@ -59 +59 @@
         thread_s * this = CURRENT_THREAD;
 
-        printk("\n[INFO] %s : threadReceived signal %d, pid %d, tid %x, core %d  [ KILLED ]\n",
+        printk("\n[DMSG] %s : threadReceived signal %d, pid %d, tid %x, core %d  [ KILLED ]\n",
                sig,
                this->process->pid,

trunk/kernel/kern/thread.c

@@ -221 +221 @@
     vseg_t       * vseg;         // stack vseg
 
-    thread_dmsg("\n[INFO] %s : enters for process %x\n", __FUNCTION__ , pid );
+    thread_dmsg("\n[DMSG] %s : enters for process %x\n", __FUNCTION__ , pid );
 
     // get process descriptor local copy
@@ -311 +311 @@
     }
 
-    thread_dmsg("\n[INFO] %s : exit / trdid = %x / process %x / core = %d\n",
+    thread_dmsg("\n[DMSG] %s : exit / trdid = %x / process %x / core = %d\n",
                 __FUNCTION__ , thread->trdid , process->pid , core_lid );
 
@@ -328 +328 @@
         vseg_t       * vseg;         // stack vseg
 
-    thread_dmsg("\n[INFO] %s : enters\n", __FUNCTION__ );
+    thread_dmsg("\n[DMSG] %s : enters\n", __FUNCTION__ );
 
     // allocate a stack from local VMM
@@ -398 +398 @@
     }
 
-    thread_dmsg("\n[INFO] %s : exit / thread %x for process %x on core %d in cluster %x\n",
+    thread_dmsg("\n[DMSG] %s : exit / thread %x for process %x on core %d in cluster %x\n",
                  __FUNCTION__, thread->trdid, process->pid, core_lid, local_cxy );
 
@@ -416 +416 @@
         thread_t     * thread;       // pointer on new thread descriptor
 
-    thread_dmsg("\n[INFO] %s : enter / for type %s on core[%x,%d] / cycle %d\n",
+    thread_dmsg("\n[DMSG] %s : enter / for type %s on core[%x,%d] / cycle %d\n",
     __FUNCTION__ , thread_type_str( type ) , local_cxy , core_lid , hal_time_stamp() );
 
@@ -449 +449 @@
         hal_cpu_context_create( thread );
 
-    thread_dmsg("\n[INFO] %s : exit / trdid = %x / type = %s / core = [%x,%d] / cycle %d\n",
+    thread_dmsg("\n[DMSG] %s : exit / trdid = %x / type = %s / core = [%x,%d] / cycle %d\n",
     __FUNCTION__ , thread->trdid , thread_type_str(type) , 
     local_cxy , core_lid , hal_time_stamp() );
@@ -502 +502 @@
     core_t     * core       = thread->core;
 
-    thread_dmsg("\n[INFO] %s : enters for thread %x in process %x / type = %s\n",
+    thread_dmsg("\n[DMSG] %s : enters for thread %x in process %x / type = %s\n",
                 __FUNCTION__ , thread->trdid , process->pid , thread_type_str( thread->type ) );
 
@@ -556 +556 @@
         tm_end = hal_get_cycles();
 
-        thread_dmsg("\n[INFO] %s : exit for thread %x in process %x / duration = %d\n",
+        thread_dmsg("\n[DMSG] %s : exit for thread %x in process %x / duration = %d\n",
                        __FUNCTION__, thread->trdid , process->pid , tm_end - tm_start );
 }
@@ -732 +732 @@
     while( 1 )
     {
-        idle_dmsg("\n[INFO] %s : core[%x][%d] goes to sleep at cycle %d\n",
+        idle_dmsg("\n[DMSG] %s : core[%x][%d] goes to sleep at cycle %d\n",
                     __FUNCTION__ , local_cxy , lid , hal_get_cycles() );
 
@@ -738 +738 @@
         //hal_core_sleep();
 
-        idle_dmsg("\n[INFO] %s : core[%x][%d] wake up at cycle %d\n",
+        idle_dmsg("\n[DMSG] %s : core[%x][%d] wake up at cycle %d\n",
                     __FUNCTION__ , local_cxy , lid , hal_get_cycles() );
 

trunk/kernel/kern/thread.h

@@ -158 +158 @@
  * This TRDID is computed by the process_register_thread() function, when the user
  * thread is registered in the local copy of the process descriptor.
+ *
+ * WARNING : Don't modify the first 4 fields order, as this order is used by the
+ * hal_kentry assembly code for the TSAR architecture.
  **************************************************************************************/
 
@@ -164 +167 @@
 typedef struct thread_s
 {
-    void              * cpu_uzone;       /*! used for exception/interrupt/syscall     */
         void              * cpu_context;     /*! used for context switch                  */
         void              * fpu_context;     /*! used for dynamic FPU allocation          */
+
+        intptr_t            k_stack_base;    /*! kernel stack base address                */
+        uint32_t            k_stack_size;    /*! kernel stack size (bytes)                */
 
         uint32_t            trdid;           /*! thread index (cxy.ltid)                  */
@@ -189 +194 @@
         intptr_t            u_stack_base;    /*! user stack base address                  */
         uint32_t            u_stack_size;    /*! user stack size (bytes)                  */
-        intptr_t            k_stack_base;    /*! kernel stack base address                */
-        uint32_t            k_stack_size;    /*! kernel stack size (bytes)                */
 
     void              * entry_func;      /*! pointer on entry function                */

trunk/kernel/libk/elf.c

@@ -24 +24 @@
 #include <kernel_config.h>
 #include <hal_types.h>
+#include <hal_special.h>
 #include <hal_uspace.h>
 #include <printk.h>
 #include <process.h>
+#include <thread.h>
+#include <mapper.h>
 #include <vseg.h>
 #include <kmem.h>
@@ -165 +168 @@
                         type                       = VSEG_TYPE_CODE;
                         process->vmm.code_vpn_base = vbase >> CONFIG_PPM_PAGE_SHIFT;
-
-                        elf_dmsg("\n[INFO] %s : found CODE vseg / base = %x / size = %x\n",
-                                 __FUNCTION__ , vbase , mem_size );
                 }
                 else               // found DATA segment
@@ -173 +173 @@
                         type                       = VSEG_TYPE_DATA;
                         process->vmm.data_vpn_base = vbase >> CONFIG_PPM_PAGE_SHIFT;
-
-                        elf_dmsg("\n[INFO] %s : found DATA vseg / base = %x / size = %x\n",
-                                 __FUNCTION__, vbase , mem_size );
                 }
 
@@ -194 +191 @@
         vfs_file_t * file_ptr = (vfs_file_t *)GET_PTR( file_xp );
 
+        // get local pointer on .elf file mapper
+        mapper_t * mapper_ptr = (mapper_t *)hal_remote_lpt( XPTR( file_cxy , 
+                                                                  &file_ptr->mapper ) );
+
         // initialize "file_mapper", "file_offset", "file_size" fields in vseg 
-        vseg->mapper_xp   = (xptr_t)hal_remote_lwd( XPTR( file_cxy , &file_ptr->mapper ) );
+        vseg->mapper_xp   = XPTR( file_cxy , mapper_ptr );
         vseg->file_offset = file_offset;
         vseg->file_size   = file_size;
@@ -201 +202 @@
         // update reference counter in file descriptor
                 vfs_file_count_up( file_xp );
+
+                elf_dmsg("\n[DMSG] %s : found %s vseg / base = %x / size = %x\n"
+                 "       file_size = %x / file_offset = %x / mapper_xp = %l\n",
+            __FUNCTION__ , vseg_type_str(vseg->type) , vseg->min , vseg->max - vseg->min ,
+        vseg->file_size , vseg->file_offset , vseg->mapper_xp );
         }
 
@@ -219 +225 @@
         error_t      error;
 
-    elf_dmsg("\n[INFO] %s : core[%x,%d] enter for <%s>\n",
+    elf_dmsg("\n[DMSG] %s : core[%x,%d] enter for <%s>\n",
     __FUNCTION__ , local_cxy , CURRENT_THREAD->core->lid , pathname );
 
@@ -239 +245 @@
         }
 
-    elf_dmsg("\n[INFO] %s : open file <%s>\n", __FUNCTION__ , pathname );
+    elf_dmsg("\n[DMSG] %s : open file <%s>\n", __FUNCTION__ , pathname );
 
         // load header in local buffer
@@ -252 +258 @@
         }
 
-        elf_dmsg("\n[INFO] %s : loaded elf header for %s\n", __FUNCTION__ , pathname );
+        elf_dmsg("\n[DMSG] %s : loaded elf header for %s\n", __FUNCTION__ , pathname );
 
         if( header.e_phnum == 0 )
@@ -289 +295 @@
         }
 
-        elf_dmsg("\n[INFO] %s : segments array allocated for %s\n", __FUNCTION__ , pathname );
+        elf_dmsg("\n[DMSG] %s : segments array allocated for %s\n", __FUNCTION__ , pathname );
 
         // load seg descriptors array to local buffer
@@ -306 +312 @@
         }
 
-        elf_dmsg("\n[INFO] %s loaded segments descriptors for %s \n", __FUNCTION__ , pathname );
+        elf_dmsg("\n[DMSG] %s loaded segments descriptors for %s \n", __FUNCTION__ , pathname );
 
         // register loadable segments in process VMM
@@ -331 +337 @@
         kmem_free(&req);
 
-    elf_dmsg("\n[INFO] %s : core[%x,%d] exit for <%s> / entry_point = %x\n",
+    elf_dmsg("\n[DMSG] %s : core[%x,%d] exit for <%s> / entry_point = %x\n",
     __FUNCTION__ , local_cxy , CURRENT_THREAD->core->lid , pathname , header.e_entry );
 

trunk/kernel/libk/grdxt.c

@@ -26 +26 @@
 #include <errno.h>
 #include <printk.h>
+#include <vseg.h>
 #include <kmem.h>
 #include <grdxt.h>
@@ -125 +126 @@
     intptr_t        value;
 
-        printk("*** %s : n1 = %d / n2 = %d / n3 = %d\n", 
+        printk("\n***** Generic Radix tree %s : n1 = %d / n2 = %d / n3 = %d\n\n", 
            name, 1<<w1 , 1<<w2 , 1<<w3 );
 

trunk/kernel/libk/grdxt.h

@@ -36 +36 @@
  * Memory for the second and third levels arrays is dynamically allocated by the
  * grdxt_insert() function and is only released by grdxt_destroy().
- * - It used to by the VMM to retrieve a vseg descriptor: key is the virtual address.
- * - It is used by the mapper to implement the file cache: key is the page index in file.
+ * It is used by the MAPPER to implement the file cache: key is the page index in file.
  ******************************************************************************************/
 
@@ -48 +47 @@
 }
 grdxt_t;
-
 
 /*******************************************************************************************
@@ -122 +120 @@
 
 /*******************************************************************************************
- * This function displays the content of the radix_tree.
+ * This function displays the current content of a radix_tree.
  *******************************************************************************************
  * @ rt      : pointer on the radix-tree descriptor.
- * @ name    : string identifying the radix-tree.
+ * @ string  : radix tree identifier. 
  ******************************************************************************************/
 void grdxt_print( grdxt_t * rt,
-                  char    * name );
+                  char    * string );
 
 

trunk/kernel/mm/kcm.c

@@ -47 +47 @@
                              kcm_page_t * kcm_page )
 {
-        kcm_dmsg("\n[INFO] %s : enters for %s / page %x / count = %d / active = %d\n",
+        kcm_dmsg("\n[DMSG] %s : enters for %s / page %x / count = %d / active = %d\n",
                  __FUNCTION__ , kmem_type_str( kcm->type ) ,
                  (intptr_t)kcm_page , kcm_page->count , kcm_page->active );
@@ -80 +80 @@
                      + (index * kcm->block_size) );
 
-        kcm_dmsg("\n[INFO] %s : allocated one block  %s / ptr = %p / page = %x / count = %d\n",
+        kcm_dmsg("\n[DMSG] %s : allocated one block  %s / ptr = %p / page = %x / count = %d\n",
                  __FUNCTION__ , kmem_type_str( kcm->type ) , ptr ,
                  (intptr_t)kcm_page , kcm_page->count );
@@ -231 +231 @@
         kcm->blocks_nr = blocks_nr;
 
-        kcm_dmsg("\n[INFO] %s : KCM %s initialised / block_size = %d / blocks_nr = %d\n",
+        kcm_dmsg("\n[DMSG] %s : KCM %s initialised / block_size = %d / blocks_nr = %d\n",
                  __FUNCTION__ , kmem_type_str( type ) , kcm->block_size , kcm->blocks_nr );
 }
@@ -301 +301 @@
                 kcm_page->active = 1;
 
-                kcm_dmsg("\n[INFO] %s : enters for type %s at cycle %d / new page = %x / count = %d\n",
+                kcm_dmsg("\n[DMSG] %s : enters for type %s at cycle %d / new page = %x / count = %d\n",
                          __FUNCTION__ , kmem_type_str( kcm->type ) , hal_get_cycles() ,
                          (intptr_t)kcm_page , kcm_page->count );
@@ -311 +311 @@
                 kcm_page = (kcm_page_t *)LIST_FIRST( &kcm->active_root , kcm_page_t , list );
 
-                kcm_dmsg("\n[INFO] %s : enters for type %s at cycle %d / page = %x / count = %d\n",
+                kcm_dmsg("\n[DMSG] %s : enters for type %s at cycle %d / page = %x / count = %d\n",
                          __FUNCTION__ , kmem_type_str( kcm->type ) , hal_get_cycles() ,
                          (intptr_t)kcm_page , kcm_page->count );

trunk/kernel/mm/kmem.c

@@ -145 +145 @@
         assert( ((type > 1) && (type < KMEM_TYPES_NR) ) , __FUNCTION__ , "illegal KCM type" );
 
-        kmem_dmsg("\n[INFO] %s : enters / KCM type %s missing in cluster %x\n",
+        kmem_dmsg("\n[DMSG] %s : enters / KCM type %s missing in cluster %x\n",
                   __FUNCTION__ , kmem_type_str( type ) , local_cxy );
 
@@ -169 +169 @@
         hal_fence();
 
-        kmem_dmsg("\n[INFO] %s : exit / KCM type %s created in cluster %x\n",
+        kmem_dmsg("\n[DMSG] %s : exit / KCM type %s created in cluster %x\n",
                   __FUNCTION__ , kmem_type_str( type ) , local_cxy );
 
@@ -192 +192 @@
         assert( (type < KMEM_TYPES_NR) , __FUNCTION__ , "illegal KMEM request type" );
 
-        kmem_dmsg("\n[INFO] %s : enters in cluster %x for type %s\n",
+        kmem_dmsg("\n[DMSG] %s : enters in cluster %x for type %s\n",
                       __FUNCTION__ , local_cxy , kmem_type_str( type ) );
 
@@ -210 +210 @@
                 if( flags & AF_ZERO ) page_zero( (page_t *)ptr );
 
-                kmem_dmsg("\n[INFO] %s : exit in cluster %x for type %s / page = %x / base = %x\n",
+                kmem_dmsg("\n[DMSG] %s : exit in cluster %x for type %s / page = %x / base = %x\n",
                           __FUNCTION__, local_cxy , kmem_type_str( type ) ,
                           (intptr_t)ptr , (intptr_t)ppm_page2base( ptr ) );
@@ -228 +228 @@
                 if( flags & AF_ZERO ) memset( ptr , 0 , size );
 
-                kmem_dmsg("\n[INFO] %s : exit in cluster %x for type %s / base = %x / size = %d\n",
+                kmem_dmsg("\n[DMSG] %s : exit in cluster %x for type %s / base = %x / size = %d\n",
                           __FUNCTION__, local_cxy , kmem_type_str( type ) ,
                           (intptr_t)ptr , req->size );
@@ -255 +255 @@
                 if( flags & AF_ZERO ) memset( ptr , 0 , kmem_type_size( type ) );
 
-                kmem_dmsg("\n[INFO] %s : exit in cluster %x for type %s / base = %x / size = %d\n",
+                kmem_dmsg("\n[DMSG] %s : exit in cluster %x for type %s / base = %x / size = %d\n",
                           __FUNCTION__, local_cxy , kmem_type_str( type ) ,
                           (intptr_t)ptr , kmem_type_size( type ) );

trunk/kernel/mm/mapper.c

@@ -143 +143 @@
     error_t       error;
 
-    mapper_dmsg("\n[INFO] %s : enters for page %d in mapper %x\n",
+    mapper_dmsg("\n[DMSG] %s : enters for page %d / mapper %x\n",
                 __FUNCTION__ , index , mapper );
 
@@ -170 +170 @@
         if ( page == NULL )   // missing page => create it and load it from file system
         {
-            mapper_dmsg("\n[INFO] %s : missing page => load from device\n", __FUNCTION__ );
+            mapper_dmsg("\n[DMSG] %s : missing page => load from device\n", __FUNCTION__ );
 
             // allocate one page from PPM
@@ -212 +212 @@
             }
 
-            // update the mapper and index fields in page descriptor
-            // required by the vfs_move_page_to_mapper()
-            page->mapper = mapper;
-            page->index  = index;
-
             // launch I/O operation to load page from file system
             error = vfs_mapper_move_page( page, 
@@ -259 +254 @@
     }
 
-    mapper_dmsg("\n[INFO] %s : exit for page %d in mapper %x / page_desc = %x\n",
+    mapper_dmsg("\n[DMSG] %s : exit for page %d / mapper %x / page_desc = %x\n",
                 __FUNCTION__ , index , mapper , page );
 
@@ -315 +310 @@
     uint8_t  * buf_ptr;        // current buffer  address
 
-    mapper_dmsg("\n[INFO] %s : enters / to_buf = %d / buffer = %x\n",
+    mapper_dmsg("\n[DMSG] %s : enters / to_buf = %d / buffer = %x\n",
                 __FUNCTION__ , to_buffer , buffer );
 
@@ -341 +336 @@
         else                       page_count = CONFIG_PPM_PAGE_SIZE;
 
-        mapper_dmsg("\n[INFO] %s : index = %d / offset = %d / count = %d\n",
+        mapper_dmsg("\n[DMSG] %s : index = %d / offset = %d / count = %d\n",
                     __FUNCTION__ , index , page_offset , page_count );
 
@@ -356 +351 @@
         buf_ptr = (uint8_t *)buffer + done;
 
-        mapper_dmsg("\n[INFO] %s : index = %d / buf_ptr = %x / map_ptr = %x\n",
+        mapper_dmsg("\n[DMSG] %s : index = %d / buf_ptr = %x / map_ptr = %x\n",
                     __FUNCTION__ , index , buf_ptr , map_ptr );
 
@@ -373 +368 @@
     }
 
-    mapper_dmsg("\n[INFO] %s : exit for buffer %x\n",
+    mapper_dmsg("\n[DMSG] %s : exit for buffer %x\n",
                 __FUNCTION__, buffer );
 
@@ -398 +393 @@
     cxy_t      dst_cxy;        // destination cluster
 
-    mapper_dmsg("\n[INFO] %s : enters / to_buf = %d / buffer = %l / size = %x / cycle %d\n",
-                __FUNCTION__ , to_buffer , buffer_xp , size , hal_time_stamp() );
+    // get buffer cluster and local pointer
+    cxy_t     buffer_cxy = GET_CXY( buffer_xp );
+    uint8_t * buffer_ptr = (uint8_t *)GET_PTR( buffer_xp );
+
+    mapper_dmsg("\n[DMSG] %s : to_buf = %d / buf_cxy = %x / buf_ptr = %x / size = %x\n",
+    __FUNCTION__ , to_buffer , buffer_cxy , buffer_ptr , size );
 
     // compute offsets of first and last bytes in file
@@ -409 +408 @@
     uint32_t last  = max_byte >> CONFIG_PPM_PAGE_SHIFT;
 
-    // get buffer cluster and local pointer
-    cxy_t     buffer_cxy = GET_CXY( buffer_xp );
-    uint8_t * buffer_ptr = (uint8_t *)GET_PTR( buffer_xp );
+    mapper_dmsg("\n[DMSG] %s : first_page = %d / last_page = %d\n",
+    __FUNCTION__ , first , last );
 
     // compute source and destination clusters
@@ -440 +438 @@
         else                       page_count = CONFIG_PPM_PAGE_SIZE;
 
-        mapper_dmsg("\n[INFO] %s : page_index = %d / offset = %d / count = %d\n",
+        mapper_dmsg("\n[DMSG] %s : page_index = %d / offset = %d / bytes = %d\n",
                     __FUNCTION__ , index , page_offset , page_count );
 
@@ -466 +464 @@
         }
 
-        mapper_dmsg("\n[INFO] %s : index = %d\n", __FUNCTION__ , index );
-
         // move fragment
         hal_remote_memcpy( XPTR( dst_cxy , dst_ptr ), XPTR( src_cxy , src_ptr ), page_count );
@@ -474 +470 @@
     }
 
-    mapper_dmsg("\n[INFO] %s : exit for buffer %l / size = %x / cycle %d\n",
-                __FUNCTION__ , buffer_xp , size , hal_time_stamp() );
+    mapper_dmsg("\n[DMSG] %s : exit / buf_cxy = %x / buf_ptr = %x / size = %x\n",
+    __FUNCTION__ , buffer_cxy , buffer_ptr , size );
 
     return 0;
 
-}  // end mapper_move_kernel_buffer()
-
+}  // end mapper_move_kernel()
+

trunk/kernel/mm/ppm.c

@@ -56 +56 @@
     page_t * page_ptr = (page_t *)GET_PTR( page_xp );
 
-    void   * base_ptr = ppm->vaddr_base + 
-                        ((page_ptr - ppm->pages_tbl)<<CONFIG_PPM_PAGE_SHIFT);
-  
+   void   * base_ptr = ppm->vaddr_base + 
+                       ((page_ptr - ppm->pages_tbl)<<CONFIG_PPM_PAGE_SHIFT);
+
         return XPTR( page_cxy , base_ptr );
 
@@ -203 +203 @@
         assert( (order < CONFIG_PPM_MAX_ORDER) , __FUNCTION__ , "illegal order argument" );
 
-        page_t * block = NULL;
-
-        ppm_dmsg("\n[INFO] %s : enters / order = %d\n",
+        page_t * block = NULL;  
+
+        ppm_dmsg("\n[DMSG] %s : enters / order = %d\n",
                  __FUNCTION__ , order );
 
@@ -256 +256 @@
         spinlock_unlock( &ppm->free_lock );
 
-        ppm_dmsg("\n[INFO] %s : base = %x / order = %d\n",
+        ppm_dmsg("\n[DMSG] %s : base = %x / order = %d\n",
                  __FUNCTION__ , (uint32_t)ppm_page2base( block ) , order );
 

trunk/kernel/mm/vmm.c

@@ -62 +62 @@
     intptr_t  size;
 
-    vmm_dmsg("\n[INFO] %s : enter for process %x\n", __FUNCTION__ , process->pid );
+    vmm_dmsg("\n[DMSG] %s : enter for process %x\n", __FUNCTION__ , process->pid );
 
     // get pointer on VMM
@@ -83 +83 @@
     vmm->vsegs_nr = 0;
         list_root_init( &vmm->vsegs_root );
-    error = grdxt_init( &vmm->grdxt,
-                        CONFIG_VMM_GRDXT_W1,
-                        CONFIG_VMM_GRDXT_W2,
-                        CONFIG_VMM_GRDXT_W3 );
- 
-    assert( (error == 0) , __FUNCTION__ , "cannot initialize radix tree\n" );
 
     // register kentry vseg in VMM
-    base = 1 << CONFIG_PPM_PAGE_SHIFT;
+    base = CONFIG_VMM_KENTRY_BASE << CONFIG_PPM_PAGE_SHIFT;
     size = CONFIG_VMM_KENTRY_SIZE << CONFIG_PPM_PAGE_SHIFT;
+
     vseg_kentry = vmm_create_vseg( process , base , size , VSEG_TYPE_CODE );
 
     assert( (vseg_kentry != NULL) , __FUNCTION__ , "cannot register kentry vseg\n" );
 
-    vmm->kent_vpn_base = 1;
-
-    // register the args vseg in VMM
-    base = (CONFIG_VMM_KENTRY_SIZE + 1 )<<CONFIG_PPM_PAGE_SHIFT;
+    vmm->kent_vpn_base = base;
+
+    // register args vseg in VMM
+    base = (CONFIG_VMM_KENTRY_BASE + 
+            CONFIG_VMM_KENTRY_SIZE ) << CONFIG_PPM_PAGE_SHIFT;
     size = CONFIG_VMM_ARGS_SIZE << CONFIG_PPM_PAGE_SHIFT;
+
     vseg_args = vmm_create_vseg( process , base , size , VSEG_TYPE_DATA );
 
     assert( (vseg_args != NULL) , __FUNCTION__ , "cannot register args vseg\n" );
 
-    vmm->args_vpn_base = CONFIG_VMM_KENTRY_SIZE + 1;
+    vmm->args_vpn_base = base;
 
     // register the envs vseg in VMM
-    base = (CONFIG_VMM_KENTRY_SIZE + CONFIG_VMM_ARGS_SIZE + 1 )<<CONFIG_PPM_PAGE_SHIFT;
+    base = (CONFIG_VMM_KENTRY_BASE + 
+            CONFIG_VMM_KENTRY_SIZE +
+            CONFIG_VMM_ARGS_SIZE   ) << CONFIG_PPM_PAGE_SHIFT;
     size = CONFIG_VMM_ENVS_SIZE << CONFIG_PPM_PAGE_SHIFT;
+
     vseg_envs = vmm_create_vseg( process , base , size , VSEG_TYPE_DATA );
 
     assert( (vseg_envs != NULL) , __FUNCTION__ , "cannot register envs vseg\n" );
 
-    vmm->envs_vpn_base = CONFIG_VMM_KENTRY_SIZE + CONFIG_VMM_ARGS_SIZE + 1;
+    vmm->envs_vpn_base = base;
 
     // register the heap vseg in VMM
     base = CONFIG_VMM_HEAP_BASE << CONFIG_PPM_PAGE_SHIFT;
     size = (CONFIG_VMM_MMAP_BASE-CONFIG_VMM_HEAP_BASE) << CONFIG_PPM_PAGE_SHIFT;
+
     vseg_heap = vmm_create_vseg( process , base , size , VSEG_TYPE_HEAP );
 
     assert( (vseg_heap != NULL) , __FUNCTION__ , "cannot register heap vseg\n" );
 
-    vmm->heap_vpn_base = CONFIG_VMM_HEAP_BASE;
+    vmm->heap_vpn_base = base;
 
     // initialize generic page table
@@ -149 +150 @@
     hal_fence();
 
-    vmm_dmsg("\n[INFO] %s : exit for process %x\n", __FUNCTION__ , process->pid );
+    vmm_dmsg("\n[DMSG] %s : exit for process %x / entry_point = %x\n",
+    __FUNCTION__ , process->pid , process->vmm.entry_point );
 
 }  // end vmm_init()
@@ -171 +173 @@
     dst_vmm->vsegs_nr = 0;
     list_root_init( &dst_vmm->vsegs_root );
-    error = grdxt_init( &dst_vmm->grdxt,
-                        CONFIG_VMM_GRDXT_W1,
-                        CONFIG_VMM_GRDXT_W2,
-                        CONFIG_VMM_GRDXT_W3 );
-    if( error )
-    {
-        printk("\n[ERROR] in %s : cannot initialize radix tree for process %x\n",
-               __FUNCTION__ , dst_process->pid );
-        return ENOMEM;
-    }
 
     // loop on src_vmm list of vsegs to create
@@ -292 +284 @@
         vseg_free( vseg );
         }
-
-    // delete vsegs radix_tree
-    grdxt_destroy( &vmm->grdxt );
 
     // release lock
@@ -456 +445 @@
         vmm_t * vmm = &process->vmm;
 
-        vmm_dmsg("\n[INFO] %s : enter for process %x / base = %x / size = %x / type = %s\n",
+        vmm_dmsg("\n[DMSG] %s : enter for process %x / base = %x / size = %x / type = %s\n",
                      __FUNCTION__ , process->pid , base , size , vseg_type_str(type) );
 
@@ -527 +516 @@
 
     // update "heap_vseg" in VMM
-        process->vmm.heap_vseg = vseg;
+        if( type == VSEG_TYPE_HEAP ) process->vmm.heap_vseg = vseg;
 
     // attach vseg to vmm
@@ -534 +523 @@
         rwlock_wr_unlock( &vmm->vsegs_lock );
 
-        vmm_dmsg("\n[INFO] %s : exit for process %x / vseg [%x, %x] has been mapped\n",
+        vmm_dmsg("\n[DMSG] %s : exit for process %x / vseg [%x, %x] registered\n",
                      __FUNCTION__ , process->pid , vseg->min , vseg->max );
 
         return vseg;
-}
+
+}  // vmm_create_vseg()
 
 /////////////////////////////////////
@@ -665 +655 @@
 }
 
+///////////////////////////////////////////////////////////////////////////////////////
+// This low-level static function is called by the vmm_get_vseg() and vmm_resize_vseg()
+// functions.  It scan the list of registered vsegs to find the unique vseg containing
+// a given virtual address.
+///////////////////////////////////////////////////////////////////////////////////////
+// @ vmm     : pointer on the process VMM.
+// @ vaddr   : virtual address.
+// @ return vseg pointer if success / return NULL if not found.
+///////////////////////////////////////////////////////////////////////////////////////
+static vseg_t * vseg_from_vaddr( vmm_t    * vmm,
+                                 intptr_t   vaddr )
+{
+    list_entry_t * iter;
+    vseg_t       * vseg = NULL;
+
+    // get lock protecting the vseg list
+    rwlock_rd_lock( &vmm->vsegs_lock );
+
+    // scan the list of vsegs
+    LIST_FOREACH( &vmm->vsegs_root , iter )
+    {
+        vseg = LIST_ELEMENT( iter , vseg_t , list );
+        if( (vaddr >= vseg->min) && (vaddr < vseg->max) ) break;
+    }
+
+    // release the lock
+    rwlock_rd_unlock( &vmm->vsegs_lock );
+
+    return vseg;
+}
+
 /////////////////////////////////////////////
 error_t vmm_resize_vseg( process_t * process,
@@ -670 +691 @@
                          intptr_t    size )
 {
-        error_t error;
+    error_t   error;
+    vseg_t  * new;
+    vpn_t     vpn_min;
+    vpn_t     vpn_max;
 
     // get pointer on process VMM
@@ -677 +701 @@
     intptr_t addr_min = base;
         intptr_t addr_max = base + size;
-    uint32_t shift    = CONFIG_PPM_PAGE_SHIFT;
 
     // get pointer on vseg
-        vseg_t * vseg = grdxt_lookup( &vmm->grdxt , (uint32_t)(base >> shift) );
+        vseg_t * vseg = vseg_from_vaddr( vmm , base );
 
         if( vseg == NULL)  return EINVAL;
@@ -696 +719 @@
         error = 0;
     }
-        else if( vseg->min == addr_min )                              // vseg must be resized
-    {
-        panic("resize not implemented yet");
-                error = 0;
-    }
-        else if( vseg->max == addr_max )                              // vseg must be resized
-    {
-        panic("resize not implemented yet");
-                error = 0;
-    }
-    else            // vseg cut in three regions => vseg must be resized & new vseg created
-    {
-        panic("resize not implemented yet");
-                error = 0;
+        else if( vseg->min == addr_min )                         // vseg must be resized
+    {
+        // update vseg base address
+        vseg->min = addr_max;
+
+        // update vpn_base and vpn_size
+        vpn_min        = vseg->min >> CONFIG_PPM_PAGE_SHIFT;
+        vpn_max        = (vseg->max - 1) >> CONFIG_PPM_PAGE_SHIFT;
+        vseg->vpn_base = vpn_min;
+        vseg->vpn_size = vpn_max - vpn_min + 1;
+        error = 0;
+    }
+        else if( vseg->max == addr_max )                          // vseg must be resized
+    {
+        // update vseg max address
+        vseg->max = addr_min;
+
+        // update vpn_base and vpn_size
+        vpn_min        = vseg->min >> CONFIG_PPM_PAGE_SHIFT;
+        vpn_max        = (vseg->max - 1) >> CONFIG_PPM_PAGE_SHIFT;
+        vseg->vpn_base = vpn_min;
+        vseg->vpn_size = vpn_max - vpn_min + 1;
+        error = 0;
+    }
+    else                                                      // vseg cut in three regions 
+    {
+        // resize existing vseg
+        vseg->max = addr_min;
+
+        // update vpn_base and vpn_size
+        vpn_min        = vseg->min >> CONFIG_PPM_PAGE_SHIFT;
+        vpn_max        = (vseg->max - 1) >> CONFIG_PPM_PAGE_SHIFT;
+        vseg->vpn_base = vpn_min;
+        vseg->vpn_size = vpn_max - vpn_min + 1;
+
+        // create new vseg
+        new = vmm_create_vseg( process , addr_min , (vseg->max - addr_max) , vseg->type ); 
+        if( new == NULL ) error = EINVAL;
+        else              error = 0;
     }
 
@@ -716 +764 @@
 
         return error;
-}
+
+}  // vmm_resize_vseg()
 
 ///////////////////////////////////////////
@@ -723 +772 @@
                        vseg_t   ** found_vseg )
 {
-    vmm_t    * vmm;
-    vseg_t   * vseg;
-
-    // get pointer on process VMM
-    vmm = &process->vmm;
-
-    // get lock protecting the vseg list
-    rwlock_rd_lock( &vmm->vsegs_lock );
-
-    // get pointer on vseg from local radix tree
-        vseg = grdxt_lookup( &vmm->grdxt, (uint32_t)(vaddr >> CONFIG_PPM_PAGE_SHIFT) );
-
-    // release the lock
-    rwlock_rd_unlock( &vmm->vsegs_lock );
+    vmm_t  * vmm = &process->vmm;
+
+    // get vseg from vaddr
+    vseg_t * vseg = vseg_from_vaddr( vmm , vaddr );
 
     if( vseg == NULL )   // vseg not found in local cluster => try to get it from ref
@@ -752 +791 @@
         xptr_t   vseg_xp;
         error_t  error;
+
         rpc_vmm_get_vseg_client( ref_cxy , ref_ptr , vaddr , &vseg_xp , &error );
             
@@ -759 +799 @@
         vseg = vseg_alloc();
 
-        if( vseg == NULL ) panic("no memory for vseg copy in cluster %x", local_cxy );
+        if( vseg == NULL ) return -1;
 
         // initialise local vseg from reference
@@ -765 +805 @@
 
         // register local vseg in local VMM
-        error = vseg_attach( &process->vmm , vseg );
-
-        if( error ) panic("no memory for vseg registration in cluster %x", local_cxy );
+        vseg_attach( &process->vmm , vseg );
     }   
     
@@ -784 +822 @@
     cxy_t      page_cxy;          // physical page cluster
     page_t   * page_ptr;          // local pointer on physical page descriptor
-
-    uint32_t   type      = vseg->type;
-    xptr_t     mapper_xp = vseg->mapper_xp;
-    uint32_t   flags     = vseg->flags;
-
-    // get mapper cluster and local pointer
-    cxy_t      mapper_cxy = GET_CXY( mapper_xp );
-    mapper_t * mapper_ptr = (mapper_t *)GET_PTR( mapper_xp );
-
-    // FILE type : simply get the physical page from the file mapper
+    uint32_t   index;             // missing page index in vseg mapper
+    uint32_t   type;              // vseg type;
+
+    type      = vseg->type;
+    index     = vpn - vseg->vpn_base;
+
+    vmm_dmsg("\n[DMSG] %s : core[%x,%d] enter for vpn = %x / type = %s / index = %d\n",
+    __FUNCTION__, local_cxy, CURRENT_THREAD->core->lid, vpn, vseg_type_str(type), index );
+
+    // FILE type : get the physical page from the file mapper
     if( type == VSEG_TYPE_FILE )
     {
-        // compute index in file mapper
-        uint32_t index = vpn - vseg->vpn_base;
+        // get extended pointer on mapper
+        xptr_t     mapper_xp = vseg->mapper_xp;
+
+        assert( (mapper_xp != XPTR_NULL), __FUNCTION__,
+        "mapper not defined for a FILE vseg\n" );
+        
+        // get mapper cluster and local pointer
+        cxy_t      mapper_cxy = GET_CXY( mapper_xp );
+        mapper_t * mapper_ptr = (mapper_t *)GET_PTR( mapper_xp );
 
         // get page descriptor from mapper
@@ -814 +859 @@
     }
 
-    // all other types : allocate a physical page from target cluster,
+    // Other types : allocate a physical page from target cluster,
     else
     {
+        uint32_t flags = vseg->flags;
+
         // get target cluster for physical page
         if( flags & VSEG_DISTRIB ) // depends on VPN LSB
         {
-            uint32_t x_width = LOCAL_CLUSTER->x_width;
-            uint32_t y_width = LOCAL_CLUSTER->y_width;
-            page_cxy = vpn & ((1<<(x_width + y_width)) - 1);
+            uint32_t x_size = LOCAL_CLUSTER->x_size;
+            uint32_t y_size = LOCAL_CLUSTER->y_size;
+            page_cxy = vpn & ((x_size * y_size) - 1);
         }
         else                       // defined in vseg descriptor
@@ -831 +878 @@
         // allocate a physical page in target cluster
         kmem_req_t   req;
-        if( page_cxy == local_cxy )    // target cluster is the local cluster
+        if( page_cxy == local_cxy )  // target cluster is the local cluster
         {
             req.type  = KMEM_PAGE;
@@ -845 +892 @@
         if( page_ptr == NULL ) return ENOMEM;
 
-        // initialise page from .elf file mapper for DATA and CODE types
+        // initialise missing page from .elf file mapper for DATA and CODE types
+        // => the mapper_xp field is an extended pointer on the .elf file mapper
         if( (type == VSEG_TYPE_CODE) || (type == VSEG_TYPE_DATA) )
         {
-            // compute missing page index in vseg
-            vpn_t page_index = vpn - vseg->vpn_base;
+            // get extended pointer on mapper
+            xptr_t     mapper_xp = vseg->mapper_xp;
+
+            assert( (mapper_xp != XPTR_NULL), __FUNCTION__,
+            "mapper not defined for a CODE or DATA vseg\n" );
+        
+            // get mapper cluster and local pointer
+            cxy_t      mapper_cxy = GET_CXY( mapper_xp );
+            mapper_t * mapper_ptr = (mapper_t *)GET_PTR( mapper_xp );
+
+            // compute missing page offset in vseg
+            uint32_t offset = index << CONFIG_PPM_PAGE_SHIFT;
 
             // compute missing page offset in .elf file
-            intptr_t page_offset = vseg->file_offset + 
-                                   (page_index << CONFIG_PPM_PAGE_SHIFT);
-
-            // compute extended pointer on page first byte 
-            xptr_t base_xp = ppm_page2base( XPTR( page_cxy , page_ptr ) );
-
-            // file_size can be smaller than vseg_size for BSS
-            intptr_t file_size = vseg->file_size;
-
-            if( file_size < page_offset )                                // fully in  BSS 
+            uint32_t elf_offset = vseg->file_offset + offset;
+
+            vmm_dmsg("\n[DMSG] %s : core[%x,%d] for vpn = %x / elf_offset = %x\n",
+            __FUNCTION__, local_cxy, CURRENT_THREAD->core->lid, vpn, elf_offset );
+
+            // compute extended pointer on page base 
+            xptr_t base_xp  = ppm_page2base( XPTR( page_cxy , page_ptr ) );
+
+            // file_size (in .elf mapper) can be smaller than vseg_size (BSS)
+            uint32_t file_size = vseg->file_size;
+
+            if( file_size < offset )                 // missing page fully in  BSS 
             {
+                vmm_dmsg("\n[DMSG] %s : core[%x,%d] for vpn = %x / fully in BSS\n",
+                __FUNCTION__, local_cxy, CURRENT_THREAD->core->lid, vpn );
+
                 if( page_cxy == local_cxy )
                 {
@@ -872 +935 @@
                 }
             }
-            else if( file_size >= (page_offset + CONFIG_PPM_PAGE_SIZE) )  // fully in  mapper
+            else if( file_size >= (offset + CONFIG_PPM_PAGE_SIZE) )  // fully in  mapper
             {
+                vmm_dmsg("\n[DMSG] %s : core[%x,%d] for vpn = %x / fully in mapper\n",
+                __FUNCTION__, local_cxy, CURRENT_THREAD->core->lid, vpn );
+
                 if( mapper_cxy == local_cxy ) 
                 {
                     error = mapper_move_kernel( mapper_ptr,
                                                 true,             // to_buffer
-                                                page_offset,
+                                                elf_offset,
                                                 base_xp,
                                                 CONFIG_PPM_PAGE_SIZE ); 
@@ -888 +954 @@
                                                    true,         // to buffer
                                                    false,        // kernel buffer
-                                                   page_offset,
-                                                   (uint64_t)base_xp,
+                                                   elf_offset,
+                                                   base_xp,
                                                    CONFIG_PPM_PAGE_SIZE,
                                                    &error );
@@ -895 +961 @@
                 if( error ) return EINVAL;
             }
-            else  // in mapper : from page_offset -> (file_size - page_offset)
-                  // in BSS    : from file_size   -> (page_offset + page_size)
+            else  // both in mapper and in BSS :
+                  // - (file_size - offset)             bytes from mapper
+                  // - (page_size + offset - file_size) bytes from BSS
             {
+                vmm_dmsg("\n[DMSG] %s : core[%x,%d] for vpn = %x / both mapper & BSS\n"
+                         "      %d bytes from mapper / %d bytes from BSS\n",
+                __FUNCTION__, local_cxy, CURRENT_THREAD->core->lid, vpn,
+                file_size - offset , offset + CONFIG_PPM_PAGE_SIZE - file_size  );
+
                 // initialize mapper part
                 if( mapper_cxy == local_cxy )
@@ -903 +975 @@
                     error = mapper_move_kernel( mapper_ptr,
                                                 true,         // to buffer
-                                                page_offset,
+                                                elf_offset,
                                                 base_xp,
-                                                file_size - page_offset ); 
+                                                file_size - offset ); 
                 }
                 else                                
@@ -913 +985 @@
                                                    true,         // to buffer
                                                    false,        // kernel buffer
-                                                   page_offset,
-                                                   (uint64_t)base_xp,
-                                                   file_size - page_offset, 
+                                                   elf_offset,
+                                                   base_xp,
+                                                   file_size - offset, 
                                                    &error );
                 }
@@ -923 +995 @@
                 if( page_cxy == local_cxy )
                 {
-                    memset( GET_PTR( base_xp ) + file_size - page_offset , 0 , 
-                            page_offset + CONFIG_PPM_PAGE_SIZE - file_size );
+                    memset( GET_PTR( base_xp ) + file_size - offset , 0 , 
+                            offset + CONFIG_PPM_PAGE_SIZE - file_size );
                 }
                 else
                 {
-                   hal_remote_memset( base_xp + file_size - page_offset , 0 , 
-                                      page_offset + CONFIG_PPM_PAGE_SIZE - file_size );
+                   hal_remote_memset( base_xp + file_size - offset , 0 , 
+                                      offset + CONFIG_PPM_PAGE_SIZE - file_size );
                 }
             }    
@@ -937 +1009 @@
     // return ppn
     *ppn = ppm_page2ppn( XPTR( page_cxy , page_ptr ) );
+
+    vmm_dmsg("\n[DMSG] %s : core[%x,%d] exit for vpn = %x / ppn = %x\n",
+    __FUNCTION__ , local_cxy , CURRENT_THREAD->core->lid , vpn , *ppn );
+
     return 0;
 
@@ -954 +1030 @@
     // this function must be called by a thread running in the reference cluster
     assert( (GET_CXY( process->ref_xp ) == local_cxy ) , __FUNCTION__ ,
-             " not called in the reference cluster\n" );
+    "not called in the reference cluster\n" );
+
+    vmm_dmsg("\n[DMSG] %s : core[%x,%d] enter for vpn = %x in process %x\n",
+    __FUNCTION__ , local_cxy , CURRENT_THREAD->core->lid , vpn , process->pid );
 
     // get VMM pointer
@@ -968 +1047 @@
     if( (attr & GPT_MAPPED) == 0 )
     {
+        vmm_dmsg("\n[DMSG] %s : core[%x,%d] page %x unmapped => try to map it\n",
+        __FUNCTION__ , local_cxy , CURRENT_THREAD->core->lid , vpn );
+
         // 1. get vseg pointer
         error = vmm_get_vseg( process , vpn<<CONFIG_PPM_PAGE_SHIFT , &vseg );
@@ -977 +1059 @@
             return error;
         }
+
+        vmm_dmsg("\n[DMSG] %s : core[%x,%d] found vseg %s / vpn_base = %x / vpn_size = %x\n",
+        __FUNCTION__ , local_cxy , CURRENT_THREAD->core->lid ,
+        vseg_type_str(vseg->type) , vseg->vpn_base , vseg->vpn_size );
 
         // 2. get physical page number, depending on vseg type
@@ -1005 +1091 @@
     }  // end new PTE
 
+    vmm_dmsg("\n[DMSG] %s : core[%x,%d] exit for vpn = %x / ppn = %x\n",
+    __FUNCTION__ , local_cxy , CURRENT_THREAD->core->lid , vpn , ppn );
+
     *ret_ppn  = ppn;
     *ret_attr = attr;

trunk/kernel/mm/vmm.h

@@ -30 +30 @@
 #include <bits.h>
 #include <list.h>
-#include <grdxt.h>
 #include <spinlock.h>
 #include <hal_gpt.h>
@@ -92 +91 @@
  * This structure defines the Virtual Memory Manager for a given process in a given cluster.
  * This local VMM provides three main services:
- * 1) It registers all vsegs statically or dynamically defined in the vseg list,
- *    and in the associated radix-tree.
- * 2) It allocates virtual memory space for the STACKS and MMAP vsegs,
- *    using dedicated allocators.
+ * 1) It registers all vsegs statically or dynamically defined in the vseg list.
+ * 2) It allocates virtual memory space for the STACKS and MMAP vsegs.
  * 3) It contains the local copy of the generic page table descriptor.
  ********************************************************************************************/
@@ -104 +101 @@
         list_entry_t   vsegs_root;         /*! all vsegs in same process and same cluster       */
         uint32_t       vsegs_nr;           /*! total number of local vsegs                      */
-        grdxt_t        grdxt;              /*! embedded generic vsegs radix tree (key is vpn)   */
 
     gpt_t          gpt;                /*! embedded generic page table descriptor           */
@@ -144 +140 @@
 
 /*********************************************************************************************
- * This function initialises the virtual memory manager attached to a process.
- * - It initializes the VSL (list of vsegs and associated radix tree).
- * - It initializes the generic page table (empty).
+ * This function initialises the virtual memory manager attached to an user process.
+ * - It registers the "kentry", "args", "envs" and "heap" vsegs in the vsegs list.
+ *   The "code" and "data" vsegs are registered by the elf_load_process() function,
+ *   the "stack" vsegs are registered by the thread_user_create() function, and the
+ *   "mmap" vsegs are dynamically created by syscalls.
+ * - It initializes the generic page table, calling the HAL specific hal_gpt_init() function.
+ *   For TSAR it map all pages for the "kentry" vseg, that must be identity mapping.
  * - It initializes the STAK and MMAP allocators.
- * - It registers the "kentry", "args", "envs" and "heap" vsegs in the vsegs list.
- * Any error in this function gives a kernel panic.
+ * TODO : Any error in this function gives a kernel panic => improve error handling.
  *********************************************************************************************
  * @ process   : pointer on process descriptor
@@ -249 +248 @@
  * (a) if the region is not entirely mapped in an existing vseg, it's an error.
  * (b) if the region has same base and size as an existing vseg, the vseg is removed.
- * (c) if the removed region cut the vseg in two parts, it is removed and re-created.
- * (d) if the removed region cut the vseg in three parts, it is removed, and two are created.
- * TODO : cases (c) and (d) are not implemented [AG]
+ * (c) if the removed region cut the vseg in two parts, it is modified.
+ * (d) if the removed region cut the vseg in three parts, it is modified, and a new
+ *     vseg is created with same type.
  *********************************************************************************************
  * @ process   : pointer on process descriptor
@@ -267 +266 @@
  * - if the vseg is missing in local VMM, it uses a RPC to get it from the reference cluster,
  *   register it in local VMM and returns the local vseg pointer, if success.
- * - if the vseg is missing in reference VMM, it returns an user error.
- * It creates a kernel panic if there is not enough memory to create a new vseg descriptor
- * in the cluster containing the calling thread.
+ * - it returns an user error if the vseg is missing in the reference VMM, or if there is 
+ *   not enough memory for a new vseg descriptor in cluster containing the calling thread.
  *********************************************************************************************
  * @ process   : [in] pointer on process descriptor
@@ -320 +318 @@
  * Depending on the vseg type, defined by the <vseg> argument, it returns the PPN 
  * (Physical Page Number) associated to a missing page defined by the <vpn> argument.
- * - For the VSEG_TYPE_FILE, it returns the physical page from the file mapper.
- *   For all other types, it allocates a new physical page from the cluster defined
- *   by the <vseg->cxy> field, or by the <vpn> MSB bits for a distributed vseg.
- * - For the VSEG_TYPE_CODE and VSEG_TYPE_DATA types, the allocated page is initialized
- *   from the .elf file mapper. For others vseg types it is not initialised.
+ * - For the FILE type, it returns directly the physical page from the file mapper.
+ * - For the CODE and DATA types, it allocates a new phsical page from the cluster defined
+ *   by the <vseg->cxy> field, or by the <vpn> MSB bits for a distributed vseg,
+ *   and initialize this page from the .elf file mapper.
+ * - For all other types, it allocates a new physical page from the cluster defined
+ *   by the <vseg->cxy> field, or by the <vpn> MSB bits for a distributed vseg,
+ *   but the new page is not initialized.
  *********************************************************************************************
  * @ vseg   : local pointer on vseg containing the mising page.

trunk/kernel/mm/vseg.c

@@ -188 +188 @@
 
 ///////////////////////////////
-error_t vseg_attach( vmm_t  * vmm,
-                     vseg_t * vseg )
-{
-    // add vseg in radix-tree
-    error_t error = grdxt_insert( &vmm->grdxt , vseg->vpn_base , vseg );
-    if ( error ) return ENOMEM;
-
+void vseg_attach( vmm_t  * vmm,
+                  vseg_t * vseg )
+{
     // update vseg descriptor
     vseg->vmm = vmm;
@@ -200 +196 @@
     // add vseg in vmm list
     list_add_last( &vmm->vsegs_root , &vseg->list );
-
-    return 0;
 }
 
@@ -208 +202 @@
                   vseg_t * vseg )
 {
-    // remove vseg from radix-tree
-    grdxt_remove( &vmm->grdxt , vseg->vpn_base );
-
     // update vseg descriptor
     vseg->vmm = NULL;

trunk/kernel/mm/vseg.h

@@ -149 +149 @@
  * @ vmm       : pointer on the VMM
  * @ vseg      : pointer on the vseg descriptor
- * @ returns 0 if success / returns ENOMEM if registration in GRDXT unpossible. 
  *********************************************************************************************/
-error_t vseg_attach( struct vmm_s  * vmm,
-                     vseg_t        * vseg );
+void vseg_attach( struct vmm_s  * vmm,
+                  vseg_t        * vseg );
 
 /**********************************************************************************************

trunk/kernel/syscalls/sys_exec.c

@@ -223 +223 @@
     bool_t    is_local   = (cxy_server == cxy_client);
 
-    exec_dmsg("\n[INFO] %s starts for process %x on core %d in cluster %x"
+    exec_dmsg("\n[DMSG] %s starts for process %x on core %d in cluster %x"
                  " / target_cluster = %x / cycle %d\n",
                  __FUNCTION__, process->pid , CURRENT_CORE->lid,
@@ -261 +261 @@
     }
 
-    exec_dmsg("\n[INFO] %s starts exec for process %x at cycle %d\n",
+    exec_dmsg("\n[DMSG] %s starts exec for process %x at cycle %d\n",
               __FUNCTION__, process->pid, hal_get_cycles() );
 
@@ -275 +275 @@
     }
 
-    exec_dmsg("\n[INFO] %s completes exec for process %x at cycle %d\n",
+    exec_dmsg("\n[DMSG] %s completes exec for process %x at cycle %d\n",
               __FUNCTION__, process->pid , hal_get_cycles() );
 

trunk/kernel/syscalls/sys_fork.c

@@ -63 +63 @@
         }
 
-        fork_dmsg("\n[INFO] %s : enters for process %d at cycle [%d]\n",
+        fork_dmsg("\n[DMSG] %s : enters for process %d at cycle [%d]\n",
                   __FUNCTION__, parent_process->pid, hal_get_cycles());
 
@@ -71 +71 @@
         {
                 hal_fpu_context_save( parent_thread );
-                fork_dmsg("\n[INFO] %s : save FPU\n", __FUNCTION__);
+                fork_dmsg("\n[DMSG] %s : save FPU\n", __FUNCTION__);
         }
 
@@ -129 +129 @@
     process_reference_init( child_process , child_pid , parent_pid );
 
-        fork_dmsg("\n[INFO] : %s created child process : pid = %x / ppid = %x\n", 
+        fork_dmsg("\n[DMSG] : %s created child process : pid = %x / ppid = %x\n", 
               __FUNCTION__, child_pid , parent_pid );
 
@@ -148 +148 @@
                             XPTR( local_cxy , &parent_process->fd_array ) );
 
-        fork_dmsg("\n[INFO] %s : duplicated child process from parent process\n",
+        fork_dmsg("\n[DMSG] %s : duplicated child process from parent process\n",
                   __FUNCTION__ );
 
@@ -162 +162 @@
     }
   
-        fork_dmsg("\n[INFO] %s : parent vmm duplicated in child process\n", __FUNCTION__ );
+        fork_dmsg("\n[DMSG] %s : parent vmm duplicated in child process\n", __FUNCTION__ );
 
     // create child main thread descriptor in local cluster 
@@ -197 +197 @@
     child_thread->trdid   = child_trdid;
 
-        fork_dmsg("\n[INFO] %s : initialised child main thread\n", __FUNCTION__ );
+        fork_dmsg("\n[DMSG] %s : initialised child main thread\n", __FUNCTION__ );
 
     // register local child thread into local child process th_tbl[]
@@ -208 +208 @@
         sched_register_thread( child_thread->core , child_thread );
   
-        fork_dmsg("\n[INFO] %s : registered main thread in scheduler\n", __FUNCTION__);
+        fork_dmsg("\n[DMSG] %s : registered main thread in scheduler\n", __FUNCTION__);
 
         // update DQDT for the child thread 
     dqdt_local_update_threads( 1 );
 
-        fork_dmsg("\n[INFO] %s : completed / parent pid = %x / child pid = %x / at cycle [%d]\n",
+        fork_dmsg("\n[DMSG] %s : completed / parent pid = %x / child pid = %x / at cycle [%d]\n",
                   __FUNCTION__, parent_process->pid, child_process->pid, hal_get_cycles() );
 

trunk/kernel/syscalls/sys_signal.c

@@ -45 +45 @@
         this->process->sig_mgr.sigactions[sig_id] = handler;
 
-        signal_dmsg("\n[INFO] %s : handler @%x has been registred for signal %d\n",
+        signal_dmsg("\n[DMSG] %s : handler @%x has been registred for signal %d\n",
                     __FUNCTION__ , handler , sig_id );
 

trunk/kernel/syscalls/sys_thread_create.c

@@ -161 +161 @@
         tm_end = hal_get_cycles();
 
-        thread_dmsg("\n[INFO] %s created thread %x for process %x in cluster %x\n"
+        thread_dmsg("\n[DMSG] %s created thread %x for process %x in cluster %x\n"
                     "  start_cycle = %d / end_cycle = %d\n",
                        trdid , process->pid , k_attr.cxy , tm_start , tm_end );

trunk/kernel/syscalls/sys_thread_sleep.c

@@ -32 +32 @@
     thread_t * this = CURRENT_THREAD;
 
-    thread_dmsg("\n[INFO] %s : thread %x in process %x goes to sleep at cycle %d\n",
+    thread_dmsg("\n[DMSG] %s : thread %x in process %x goes to sleep at cycle %d\n",
                 __FUNCTION__, this->trdid, this->process->pid, hal_get_cycles() );
 
@@ -38 +38 @@
     sched_yield( NULL );
 
-    thread_dmsg("\n[INFO] %s : thread %x in process %x resume at cycle\n",
+    thread_dmsg("\n[DMSG] %s : thread %x in process %x resume at cycle\n",
                 __FUNCTION__, this->trdid, this->process->pid, hal_get_cycles() );
 

trunk/kernel/syscalls/sys_trace.c

@@ -49 +49 @@
         // desactivate thread trace TODO
 
-            printk("\n[INFO] %s : trace OFF  for thread %x in process %x\n",
+            printk("\n[DMSG] %s : trace OFF  for thread %x in process %x\n",
                __FUNCTION__ , trdid , pid );
     }
@@ -56 +56 @@
         // activate thread trace TODO
                     
-            printk("\n[INFO] %s : trace ON for thread %x in process %x\n",
+            printk("\n[DMSG] %s : trace ON for thread %x in process %x\n",
                __FUNCTION__ , trdid , pid );
     }

trunk/kernel/vfs/devfs.c

@@ -79 +79 @@
     error_t  error;
 
-    devfs_dmsg("\n[INFO] %s : enter in cluster %x\n",
+    devfs_dmsg("\n[DMSG] %s : enter in cluster %x\n",
                __FUNCTION__ , local_cxy );
 
@@ -93 +93 @@
     assert( (error == 0) , __FUNCTION__ , "cannot create <dev>\n" );
 
-    devfs_dmsg("\n[INFO] %s : <dev> created in cluster %x\n",
+    devfs_dmsg("\n[DMSG] %s : <dev> created in cluster %x\n",
                __FUNCTION__ , local_cxy );
 
@@ -107 +107 @@
     assert( (error == 0) , __FUNCTION__ , "cannot create <external>\n" );
 
-    devfs_dmsg("\n[INFO] %s : <external> created in cluster %x\n",
+    devfs_dmsg("\n[DMSG] %s : <external> created in cluster %x\n",
                __FUNCTION__ , local_cxy );
 } 

trunk/kernel/vfs/fatfs.c

@@ -249 +249 @@
 error_t fatfs_get_cluster( mapper_t * mapper,
                            uint32_t   first_cluster_id,
-                           uint32_t   page_index,
+                           uint32_t   searched_page_index,
                            uint32_t * searched_cluster_id )
 {
     page_t   * current_page_desc;      // pointer on current page descriptor
     uint32_t * current_page_buffer;    // pointer on current page (array of uint32_t)
-    uint32_t   current_page_index;     // index of current page in mapper 
+    uint32_t   current_page_index;     // index of current page in FAT 
     uint32_t   current_page_offset;    // offset of slot in current page
     uint32_t   page_count_in_file;     // index of page in file (index in linked list)
-    uint32_t   current_cluster_id;     // content of current FAT slot
-
-    assert( (page_index > 0) , __FUNCTION__ , "no FAT access required for first page\n");
-
-    fatfs_dmsg("\n[INFO] %s : enters / mapper = %x / first_cluster_id = %d / page_index = %d\n",
-               __FUNCTION__ , first_cluster_id , page_index );
-
-#if (CONFIG_FATFS_DEBUG > 1)
-    xptr_t     base_xp = ppm_page2base( XPTR( local_cxy , mapper_get_page ( mapper , 0 ) ) );
-    uint32_t * buf     = (uint32_t *)GET_PTR( base_xp );
-    uint32_t   line , word;
-    printk("\n***  FAT mapper content for first 256 entries ***\n");
-    for( line = 0 ; line < 16 ; line++ )
-    {
-        printk("%X : ", line );
-        for( word = 0 ; word < 16 ; word++ ) printk("%X ", buf[(line<<4) + word] );
-        printk("\n");
-    }
-#endif
-
-    // compute number of FAT slots per page
+    uint32_t   next_cluster_id;        // content of current FAT slot
+
+    assert( (searched_page_index > 0) , __FUNCTION__ , 
+    "no FAT access required for first page\n");
+
+    fatfs_dmsg("\n[DMSG] %s : enter / first_cluster_id = %d / searched_page_index = %d\n",
+    __FUNCTION__ , first_cluster_id , searched_page_index );
+
+    // get number of FAT slots per page
     uint32_t slots_per_page = CONFIG_PPM_PAGE_SIZE >> 2;
 
@@ -284 +272 @@
     current_page_offset = first_cluster_id % slots_per_page;
     page_count_in_file  = 0;
+    next_cluster_id     = 0xFFFFFFFF;
 
     // scan FAT (i.e. traverse FAT linked list)
-    while( page_count_in_file <= page_index )
-    {
-
-        fatfs_dmsg("\n[INFO] %s : page_index = %d / page_offset = %d / count = %d\n",
-               __FUNCTION__ , current_page_index , current_page_offset , page_count_in_file );
-
+    while( page_count_in_file < searched_page_index )
+    {
         // get pointer on current page descriptor
         current_page_desc = mapper_get_page( mapper , current_page_index );
@@ -302 +287 @@
 
         // get FAT slot content 
-        current_cluster_id = current_page_buffer[current_page_offset];
+        next_cluster_id = current_page_buffer[current_page_offset];
+
+        fatfs_dmsg("\n[DMSG] %s : traverse FAT / current_page_index = %d\n"
+                   "       current_page_offset = %d / next_cluster_id = %d\n",
+        __FUNCTION__ , current_page_index , current_page_offset , next_cluster_id );
 
         // update loop variables
-        current_page_index  = current_cluster_id / slots_per_page;
-        current_page_offset = current_cluster_id % slots_per_page;
+        current_page_index  = next_cluster_id / slots_per_page;
+        current_page_offset = next_cluster_id % slots_per_page;
         page_count_in_file++;
     }
-    
-    fatfs_dmsg("\n[INFO] %s : exit / cluster_id = %d\n",
-               __FUNCTION__ , current_cluster_id );
-
-    *searched_cluster_id = current_cluster_id;
+
+    if( next_cluster_id == 0xFFFFFFFF ) return EIO;
+   
+    fatfs_dmsg("\n[DMSG] %s : exit / cluster_id = %d\n", __FUNCTION__ , next_cluster_id );
+
+    *searched_cluster_id = next_cluster_id;
     return 0;
 
@@ -343 +333 @@
     uint8_t     * buffer;
 
-    fatfs_dmsg("\n[INFO] %s : enter for fatfs_ctx = %x\n",
+    fatfs_dmsg("\n[DMSG] %s : enter for fatfs_ctx = %x\n",
                __FUNCTION__ , fatfs_ctx );
 
@@ -357 +347 @@
                    "cannot allocate memory for 512 bytes buffer\n" );
      
-    fatfs_dmsg("\n[INFO] %s : allocated 512 bytes buffer\n", __FUNCTION__ );
+    fatfs_dmsg("\n[DMSG] %s : allocated 512 bytes buffer\n", __FUNCTION__ );
 
     // load the boot record from device
@@ -363 +353 @@
     error = dev_ioc_sync_read( buffer , 0 , 1 );
 
-    fatfs_dmsg("\n[INFO] %s : buffer loaded\n", __FUNCTION__ );
-
-    assert( (error == 0) , __FUNCTION__ ,
-                   "cannot access boot record\n" );
-
-#if (CONFIG_FATFS_DEBUG > 1)
+    fatfs_dmsg("\n[DMSG] %s : buffer loaded\n", __FUNCTION__ );
+
+    assert( (error == 0) , __FUNCTION__ , "cannot access boot record\n" );
+
+#if (CONFIG_FATFS_DEBUG & 0x1)
+if( hal_time_stamp() > CONFIG_FATFS_DEBUG )
+{
     uint32_t   line;
     uint32_t   byte = 0;
-    printk("\n***** FAT boot record\n" );
+    printk("\n***** %s : FAT boot record\n", __FUNCTION__ );
     for ( line = 0 ; line < 32 ; line++ )
     {
@@ -383 +374 @@
          byte += 16;
     }
+}
 #endif
 
@@ -423 +415 @@
     kmem_free( &req );
 
-    fatfs_dmsg("\n[INFO] %s : boot record read & released\n",
+    fatfs_dmsg("\n[DMSG] %s : boot record read & released\n",
                __FUNCTION__ );
 
@@ -445 +437 @@
     fatfs_ctx->fat_mapper_xp         = XPTR( local_cxy , fat_mapper );
 
-    fatfs_dmsg("\n[INFO] %s : exit for fatfs_ctx = %x\n",
+    fatfs_dmsg("\n[DMSG] %s : exit for fatfs_ctx = %x\n",
                __FUNCTION__ , fatfs_ctx );
 
@@ -472 +464 @@
     fatfs_ctx_t * fatfs_ctx;   // pointer on local FATFS context
 
-    // get pointer on source mapper and page index from page descriptor
+    // get pointer on mapper and page index from page descriptor
     mapper = page->mapper;
     index  = page->index;
 
-    // get VFS inode pointer from mapper
+    // get inode pointer from mapper
     inode = mapper->inode;
 
-    fatfs_dmsg("\n[INFO] %s : core[%x,%d] enter for inode %x / page_id = %d / mapper = %x\n",
-    __FUNCTION__ , local_cxy , CURRENT_THREAD->core->lid , inode , index , mapper );
-
-    // get page to move base address
+    fatfs_dmsg("\n[DMSG] %s : core[%x,%d] enter for page %d / inode %x / mapper %x\n",
+    __FUNCTION__ , local_cxy , CURRENT_THREAD->core->lid , index , inode , mapper );
+
+    // get page base address
     xptr_t base_xp = ppm_page2base( XPTR( local_cxy , page ) );
     buffer = (uint8_t *)GET_PTR( base_xp );
@@ -496 +488 @@
         lba = fatfs_ctx->fat_begin_lba + (count * index);
  
-        fatfs_dmsg("\n[INFO] %s : core[%x,%d] access FAT on device / lba = %d\n",
+        fatfs_dmsg("\n[DMSG] %s : core[%x,%d] access FAT on device / lba = %d\n",
         __FUNCTION__ , local_cxy , CURRENT_THREAD->core->lid , lba );
 
@@ -519 +511 @@
         else                        // FAT mapper access required
         {
+            fatfs_dmsg("\n[DMSG] %s : core[%x,%d] must access FAT\n",
+            __FUNCTION__ , local_cxy , CURRENT_THREAD->core->lid );
+
             // get cluster and local pointer on FAT mapper
             xptr_t     fat_mapper_xp  = fatfs_ctx->fat_mapper_xp;
@@ -545 +540 @@
         }
 
+        fatfs_dmsg("\n[DMSG] %s : core[%x,%d] access device for inode %x / cluster_id %d\n",
+        __FUNCTION__ , local_cxy , CURRENT_THREAD->core->lid , inode , searched_cluster_id );
+
         // get lba from cluster_id
         lba = fatfs_lba_from_cluster( fatfs_ctx , searched_cluster_id );
-
-        fatfs_dmsg("\n[INFO] %s : core[%x,%d] access device for inode %x / cluster_id = %d\n",
-        __FUNCTION__ , local_cxy , CURRENT_THREAD->core->lid , inode , first_cluster_id );
 
         // access device
@@ -558 +553 @@
     }
 
-    fatfs_dmsg("\n[INFO] %s : core[%x,%d] exit for inode %x / page_id = %d / mapper = %x\n",
-    __FUNCTION__ , local_cxy , CURRENT_THREAD->core->lid , inode , index , mapper );
+    fatfs_dmsg("\n[DMSG] %s : core[%x,%d] exit for page %d / inode %x / mapper %x\n",
+    __FUNCTION__ , local_cxy , CURRENT_THREAD->core->lid , index , inode , mapper );
+
+#if (CONFIG_FATFS_DEBUG & 0x1)
+if( hal_time_stamp() > CONFIG_FATFS_DEBUG )
+{
+    uint32_t * tab = (uint32_t *)buffer;
+    uint32_t line , word;
+    printk("\n***** %s : First 64 words of loaded page\n", __FUNCTION__ );
+    for( line = 0 ; line < 8 ; line++ )
+    {
+        printk("%X : ", line );
+        for( word = 0 ; word < 8 ; word++ ) printk("%X ", tab[(line<<3) + word] );
+        printk("\n");
+    }
+}
+#endif
 
     return 0;
@@ -574 +584 @@
     // - scan the directory entries in each 4 Kbytes page
 
-    fatfs_dmsg("\n[INFO] %s : enter for child <%s> in parent inode %l\n",
+    fatfs_dmsg("\n[DMSG] %s : enter for child <%s> in parent inode %l\n",
                __FUNCTION__ , name , XPTR( local_cxy , parent_inode ) );
 
@@ -612 +622 @@
         base = (uint8_t *)GET_PTR( base_xp );
 
-#if (CONFIG_FATFS_DEBUG > 1)
+#if (CONFIG_FATFS_DEBUG & 0x1)
+if( hal_time_stamp() > CONFIG_FATFS_DEBUG )
+{
     uint32_t * buf = (uint32_t *)base;
     uint32_t line , word;
-    printk("\n***** first 16 dir entries for parent inode %x\n", parent_inode );
+    printk("\n***** %s : First 16 dentries for parent inode %x\n",
+    __FUNCTION__ , parent_inode );
     for( line = 0 ; line < 16 ; line++ )
     {
@@ -622 +635 @@
         printk("\n");
     }
+}
 #endif
-
-
         // scan this page until end of directory, end of page, or name found
         while( (offset < 4096) && (found == 0) )
@@ -693 +705 @@
     if ( found == -1 )  // found end of directory => failure 
     {
-        fatfs_dmsg("\n[INFO] %s : exit / child <%s> not found in parent inode %l\n",
+        fatfs_dmsg("\n[DMSG] %s : exit / child <%s> not found in parent inode %l\n",
                    __FUNCTION__ , name , XPTR( local_cxy , parent_inode ) );
 
@@ -711 +723 @@
         hal_remote_sw( XPTR( child_cxy , &child_ptr->extend ) , cluster );
 
-        fatfs_dmsg("\n[INFO] %s : exit / child <%s> found in parent inode %l\n",
+        fatfs_dmsg("\n[DMSG] %s : exit / child <%s> found in parent inode %l\n",
                    __FUNCTION__ , name , XPTR( local_cxy , parent_inode ) );
 

trunk/kernel/vfs/fatfs.h

@@ -202 +202 @@
  ******************************************************************************************
  * @ mapper                  : local pointer on the FAT mapper.
- * @ first_cluster_id    : index of the first FATFS cluster allocated to the file.
- * @ searched_page       : index of searched page in the file.
+ * @ first_cluster       : index of the first FATFS cluster allocated to the file.
+ * @ page_index          : index of searched page in file.
  * @ searched_cluster_id : [out] found FATFS cluster index.
  * @ return 0 if success / return EIO if a FAT mapper miss cannot be solved.

trunk/kernel/vfs/vfs.c

@@ -1707 +1707 @@
     assert( (mapper != NULL) , __FUNCTION__ , "no mapper for page\n" );
 
-    vfs_dmsg("\n[INFO] %s : enters for page %d in mapper / inode_xp %l\n",
-    __FUNCTION__ , page->index , XPTR( local_cxy , &mapper->inode ) );
+    vfs_dmsg("\n[DMSG] %s : enters for page %d / inode_cxy = %x / inode_ptr = %x\n",
+    __FUNCTION__ , page->index , local_cxy , mapper->inode );
 
     // get FS type
@@ -1733 +1733 @@
     }
 
-    vfs_dmsg("\n[INFO] %s : exit for page %d in mapper / inode %l\n",
-    __FUNCTION__ , page->index , XPTR( local_cxy , &mapper->inode) );
+    vfs_dmsg("\n[DMSG] %s : exit for page %d / inode_cxy = %x / inode_ptr = %x\n",
+    __FUNCTION__ , page->index , local_cxy , mapper->inode );
 
     return error;