Changeset 446 for trunk/kernel/syscalls/sys_read.c

Timestamp:

Jun 19, 2018, 5:12:57 PM (6 years ago)

Author:

alain

Message:

miscelaneous...

File:

• trunk/kernel/syscalls/sys_read.c (modified) (4 diffs)

trunk/kernel/syscalls/sys_read.c

@@ -63 +63 @@
     reg_t        save_sr;     // required to enable IRQs during syscall
 
-        thread_t  *  this    = CURRENT_THREAD;
-        process_t *  process = this->process;
+        thread_t  *  this             = CURRENT_THREAD;
+        process_t *  process          = this->process;
+    xptr_t       process_owner_xp = process->owner_xp;
  
 #if DEBUG_SYS_READ
@@ -165 +166 @@
                                 count );
     }
-    else if( type == INODE_TYPE_DEV )  // check ownership & read from from device
+    else if( type == INODE_TYPE_DEV )  // check ownership & read from device
     {
         // get cluster and pointers on TXT_RX chdev 
@@ -172 +173 @@
         chdev_t * chdev_ptr = GET_PTR( chdev_xp );
 
-        volatile xptr_t    owner_xp;    
+        volatile xptr_t    txt_owner_xp;    
+        uint32_t           iter = 0;
 
         while( 1 )
         {
-            // extended pointer on owner process
-            owner_xp  = hal_remote_lwd( XPTR( chdev_cxy , &chdev_ptr->ext.txt.owner_xp ) );
+            // extended pointer on TXT owner process
+            txt_owner_xp  = hal_remote_lwd( XPTR( chdev_cxy , &chdev_ptr->ext.txt.owner_xp ) );
 
             // check TXT_RX ownership
-            if ( XPTR( local_cxy , process ) != owner_xp )
+            if ( process_owner_xp != txt_owner_xp )
             {
+                if( (iter & 0xFFF) == 0 )
+                printk("\n[WARNING] in %s : thread %x in process %x wait TXT_RX / cycle %d\n",
+                __FUNCTION__, this->trdid, process->pid, (uint32_t)hal_get_cycles() );
+
                 // deschedule without blocking
-                sched_yield( "wait TXT ownership" );
+                sched_yield( "wait TXT_RX ownership" );
+
+                iter++;
             }
             else
@@ -191 +199 @@
         }
 
+printk("\n###### in %s : thread %x in process %x got TXT_RX ownership\n", 
+__FUNCTION__, this->trdid, process->pid );
+                
         // move count bytes from device
         nbytes = devfs_user_move( true,             // from device to buffer