Changeset 629 for trunk/kernel/libk/remote_queuelock.c

Timestamp:

May 17, 2019, 9:27:04 AM (5 years ago)

Author:

alain

Message:

Remove the "giant" rwlock protecting the GPT, and
use the GPT_LOCKED attribute in each PTE to prevent
concurrent modifications of one GPT entry.
The version number has been incremented to 2.1.

File:

• trunk/kernel/libk/remote_queuelock.c (modified) (6 diffs)

trunk/kernel/libk/remote_queuelock.c

@@ -2 +2 @@
  * remote_queuelock.c - remote kernel lock with waiting queue implementation.
  *
- * Authors   Alain Greiner     (2016,2017,2018)
+ * Authors   Alain Greiner     (2016,2017,2018,2019)
  *
  * Copyright (c) UPMC Sorbonne Universites
@@ -56 +56 @@
 #if DEBUG_QUEUELOCK_TYPE
 thread_t * this = CURRENT_THREAD;
-if( DEBUG_QUEUELOCK_TYPE == type )
+if( (type     == DEBUG_QUEUELOCK_TYPE) &&
+    (lock_ptr == DEBUG_QUEUELOCK_PTR ) &&
+    (lock_cxy == DEBUG_QUEUELOCK_CXY ) )
 printk("\n[%s] thread[%x,%x] initialise lock %s [%x,%x]\n",
 __FUNCTION__, this->process->pid, this->trdid,
@@ -91 +93 @@
 
 #if DEBUG_QUEUELOCK_TYPE
-if( (DEBUG_QUEUELOCK_TYPE == lock_type) || (DEBUG_QUEUELOCK_TYPE == 1000) )
+if( (lock_type == DEBUG_QUEUELOCK_TYPE) &&
+    (lock_ptr  == DEBUG_QUEUELOCK_PTR ) &&
+    (lock_cxy  == DEBUG_QUEUELOCK_CXY ) )
 printk("\n[%s] thread[%x,%x] BLOCK on q_lock %s [%x,%x]\n",
 __FUNCTION__, this->process->pid, this->trdid, 
@@ -117 +121 @@
 
 #if DEBUG_QUEUELOCK_TYPE
-if( (DEBUG_QUEUELOCK_TYPE == lock_type) || (DEBUG_QUEUELOCK_TYPE == 1000) )
+if( (lock_type == DEBUG_QUEUELOCK_TYPE) &&
+    (lock_ptr  == DEBUG_QUEUELOCK_PTR ) &&
+    (lock_cxy  == DEBUG_QUEUELOCK_CXY ) )
 printk("\n[%s] thread[%x,%x] ACQUIRE q_lock %s [%x,%x]\n",
 __FUNCTION__, this->process->pid, this->trdid, 
@@ -152 +158 @@
 thread_t * this      = CURRENT_THREAD;
 uint32_t   lock_type = hal_remote_l32( XPTR( lock_cxy , &lock_ptr->lock.type ) );
-if( (DEBUG_QUEUELOCK_TYPE == lock_type) || (DEBUG_QUEUELOCK_TYPE == 1000) )
+if( (lock_type == DEBUG_QUEUELOCK_TYPE) &&
+    (lock_ptr  == DEBUG_QUEUELOCK_PTR ) &&
+    (lock_cxy  == DEBUG_QUEUELOCK_CXY ) )
 printk("\n[%s] thread[%x,%x] RELEASE q_lock %s (%x,%x)\n",
 __FUNCTION__, this->process->pid, this->trdid,
@@ -171 +179 @@
 
 #if DEBUG_QUEUELOCK_TYPE
-if( (DEBUG_QUEUELOCK_TYPE == lock_type) || (DEBUG_QUEUELOCK_TYPE == 1000) )
+if( (lock_type == DEBUG_QUEUELOCK_TYPE) &&
+    (lock_ptr  == DEBUG_QUEUELOCK_PTR ) &&
+    (lock_cxy  == DEBUG_QUEUELOCK_CXY ) )
 {
     trdid_t     trdid   = hal_remote_l32( XPTR( thread_cxy , &thread_ptr->trdid ) );