From 771465fed0cf50ee2dd790723245fc091699c324 Mon Sep 17 00:00:00 2001
From: rpj <rpj>
Date: Mon, 17 May 2004 01:38:02 +0000
Subject: re-indentation, bug fixes, hooks for pre-emptive async cancelation

---
 pthread_rwlock_timedwrlock.c | 167 ++++++++++++++++++++++---------------------
 1 file changed, 86 insertions(+), 81 deletions(-)

(limited to 'pthread_rwlock_timedwrlock.c')

diff --git a/pthread_rwlock_timedwrlock.c b/pthread_rwlock_timedwrlock.c
index 5844510..b23abd2 100644
--- a/pthread_rwlock_timedwrlock.c
+++ b/pthread_rwlock_timedwrlock.c
@@ -41,95 +41,100 @@
 #include "implement.h"
 
 int
-pthread_rwlock_timedwrlock(pthread_rwlock_t * rwlock, const struct timespec * abstime)
+pthread_rwlock_timedwrlock (pthread_rwlock_t * rwlock,
+			    const struct timespec *abstime)
 {
-    int result;
-    pthread_rwlock_t rwl;
-
-    if (rwlock == NULL || *rwlock == NULL)
-      {
-	return EINVAL;
-      }
-
-    /*
-     * We do a quick check to see if we need to do more work
-     * to initialise a static rwlock. We check
-     * again inside the guarded section of ptw32_rwlock_check_need_init()
-     * to avoid race conditions.
-     */
-    if (*rwlock == PTHREAD_RWLOCK_INITIALIZER)
-      {
-	result = ptw32_rwlock_check_need_init(rwlock);
-
-	if (result != 0 && result != EBUSY)
-	  {
-	    return result;
-	  }
-      }
-
-    rwl = *rwlock;
-
-    if (rwl->nMagic != PTW32_RWLOCK_MAGIC)
-      {
-	return EINVAL;
-      }
-
-    if ((result = pthread_mutex_timedlock(&(rwl->mtxExclusiveAccess), abstime)) != 0)
-      {
-	return result;
-      }
-
-    if ((result = pthread_mutex_timedlock(&(rwl->mtxSharedAccessCompleted), abstime)) != 0)
-      {
-	(void) pthread_mutex_unlock(&(rwl->mtxExclusiveAccess));
-	return result;
-      }
-
-    if (rwl->nExclusiveAccessCount == 0) 
-      {
-	if (rwl->nCompletedSharedAccessCount > 0) 
-	  {
-	    rwl->nSharedAccessCount -= rwl->nCompletedSharedAccessCount;
-	    rwl->nCompletedSharedAccessCount = 0;
-	  }
-
-	if (rwl->nSharedAccessCount > 0) 
-	  {
-	    rwl->nCompletedSharedAccessCount = -rwl->nSharedAccessCount;
-
-	    /*
-	     * This routine may be a cancelation point
-	     * according to POSIX 1003.1j section 18.1.2.
-	     */
+  int result;
+  pthread_rwlock_t rwl;
+
+  if (rwlock == NULL || *rwlock == NULL)
+    {
+      return EINVAL;
+    }
+
+  /*
+   * We do a quick check to see if we need to do more work
+   * to initialise a static rwlock. We check
+   * again inside the guarded section of ptw32_rwlock_check_need_init()
+   * to avoid race conditions.
+   */
+  if (*rwlock == PTHREAD_RWLOCK_INITIALIZER)
+    {
+      result = ptw32_rwlock_check_need_init (rwlock);
+
+      if (result != 0 && result != EBUSY)
+	{
+	  return result;
+	}
+    }
+
+  rwl = *rwlock;
+
+  if (rwl->nMagic != PTW32_RWLOCK_MAGIC)
+    {
+      return EINVAL;
+    }
+
+  if ((result =
+       pthread_mutex_timedlock (&(rwl->mtxExclusiveAccess), abstime)) != 0)
+    {
+      return result;
+    }
+
+  if ((result =
+       pthread_mutex_timedlock (&(rwl->mtxSharedAccessCompleted),
+				abstime)) != 0)
+    {
+      (void) pthread_mutex_unlock (&(rwl->mtxExclusiveAccess));
+      return result;
+    }
+
+  if (rwl->nExclusiveAccessCount == 0)
+    {
+      if (rwl->nCompletedSharedAccessCount > 0)
+	{
+	  rwl->nSharedAccessCount -= rwl->nCompletedSharedAccessCount;
+	  rwl->nCompletedSharedAccessCount = 0;
+	}
+
+      if (rwl->nSharedAccessCount > 0)
+	{
+	  rwl->nCompletedSharedAccessCount = -rwl->nSharedAccessCount;
+
+	  /*
+	   * This routine may be a cancelation point
+	   * according to POSIX 1003.1j section 18.1.2.
+	   */
 #ifdef _MSC_VER
 #pragma inline_depth(0)
 #endif
-	    pthread_cleanup_push(ptw32_rwlock_cancelwrwait, (void*)rwl);
-
-	    do
-	      {
-                result = pthread_cond_timedwait(&(rwl->cndSharedAccessCompleted),
-                                                &(rwl->mtxSharedAccessCompleted),
-                                                abstime);
-	      }
-	    while (result == 0 && rwl->nCompletedSharedAccessCount < 0);
-
-	    pthread_cleanup_pop ((result != 0) ? 1 : 0);
+	  pthread_cleanup_push (ptw32_rwlock_cancelwrwait, (void *) rwl);
+
+	  do
+	    {
+	      result =
+		pthread_cond_timedwait (&(rwl->cndSharedAccessCompleted),
+					&(rwl->mtxSharedAccessCompleted),
+					abstime);
+	    }
+	  while (result == 0 && rwl->nCompletedSharedAccessCount < 0);
+
+	  pthread_cleanup_pop ((result != 0) ? 1 : 0);
 #ifdef _MSC_VER
 #pragma inline_depth()
 #endif
 
-	    if (result == 0)
-	      {
-		rwl->nSharedAccessCount = 0;
-	      }
-	  }
-      }
+	  if (result == 0)
+	    {
+	      rwl->nSharedAccessCount = 0;
+	    }
+	}
+    }
 
-    if (result == 0)
-      {
-	rwl->nExclusiveAccessCount++;
-      }
+  if (result == 0)
+    {
+      rwl->nExclusiveAccessCount++;
+    }
 
-    return result;
+  return result;
 }
-- 
cgit v1.2.3