Changeset 415 for trunk/kernel/kern/rpc.c

Timestamp:

Dec 22, 2017, 1:16:59 PM (6 years ago)

Author:

alain

Message:

Few bugs.

File:

• trunk/kernel/kern/rpc.c (modified) (10 diffs)

trunk/kernel/kern/rpc.c

@@ -106 +106 @@
     rpc->lid       = core->lid;
 
+printk("\n   @@@ enter %s : rpc_desc_cxy = %x / rpc_desc_ptr = %x / index = %d / &index = %x\n",
+__FUNCTION__ , local_cxy , rpc , rpc->index , &rpc->index);
+ 
     // build an extended pointer on the RPC descriptor
         xptr_t   desc_xp = XPTR( local_cxy , rpc );
@@ -176 +179 @@
     }
     
+printk("\n   @@@ exit %s : rpc_desc_cxy = %x / rpc_desc_ptr = %x / index = %d / &index = %x\n",
+__FUNCTION__ , local_cxy , rpc , rpc->index , &rpc->index);
+ 
 }  // end rpc_send()
 
@@ -245 +251 @@
     }
 
+//@@@
+sched_display( 0 );
+//@@@
+
 grpc_dmsg("\n[DBG] %s : core[%x,%d] / interrupted thread %s deschedules / cycle %d\n", 
 __FUNCTION__, local_cxy, core->lid, thread_type_str(this->type), hal_time_stamp() );
@@ -300 +310 @@
                 while( 1 )  // internal loop
             {
+
                     empty = local_fifo_get_item( rpc_fifo , (uint64_t *)&desc_xp );
 
@@ -311 +322 @@
                         index = hal_remote_lw( XPTR( desc_cxy , &desc_ptr->index ) );
 
+printk("\n   @@@ in %s : rpc_desc_cxy = %x / rpc_desc_ptr = %x / index = %d / &index = %x\n",
+__FUNCTION__ , desc_cxy , desc_ptr , index , &desc_ptr->index );
+ 
 grpc_dmsg("\n[DBG] %s : core[%x,%d] / RPC thread %x / starts rpc %d / cycle %d\n",
-__FUNCTION__ , local_cxy , this->core->lid , this->trdid , index , hal_time_stamp() );
+__FUNCTION__ , local_cxy , this->core->lid , this->trdid , index , (uint32_t)hal_get_cycles() );
 
                     // call the relevant server function
@@ -980 +994 @@
 
 /////////////////////////////////////////////////////////////////////////////////////////
-// [9]     Marshaling functions attached to RPC_PROCESS_KILL  (multicast / non blocking)
+// [9] Marshaling functions attached to RPC_PROCESS_SIGACTION (multicast / non blocking)
 /////////////////////////////////////////////////////////////////////////////////////////
 
@@ -990 +1004 @@
                                    xptr_t      client_xp )     // in
 {
-signal_dmsg("\n[DBG] %s : enter for %s / thread %x on core[%x,%d] / cycle %d\n",
-__FUNCTION__ , process_action_str( sigaction ) , CURRENT_THREAD ,
+sigaction_dmsg("\n[DBG] %s : enter for %s (%d) / thread %x on core[%x,%d] / cycle %d\n",
+__FUNCTION__ , process_action_str( sigaction ) , sigaction , CURRENT_THREAD ,
 local_cxy , CURRENT_THREAD->core->lid , hal_time_stamp() );
 
@@ -1007 +1021 @@
     rpc_send( cxy , &rpc , false );
 
-signal_dmsg("\n[DBG] %s : exit for %s / thread %x on core[%x,%d] / cycle %d\n",
-__FUNCTION__ , process_action_str( sigaction ) , CURRENT_THREAD ,
+sigaction_dmsg("\n[DBG] %s : exit for %s (%d) / thread %x on core[%x,%d] / cycle %d\n",
+__FUNCTION__ , process_action_str( sigaction ) , sigaction , CURRENT_THREAD ,
 local_cxy , CURRENT_THREAD->core->lid , hal_time_stamp() );
 }  
@@ -1030 +1044 @@
     client_xp = (xptr_t)               hal_remote_lwd( XPTR( client_cxy , &desc->args[3] ) );
     
-signal_dmsg("\n[DBG] %s : enter for %s / thread %x on core[%x,%d] / cycle %d\n",
-__FUNCTION__ , process_action_str( action ) , CURRENT_THREAD ,
+sigaction_dmsg("\n[DBG] %s : enter for %s (%d) / thread %x on core[%x,%d] / cycle %d\n",
+__FUNCTION__ , process_action_str( action ) , action , CURRENT_THREAD ,
 local_cxy , CURRENT_THREAD->core->lid , hal_time_stamp() );
 
@@ -1039 +1053 @@
     else if (action == UNBLOCK_ALL_THREADS ) process_unblock( process , rsp_xp , client_xp );
 
-signal_dmsg("\n[DBG] %s : exit for %s / thread %x on core[%x,%d] / cycle %d\n",
-__FUNCTION__ , process_action_str( action ) , CURRENT_THREAD ,
+sigaction_dmsg("\n[DBG] %s : exit for %s (%d) / thread %x on core[%x,%d] / cycle %d\n",
+__FUNCTION__ , process_action_str( action ) , action , CURRENT_THREAD ,
 local_cxy , CURRENT_THREAD->core->lid , hal_time_stamp() );
 }