gnustep/libs-base
0
0
Fork 0
mirror of https://github.com/gnustep/libs-base.git synced 2025-04-22 16:33:29 +00:00
Code Issues Projects Releases Packages Wiki Activity

Commit file accidentally omitted earlier.

Browse source 
git-svn-id: svn+ssh://svn.gna.org/svn/gnustep/libs/base/trunk@18039 72102866-910b-0410-8b05-ffd578937521
This commit is contained in:
Richard Frith-Macdonald 2003-11-03 06:27:52 +00:00
parent 5bd9bdbc5c
commit 33cd489562
1 changed files with 11 additions and 39 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

50
Source/NSNotificationCenter.m
View file

@ -34,6 +34,7 @@
#include "Foundation/NSException.h"
#include "Foundation/NSLock.h"
#include "Foundation/NSThread.h"
#include "GNUstepBase/GSLock.h"
/**
@ -208,6 +209,8 @@ static void obsFree(Observation *o);
#include "GNUstepBase/GSIMap.h"
@class GSLazyRecursiveLock;
/*
* An NC table is used to keep track of memory allocated to store
* Observation structures. When an Observation is removed from the
@ -237,9 +240,7 @@ typedef struct NCTbl {
GSIMapTable named; /* Getting named messages only. */
GSIArray array; /* Temp store during posting. */
unsigned lockCount; /* Count recursive operations. */
NSRecursiveLock *_lock; /* Lock out other threads. */
IMP lImp;
IMP uImp;
GSLazyRecursiveLock *_lock; /* Lock out other threads. */
BOOL lockingDisabled;
BOOL immutableInPost;
@ -415,16 +416,16 @@ static NCTable *newNCTable(void)
static inline void lockNCTable(NCTable* t)
{
if (t->_lock != nil && t->lockingDisabled == NO)
(*t->lImp)(t->_lock, @selector(lock));
if (t->lockingDisabled == NO)
[t->_lock lock];
t->lockCount++;
}
static inline void unlockNCTable(NCTable* t)
{
t->lockCount--;
if (t->_lock != nil && t->lockingDisabled == NO)
(*t->uImp)(t->_lock, @selector(unlock));
if (t->lockingDisabled == NO)
[t->_lock unlock];
}
static void obsFree(Observation *o)
@ -582,42 +583,13 @@ static NSNotificationCenter *default_center = nil;
/* Initializing. */
- (void) _becomeThreaded: (NSNotification*)notification
{
unsigned count;
TABLE->_lock = [NSRecursiveLock new];
TABLE->lImp = [TABLE->_lock methodForSelector: @selector(lock)];
TABLE->uImp = [TABLE->_lock methodForSelector: @selector(unlock)];
count = LOCKCOUNT;
/*
* If we start locking inside a method that would normally have been
* locked, we must lock the lock enough times so that when we leave
* the method the number of unlocks will match.
*/
while (count-- > 0)
{
(*TABLE->lImp)(TABLE->_lock, @selector(lock));
}
}
- (id) init
{
[super init];
TABLE = newNCTable();
if ([NSThread isMultiThreaded])
if ((self = [super init]) != nil)
{
[self _becomeThreaded: nil];
TABLE = newNCTable();
TABLE->_lock = [GSLazyRecursiveLock new];
}
else
{
[[NSNotificationCenter defaultCenter]
addObserver: self
selector: @selector(_becomeThreaded:)
name: NSWillBecomeMultiThreadedNotification
object: nil];
}
return self;
}