gnustep/libs-base
0
0
Fork 0
mirror of https://github.com/gnustep/libs-base.git synced 2025-05-31 00:30:53 +00:00
Code Issues Projects Releases Packages Wiki Activity

connection root object fixup

Browse source 
git-svn-id: svn+ssh://svn.gna.org/svn/gnustep/libs/base/trunk@28766 72102866-910b-0410-8b05-ffd578937521
This commit is contained in:
Richard Frith-MacDonald 2009-10-03 15:35:40 +00:00
parent fcc33c1b71
commit e06f2305f0
3 changed files with 40 additions and 14 deletions
Download patch file Download diff file Expand all files Collapse all files

41
Source/NSConnection.m
View file

@ -1656,7 +1656,7 @@ static NSLock *cached_proxies_gate = nil;
* If this is a server connection without a remote end, its root proxy
* is the same as its root object.
*/
if (IreceivePort ==IsendPort)
if (IreceivePort == IsendPort)
{
return [self rootObject];
}
@ -2843,25 +2843,42 @@ static void callEncoder (DOContext *ctxt)
for (pos = 0; pos < count; pos++)
{
unsigned target;
NSDistantObject *prox;
ProxyStruct *prox;
[rmc decodeValueOfObjCType: @encode(typeof(target)) at: &target];
prox = (NSDistantObject*)[self includesLocalTarget: target];
if (prox != nil)
prox = (ProxyStruct*)[self includesLocalTarget: target];
if (prox != 0)
{
if (debug_connection > 3)
NSLog(@"releasing object with target (0x%x) on (%@) counter %d",
target, self, ((ProxyStruct*)prox)->_counter);
#if 1
// FIXME thread safety
if (--(((ProxyStruct*)prox)->_counter) == 0)
target, self, prox->_counter);
M_LOCK(IrefGate);
NS_DURING
{
[self removeLocalObject: prox];
if (--(prox->_counter) == 0)
{
id rootObject = rootObjectForInPort(IreceivePort);
if (rootObject == prox->_object)
{
/* Don't deallocate root object ...
*/
prox->_counter = 0;
}
else
{
[self removeLocalObject: (id)prox];
}
}
}
#else
[self removeLocalObject: prox];
#endif
NS_HANDLER
{
M_UNLOCK(IrefGate);
[localException raise];
}
NS_ENDHANDLER
M_UNLOCK(IrefGate);
}
else if (debug_connection > 3)
NSLog(@"releasing object with target (0x%x) on (%@) - nothing to do",