The Tor Browser / file comparison
comparison: nsprpub/pr/src/bthreads/btlocks.c
nsprpub/pr/src/bthreads/btlocks.c
- changeset 0
- 6474c204b198
equal
deleted
inserted
replaced
| -1:000000000000 | 0:f74959220603 |
|---|---|
| 1 /* -*- Mode: C++; c-basic-offset: 4 -*- */ | |
| 2 /* This Source Code Form is subject to the terms of the Mozilla Public | |
| 3 * License, v. 2.0. If a copy of the MPL was not distributed with this | |
| 4 * file, You can obtain one at http://mozilla.org/MPL/2.0/. */ | |
| 5 | |
| 6 /* | |
| 7 ** File: btlocks.c | |
| 8 ** Description: Implemenation for thread locks using bthreads | |
| 9 ** Exports: prlock.h | |
| 10 */ | |
| 11 | |
| 12 #include "primpl.h" | |
| 13 | |
| 14 #include <string.h> | |
| 15 #include <sys/time.h> | |
| 16 | |
| 17 void | |
| 18 _PR_InitLocks (void) | |
| 19 { | |
| 20 } | |
| 21 | |
| 22 PR_IMPLEMENT(PRLock*) | |
| 23 PR_NewLock (void) | |
| 24 { | |
| 25 PRLock *lock; | |
| 26 status_t semresult; | |
| 27 | |
| 28 if (!_pr_initialized) _PR_ImplicitInitialization(); | |
| 29 | |
| 30 lock = PR_NEWZAP(PRLock); | |
| 31 if (lock != NULL) { | |
| 32 | |
| 33 lock->benaphoreCount = 0; | |
| 34 lock->semaphoreID = create_sem( 0, "nsprLockSem" ); | |
| 35 if( lock->semaphoreID < B_NO_ERROR ) { | |
| 36 | |
| 37 PR_DELETE( lock ); | |
| 38 lock = NULL; | |
| 39 } | |
| 40 } | |
| 41 | |
| 42 return lock; | |
| 43 } | |
| 44 | |
| 45 PR_IMPLEMENT(void) | |
| 46 PR_DestroyLock (PRLock* lock) | |
| 47 { | |
| 48 status_t result; | |
| 49 | |
| 50 PR_ASSERT(NULL != lock); | |
| 51 result = delete_sem(lock->semaphoreID); | |
| 52 PR_ASSERT(result == B_NO_ERROR); | |
| 53 PR_DELETE(lock); | |
| 54 } | |
| 55 | |
| 56 PR_IMPLEMENT(void) | |
| 57 PR_Lock (PRLock* lock) | |
| 58 { | |
| 59 PR_ASSERT(lock != NULL); | |
| 60 | |
| 61 if( atomic_add( &lock->benaphoreCount, 1 ) > 0 ) { | |
| 62 | |
| 63 if( acquire_sem(lock->semaphoreID ) != B_NO_ERROR ) { | |
| 64 | |
| 65 atomic_add( &lock->benaphoreCount, -1 ); | |
| 66 return; | |
| 67 } | |
| 68 } | |
| 69 | |
| 70 lock->owner = find_thread( NULL ); | |
| 71 } | |
| 72 | |
| 73 PR_IMPLEMENT(PRStatus) | |
| 74 PR_Unlock (PRLock* lock) | |
| 75 { | |
| 76 PR_ASSERT(lock != NULL); | |
| 77 lock->owner = NULL; | |
| 78 if( atomic_add( &lock->benaphoreCount, -1 ) > 1 ) { | |
| 79 | |
| 80 release_sem_etc( lock->semaphoreID, 1, B_DO_NOT_RESCHEDULE ); | |
| 81 } | |
| 82 | |
| 83 return PR_SUCCESS; | |
| 84 } | |
| 85 | |
| 86 PR_IMPLEMENT(void) | |
| 87 PR_AssertCurrentThreadOwnsLock(PRLock *lock) | |
| 88 { | |
| 89 PR_ASSERT(lock != NULL); | |
| 90 PR_ASSERT(lock->owner == find_thread( NULL )); | |
| 91 } |
