mirror of
https://github.com/gnustep/libs-base.git
synced 2025-04-26 18:21:04 +00:00
git-svn-id: svn+ssh://svn.gna.org/svn/gnustep/libs/base/trunk@3630 72102866-910b-0410-8b05-ffd578937521
879 lines
24 KiB
Objective-C
879 lines
24 KiB
Objective-C
/* Implementation for GNU Objective-C version of NSDistantObject
|
||
Copyright (C) 1997 Free Software Foundation, Inc.
|
||
|
||
Written by: Richard Frith-Macdonald <richard@brainstorm.co.uk>
|
||
Based on code by: Andrew Kachites McCallum <mccallum@gnu.ai.mit.edu>
|
||
Created: August 1997
|
||
|
||
This file is part of the GNUstep Base Library.
|
||
|
||
This library is free software; you can redistribute it and/or
|
||
modify it under the terms of the GNU Library General Public
|
||
License as published by the Free Software Foundation; either
|
||
version 2 of the License, or (at your option) any later version.
|
||
|
||
This library is distributed in the hope that it will be useful,
|
||
but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
|
||
Library General Public License for more details.
|
||
|
||
You should have received a copy of the GNU Library General Public
|
||
License along with this library; if not, write to the Free
|
||
Software Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
|
||
*/
|
||
|
||
#include <config.h>
|
||
#include <Foundation/DistributedObjects.h>
|
||
#include <Foundation/NSLock.h>
|
||
#include <Foundation/NSMethodSignature.h>
|
||
#include <Foundation/NSException.h>
|
||
|
||
static int debug_proxy = 0;
|
||
static Class placeHolder = 0;
|
||
static Class distantObjectClass = 0;
|
||
|
||
|
||
|
||
/*
|
||
* The GSDistantObjectPlaceHolder class is simply used as a placeholder
|
||
* for an NSDistantObject so we can manage efficient allocation and
|
||
* initialisation - in most cases when we ask for an NSDistantObject
|
||
* instance, we will get a pre-existing one, so we don't want to go
|
||
* allocating the memory for a new instance unless absolutely necessary.
|
||
*/
|
||
@interface GSDistantObjectPlaceHolder
|
||
+ (id) initWithLocal: (id)anObject connection: (NSConnection*)aConnection;
|
||
+ (id) initWithTarget: (unsigned)target connection: (NSConnection*)aConnection;
|
||
+ (void) autorelease;
|
||
+ (void) release;
|
||
+ (id) retain;
|
||
@end
|
||
|
||
@implementation GSDistantObjectPlaceHolder
|
||
|
||
+ (void) autorelease
|
||
{
|
||
}
|
||
|
||
+ (void) release
|
||
{
|
||
}
|
||
|
||
+ (id) retain
|
||
{
|
||
return self;
|
||
}
|
||
|
||
+ (void) initialize
|
||
{
|
||
if (self == [GSDistantObjectPlaceHolder class])
|
||
{
|
||
distantObjectClass = [NSDistantObject class];
|
||
}
|
||
}
|
||
|
||
+ (id) initWithLocal: (id)anObject connection: (NSConnection*)aConnection
|
||
{
|
||
NSDistantObject *proxy;
|
||
|
||
NSAssert([aConnection isValid], NSInternalInconsistencyException);
|
||
|
||
/*
|
||
* If there already is a local proxy for this target/connection
|
||
* combination, don't create a new one, just return the old one.
|
||
*/
|
||
if ((proxy = [aConnection localForObject: anObject]))
|
||
{
|
||
return [proxy retain];
|
||
}
|
||
|
||
proxy = (NSDistantObject*)NSAllocateObject(distantObjectClass,
|
||
0, NSDefaultMallocZone());
|
||
return [proxy initWithLocal: anObject connection: aConnection];
|
||
}
|
||
|
||
+ (id) initWithTarget: (unsigned)target connection: (NSConnection*)aConnection
|
||
{
|
||
NSDistantObject *proxy;
|
||
|
||
NSAssert([aConnection isValid], NSInternalInconsistencyException);
|
||
|
||
/*
|
||
* If there already is a local proxy for this target/connection
|
||
* combination, don't create a new one, just return the old one.
|
||
*/
|
||
if ((proxy = [aConnection proxyForTarget: target]))
|
||
{
|
||
return [proxy retain];
|
||
}
|
||
|
||
proxy = (NSDistantObject*)NSAllocateObject(distantObjectClass,
|
||
0, NSDefaultMallocZone());
|
||
return [proxy initWithTarget: target connection: aConnection];
|
||
}
|
||
@end
|
||
|
||
@interface NSDistantObject (Debug)
|
||
+ (void) setDebug: (int)val;
|
||
@end
|
||
|
||
@implementation NSDistantObject (Debug)
|
||
+ (void) setDebug: (int)val
|
||
{
|
||
debug_proxy = val;
|
||
}
|
||
@end
|
||
|
||
@implementation NSDistantObject
|
||
|
||
/* This is the proxy tag; it indicates where the local object is,
|
||
and determines whether the reply port to the Connection-where-the-
|
||
proxy-is-local needs to encoded/decoded or not. */
|
||
enum
|
||
{
|
||
PROXY_LOCAL_FOR_RECEIVER = 0,
|
||
PROXY_LOCAL_FOR_SENDER,
|
||
PROXY_REMOTE_FOR_BOTH
|
||
};
|
||
|
||
+ (void) initialize
|
||
{
|
||
if (self == [NSDistantObject class])
|
||
{
|
||
placeHolder = [GSDistantObjectPlaceHolder class];
|
||
}
|
||
}
|
||
|
||
+ (id) allocWithZone: (NSZone*)z
|
||
{
|
||
return placeHolder;
|
||
}
|
||
|
||
+ (NSDistantObject*) proxyWithLocal: (id)anObject
|
||
connection: (NSConnection*)aConnection
|
||
{
|
||
return [[placeHolder initWithLocal: anObject
|
||
connection: aConnection] autorelease];
|
||
}
|
||
|
||
+ (NSDistantObject*) proxyWithTarget: (unsigned)anObject
|
||
connection: (NSConnection*)aConnection
|
||
{
|
||
return [[placeHolder initWithTarget: anObject
|
||
connection: aConnection] autorelease];
|
||
}
|
||
|
||
- (NSConnection*) connectionForProxy
|
||
{
|
||
return _connection;
|
||
}
|
||
|
||
- (void) dealloc
|
||
{
|
||
if (_object)
|
||
{
|
||
/*
|
||
* A proxy for local object retains it's target so that it
|
||
* will continue to exist as long as there is a remote
|
||
* application using it - so we release the object here.
|
||
*/
|
||
[_object release];
|
||
}
|
||
else
|
||
{
|
||
/*
|
||
* A proxy retains it's connection so that the connection will
|
||
* continue to exist as long as there is a somethig to use it.
|
||
* So we release our reference to the connection here.
|
||
*/
|
||
[_connection release];
|
||
}
|
||
[super dealloc];
|
||
}
|
||
|
||
- (void) encodeWithCoder: (NSCoder*)aRmc
|
||
{
|
||
unsigned proxy_target;
|
||
gsu8 proxy_tag;
|
||
NSConnection *encoder_connection;
|
||
|
||
if ([aRmc class] != [PortEncoder class])
|
||
[NSException raise: NSGenericException
|
||
format: @"NSDistantObject objects only encode with PortEncoder class"];
|
||
|
||
encoder_connection = [(NSPortCoder*)aRmc connection];
|
||
NSAssert(encoder_connection, NSInternalInconsistencyException);
|
||
if (![encoder_connection isValid])
|
||
[NSException
|
||
raise: NSGenericException
|
||
format: @"Trying to encode to an invalid Connection.\n"
|
||
@"You should request NSConnectionDidDieNotification's and\n"
|
||
@"release all references to the proxy's of invalid Connections."];
|
||
|
||
proxy_target = _handle;
|
||
|
||
if (encoder_connection == _connection)
|
||
{
|
||
if (_object)
|
||
{
|
||
/*
|
||
* This proxy is a local to us, remote to other side.
|
||
*/
|
||
proxy_tag = PROXY_LOCAL_FOR_SENDER;
|
||
|
||
if (debug_proxy)
|
||
NSLog(@"Sending a proxy, will be remote 0x%x connection 0x%x\n",
|
||
(unsigned)proxy_target,
|
||
(unsigned)_connection);
|
||
|
||
[aRmc encodeValueOfCType: @encode(typeof(proxy_tag))
|
||
at: &proxy_tag
|
||
withName: @"Proxy is local for sender"];
|
||
|
||
[aRmc encodeValueOfCType: @encode(typeof(proxy_target))
|
||
at: &proxy_target
|
||
withName: @"Proxy target"];
|
||
}
|
||
else
|
||
{
|
||
/*
|
||
* This proxy is a local object on the other side.
|
||
*/
|
||
proxy_tag = PROXY_LOCAL_FOR_RECEIVER;
|
||
|
||
if (debug_proxy)
|
||
NSLog(@"Sending a proxy, will be local 0x%x connection 0x%x\n",
|
||
(unsigned)proxy_target,
|
||
(unsigned)_connection);
|
||
|
||
[aRmc encodeValueOfCType: @encode(typeof(proxy_tag))
|
||
at: &proxy_tag
|
||
withName: @"Proxy is local for receiver"];
|
||
|
||
[aRmc encodeValueOfCType: @encode(typeof(proxy_target))
|
||
at: &proxy_target
|
||
withName: @"Proxy target"];
|
||
}
|
||
}
|
||
else
|
||
{
|
||
/*
|
||
* This proxy will still be remote on the other side
|
||
*/
|
||
NSPort *proxy_connection_out_port = [_connection sendPort];
|
||
|
||
NSAssert(proxy_connection_out_port, NSInternalInconsistencyException);
|
||
NSAssert([proxy_connection_out_port isValid], NSInternalInconsistencyException);
|
||
NSAssert(proxy_connection_out_port != [encoder_connection sendPort], NSInternalInconsistencyException);
|
||
|
||
proxy_tag = PROXY_REMOTE_FOR_BOTH;
|
||
|
||
if (debug_proxy)
|
||
NSLog(@"Sending triangle-connection proxy 0x%x "
|
||
@"proxy-conn 0x%x to-conn 0x%x\n",
|
||
(unsigned)_object,
|
||
(unsigned)_connection, (unsigned)encoder_connection);
|
||
|
||
/*
|
||
* It's remote here, so we need to tell other side where to form
|
||
* triangle connection to
|
||
*/
|
||
[aRmc encodeValueOfCType: @encode(typeof(proxy_tag))
|
||
at: &proxy_tag
|
||
withName: @"Proxy remote for both sender and receiver"];
|
||
|
||
[aRmc encodeValueOfCType: @encode(typeof(proxy_target))
|
||
at: &proxy_target
|
||
withName: @"Proxy target"];
|
||
|
||
[aRmc encodeBycopyObject: proxy_connection_out_port
|
||
withName: @"Proxy outPort"];
|
||
/*
|
||
* Make a note that we have passed this on to another process.
|
||
*/
|
||
_isVended = YES;
|
||
}
|
||
}
|
||
|
||
/*
|
||
* This method needs to be implemented to actually do anything.
|
||
*/
|
||
- (void) forwardInvocation: (NSInvocation*)anInvocation
|
||
{
|
||
[NSException raise: NSInvalidArgumentException
|
||
format: @"Not yet implemented '%s'", sel_get_name(_cmd)];
|
||
}
|
||
|
||
- (id) initWithCoder: (NSCoder*)aCoder
|
||
{
|
||
gsu8 proxy_tag;
|
||
unsigned target;
|
||
id decoder_connection;
|
||
|
||
if ([aCoder class] != [PortDecoder class])
|
||
{
|
||
[self release];
|
||
[NSException raise: NSGenericException
|
||
format: @"NSDistantObject objects only decode with "
|
||
@"PortDecoder class"];
|
||
}
|
||
|
||
decoder_connection = [(NSPortCoder*)aCoder connection];
|
||
NSAssert(decoder_connection, NSInternalInconsistencyException);
|
||
|
||
/* First get the tag, so we know what values need to be decoded. */
|
||
[aCoder decodeValueOfCType: @encode(typeof(proxy_tag))
|
||
at: &proxy_tag
|
||
withName: NULL];
|
||
|
||
switch (proxy_tag)
|
||
{
|
||
case PROXY_LOCAL_FOR_RECEIVER:
|
||
/*
|
||
* This was a proxy on the other side of the connection, but
|
||
* here it's local.
|
||
* Lookup the target handle to ensure that it exists here.
|
||
* Return a retained copy of the local target object.
|
||
*/
|
||
[aCoder decodeValueOfCType: @encode(typeof(target))
|
||
at: &target
|
||
withName: NULL];
|
||
|
||
if (debug_proxy)
|
||
NSLog(@"Receiving a proxy for local object 0x%x "
|
||
@"connection 0x%x\n", target, (unsigned)decoder_connection);
|
||
|
||
if (![[decoder_connection class] includesLocalTarget: target])
|
||
{
|
||
[self release];
|
||
[NSException raise: @"ProxyDecodedBadTarget"
|
||
format: @"No local object with given address"];
|
||
}
|
||
else
|
||
{
|
||
NSDistantObject *o;
|
||
|
||
o = [decoder_connection includesLocalTarget: target];
|
||
if (debug_proxy)
|
||
{
|
||
NSLog(@"Local object is 0x%x (0x%x)\n",
|
||
(unsigned)o, (unsigned)o ? o->_object : 0);
|
||
}
|
||
[self release];
|
||
return o ? [o->_object retain] : nil;
|
||
}
|
||
|
||
case PROXY_LOCAL_FOR_SENDER:
|
||
/*
|
||
* This was a local object on the other side of the connection,
|
||
* but here it's a proxy object. Get the target address, and
|
||
* send [NSDistantObject +proxyWithTarget:connection:]; this will
|
||
* return the proxy object we already created for this target, or
|
||
* create a new proxy object if necessary.
|
||
*/
|
||
[aCoder decodeValueOfCType: @encode(typeof(target))
|
||
at: &target
|
||
withName: NULL];
|
||
if (debug_proxy)
|
||
NSLog(@"Receiving a proxy, was local 0x%x connection 0x%x\n",
|
||
(unsigned)target, (unsigned)decoder_connection);
|
||
[self release];
|
||
return [[NSDistantObject proxyWithTarget: target
|
||
connection: decoder_connection] retain];
|
||
|
||
case PROXY_REMOTE_FOR_BOTH:
|
||
/*
|
||
* This was a proxy on the other side of the connection, and it
|
||
* will be a proxy on this side too; that is, the local version
|
||
* of this object is not on this host, not on the host the
|
||
* NSPortCoder is connected to, but on a *third* host.
|
||
* This is why I call this a "triangle connection". In addition
|
||
* to decoding the target, we decode the OutPort object that we
|
||
* will use to talk directly to this third host. We send
|
||
* [NSConnection +newForInPort:outPort:ancestorConnection:]; this
|
||
* will either return the connection already created for this
|
||
* inPort/outPort pair, or create a new connection if necessary.
|
||
*/
|
||
{
|
||
NSDistantObject *result;
|
||
NSConnection *proxy_connection;
|
||
NSPort *proxy_connection_out_port = nil;
|
||
|
||
[aCoder decodeValueOfCType: @encode(typeof(target))
|
||
at: &target
|
||
withName: NULL];
|
||
|
||
[aCoder decodeObjectAt: &proxy_connection_out_port
|
||
withName: NULL];
|
||
|
||
NSAssert(proxy_connection_out_port, NSInternalInconsistencyException);
|
||
/* xxx - if there already exists a connection for talking to the
|
||
* out port, we use that one rather than creating a new one from
|
||
* our listening port.
|
||
*
|
||
* First we try for a connection from our receive port,
|
||
* Then we try any connection to the send port
|
||
* Finally we resort to creating a new connection - we don't
|
||
* release the newly created connection - it will get released
|
||
* automatically when no proxies are left on it.
|
||
*/
|
||
proxy_connection = [[decoder_connection class]
|
||
connectionByInPort:
|
||
[decoder_connection receivePort]
|
||
outPort:
|
||
proxy_connection_out_port];
|
||
if (proxy_connection == nil)
|
||
proxy_connection = [[decoder_connection class]
|
||
connectionByOutPort:
|
||
proxy_connection_out_port];
|
||
if (proxy_connection == nil)
|
||
proxy_connection = [[decoder_connection class]
|
||
newForInPort: [decoder_connection receivePort]
|
||
outPort: proxy_connection_out_port
|
||
ancestorConnection: decoder_connection];
|
||
|
||
if (debug_proxy)
|
||
NSLog(@"Receiving a triangle-connection proxy 0x%x "
|
||
@"connection 0x%x\n", target, (unsigned)proxy_connection);
|
||
|
||
NSAssert(proxy_connection != decoder_connection, NSInternalInconsistencyException);
|
||
NSAssert([proxy_connection isValid], NSInternalInconsistencyException);
|
||
|
||
/*
|
||
* If we don't already have a proxy for the object on the
|
||
* remote system, we must tell the other end to retain its
|
||
* local object for our use.
|
||
*/
|
||
if ([proxy_connection includesProxyForTarget: target] == NO)
|
||
[proxy_connection retainTarget: target];
|
||
|
||
[self release];
|
||
result = [[NSDistantObject proxyWithTarget: target
|
||
connection: proxy_connection] retain];
|
||
return result;
|
||
}
|
||
|
||
default:
|
||
/* xxx This should be something different than NSGenericException. */
|
||
[self release];
|
||
[NSException raise: NSGenericException
|
||
format: @"Bad proxy tag"];
|
||
}
|
||
/* Not reached. */
|
||
return nil;
|
||
}
|
||
|
||
- (id) initWithLocal: (id)anObject connection: (NSConnection*)aConnection
|
||
{
|
||
NSDistantObject *new_proxy;
|
||
|
||
NSAssert([aConnection isValid], NSInternalInconsistencyException);
|
||
|
||
/*
|
||
* If there already is a local proxy for this target/connection
|
||
* combination, don't create a new one, just return the old one.
|
||
*/
|
||
if ((new_proxy = [aConnection localForObject: anObject]))
|
||
{
|
||
[self dealloc];
|
||
return [new_proxy retain];
|
||
}
|
||
|
||
_connection = aConnection;
|
||
|
||
/*
|
||
* We retain our target object so it can't disappear while a remote
|
||
* application wants to use it.
|
||
*/
|
||
_object = [anObject retain];
|
||
|
||
/*
|
||
* We register this object with the connection using it.
|
||
*/
|
||
[_connection addLocalObject: self];
|
||
|
||
if (debug_proxy)
|
||
NSLog(@"Created new local=0x%x object 0x%x connection 0x%x\n",
|
||
(unsigned)self, (unsigned)_object, (unsigned)_connection);
|
||
|
||
return self;
|
||
}
|
||
|
||
- (id) initWithTarget: (unsigned)target connection: (NSConnection*)aConnection
|
||
{
|
||
NSDistantObject *new_proxy;
|
||
|
||
NSAssert([aConnection isValid], NSInternalInconsistencyException);
|
||
|
||
/*
|
||
* If there already is a proxy for this target/connection combination,
|
||
* don't create a new one, just return the old one.
|
||
*/
|
||
if ((new_proxy = [aConnection proxyForTarget: target]))
|
||
{
|
||
[self dealloc];
|
||
return [new_proxy retain];
|
||
}
|
||
|
||
_object = nil;
|
||
_handle = target;
|
||
|
||
/*
|
||
* We retain our connection so it can't disappear while the app
|
||
* may want to use it.
|
||
*/
|
||
_connection = [aConnection retain];
|
||
|
||
/*
|
||
* We register this object with the connection using it.
|
||
*/
|
||
[_connection addProxy: self];
|
||
|
||
if (debug_proxy)
|
||
NSLog(@"Created new proxy=0x%x object 0x%x connection 0x%x\n",
|
||
(unsigned)self, (unsigned)_object, (unsigned)_connection);
|
||
|
||
return self;
|
||
}
|
||
|
||
- (NSMethodSignature*) methodSignatureForSelector: (SEL)aSelector
|
||
{
|
||
if (_object)
|
||
{
|
||
return [_object methodSignatureForSelector: aSelector];
|
||
}
|
||
else
|
||
{
|
||
if (_protocol)
|
||
{
|
||
const char *types = 0;
|
||
|
||
struct objc_method_description* mth;
|
||
|
||
mth = [_protocol descriptionForInstanceMethod: aSelector];
|
||
if (mth == 0)
|
||
{
|
||
mth = [_protocol descriptionForClassMethod: aSelector];
|
||
}
|
||
if (mth != 0)
|
||
{
|
||
types = mth->types;
|
||
}
|
||
if (types == 0)
|
||
{
|
||
return nil;
|
||
}
|
||
return [NSMethodSignature signatureWithObjCTypes: types];
|
||
}
|
||
else
|
||
{
|
||
arglist_t args;
|
||
|
||
/*
|
||
* No protocol - so try forwarding the message.
|
||
*/
|
||
args = __builtin_apply_args();
|
||
__builtin_return([self forward: _cmd : args]);
|
||
}
|
||
}
|
||
}
|
||
|
||
- (void) setProtocolForProxy: (Protocol*)aProtocol
|
||
{
|
||
_protocol = aProtocol;
|
||
}
|
||
|
||
- (void) release
|
||
{
|
||
if ([self retainCount] == 2)
|
||
{
|
||
if (_object == nil)
|
||
{
|
||
/*
|
||
* If the only thing retaining us after this release is our
|
||
* connection we must be removed from the connection.
|
||
* Bracket that removal with a retain and release to ensure
|
||
* that we don't have problems when the connection releases us.
|
||
*/
|
||
[super retain];
|
||
[_connection removeProxy: self];
|
||
[super release];
|
||
}
|
||
}
|
||
[super release];
|
||
}
|
||
|
||
@end
|
||
|
||
@implementation NSDistantObject(GNUstepExtensions)
|
||
|
||
+ newForRemoteTarget: (unsigned)target connection: (NSConnection*)conn
|
||
{
|
||
return [[NSDistantObject alloc] initWithTarget: target connection: conn];
|
||
}
|
||
|
||
- awakeAfterUsingCoder: aDecoder
|
||
{
|
||
return self;
|
||
}
|
||
|
||
static inline BOOL class_is_kind_of (Class self, Class aClassObject)
|
||
{
|
||
Class class;
|
||
|
||
for (class = self; class!=Nil; class = class_get_super_class(class))
|
||
if (class==aClassObject)
|
||
return YES;
|
||
return NO;
|
||
}
|
||
|
||
|
||
|
||
#if 0
|
||
+ newWithCoder: aRmc
|
||
{
|
||
gsu8 proxy_tag;
|
||
unsigned target;
|
||
id decoder_connection;
|
||
|
||
if ([aRmc class] != [PortDecoder class])
|
||
[NSException raise: NSGenericException
|
||
format: @"NSDistantObject objects only decode with PortDecoder class"];
|
||
|
||
decoder_connection = [aRmc connection];
|
||
NSAssert(decoder_connection, NSInternalInconsistencyException);
|
||
|
||
/* First get the tag, so we know what values need to be decoded. */
|
||
[aRmc decodeValueOfCType: @encode(typeof(proxy_tag))
|
||
at: &proxy_tag
|
||
withName: NULL];
|
||
|
||
switch (proxy_tag)
|
||
{
|
||
case PROXY_LOCAL_FOR_RECEIVER:
|
||
/*
|
||
* This was a proxy on the other side of the connection, but
|
||
* here it's local.
|
||
* Lookup the target handle to ensure that it exists here.
|
||
* Return a retained copy of the local target object.
|
||
*/
|
||
[aRmc decodeValueOfCType: @encode(typeof(target))
|
||
at: &target
|
||
withName: NULL];
|
||
|
||
if (debug_proxy)
|
||
NSLog(@"Receiving a proxy for local object 0x%x "
|
||
@"connection 0x%x\n", target, (unsigned)decoder_connection);
|
||
|
||
if (![[decoder_connection class] includesLocalTarget: target])
|
||
[NSException raise: @"ProxyDecodedBadTarget"
|
||
format: @"No local object with given address"];
|
||
else
|
||
{
|
||
NSDistantObject *o;
|
||
|
||
o = [decoder_connection includesLocalTarget: target];
|
||
if (debug_proxy)
|
||
{
|
||
NSLog(@"Local object is 0x%x (0x%x)\n",
|
||
(unsigned)o, (unsigned)o->_object);
|
||
}
|
||
[self release];
|
||
return [o->_object retain];
|
||
}
|
||
|
||
case PROXY_LOCAL_FOR_SENDER:
|
||
/*
|
||
* This was a local object on the other side of the connection,
|
||
* but here it's a proxy object. Get the target address, and
|
||
* send [NSDistantObject +proxyWithTarget:connection:]; this will
|
||
* return the proxy object we already created for this target, or
|
||
* create a new proxy object if necessary.
|
||
*/
|
||
[aRmc decodeValueOfCType: @encode(typeof(target))
|
||
at: &target
|
||
withName: NULL];
|
||
if (debug_proxy)
|
||
NSLog(@"Receiving a proxy, was local 0x%x connection 0x%x\n",
|
||
(unsigned)target, (unsigned)decoder_connection);
|
||
return [[NSDistantObject proxyWithTarget: target
|
||
connection: decoder_connection] retain];
|
||
|
||
case PROXY_REMOTE_FOR_BOTH:
|
||
/*
|
||
* This was a proxy on the other side of the connection, and it
|
||
* will be a proxy on this side too; that is, the local version
|
||
* of this object is not on this host, not on the host the
|
||
* NSPortCoder is connected to, but on a *third* host.
|
||
* This is why I call this a "triangle connection". In addition
|
||
* to decoding the target, we decode the OutPort object that we
|
||
* will use to talk directly to this third host. We send
|
||
* [NSConnection +newForInPort:outPort:ancestorConnection:]; this
|
||
* will either return the connection already created for this
|
||
* inPort/outPort pair, or create a new connection if necessary.
|
||
*/
|
||
{
|
||
NSDistantObject *result;
|
||
NSConnection *proxy_connection;
|
||
NSPort* proxy_connection_out_port = nil;
|
||
|
||
[aRmc decodeValueOfCType: @encode(typeof(target))
|
||
at: &target
|
||
withName: NULL];
|
||
|
||
[aRmc decodeObjectAt: &proxy_connection_out_port
|
||
withName: NULL];
|
||
|
||
NSAssert(proxy_connection_out_port, NSInternalInconsistencyException);
|
||
/* xxx - if there already exists a connection for talking to the
|
||
* out port, we use that one rather than creating a new one from
|
||
* our listening port.
|
||
*
|
||
* First we try for a connection from our receive port,
|
||
* Then we try any connection to the send port
|
||
* Finally we resort to creating a new connection - we don't
|
||
* release the newly created connection - it will get released
|
||
* automatically when no proxies are left on it.
|
||
*/
|
||
proxy_connection = [[decoder_connection class]
|
||
connectionByInPort:
|
||
[decoder_connection receivePort]
|
||
outPort:
|
||
proxy_connection_out_port];
|
||
if (proxy_connection == nil)
|
||
proxy_connection = [[decoder_connection class]
|
||
connectionByOutPort:
|
||
proxy_connection_out_port];
|
||
if (proxy_connection == nil)
|
||
proxy_connection = [[decoder_connection class]
|
||
newForInPort: [decoder_connection receivePort]
|
||
outPort: proxy_connection_out_port
|
||
ancestorConnection: decoder_connection];
|
||
|
||
if (debug_proxy)
|
||
NSLog(@"Receiving a triangle-connection proxy 0x%x "
|
||
@"connection 0x%x\n", target, (unsigned)proxy_connection);
|
||
|
||
NSAssert(proxy_connection != decoder_connection, NSInternalInconsistencyException);
|
||
NSAssert([proxy_connection isValid], NSInternalInconsistencyException);
|
||
|
||
/*
|
||
* If we don't already have a proxy for the object on the
|
||
* remote system, we must tell the other end to retain its
|
||
* local object for our use.
|
||
*/
|
||
if ([proxy_connection includesProxyForTarget: target] == NO)
|
||
[proxy_connection retainTarget: target];
|
||
|
||
result = [[NSDistantObject proxyWithTarget: target
|
||
connection: proxy_connection] retain];
|
||
return result;
|
||
}
|
||
|
||
default:
|
||
/* xxx This should be something different than NSGenericException. */
|
||
[NSException raise: NSGenericException
|
||
format: @"Bad proxy tag"];
|
||
}
|
||
/* Not reached. */
|
||
return nil;
|
||
}
|
||
#endif
|
||
|
||
- (const char *) selectorTypeForProxy: (SEL)selector
|
||
{
|
||
#if NeXT_runtime
|
||
{
|
||
elt e;
|
||
const char *t;
|
||
e = coll_hash_value_for_key(_method_types, selector);
|
||
t = e.char_ptr_u;
|
||
if (!t)
|
||
{
|
||
/* This isn't what we want, unless the remote machine has
|
||
the same architecture as us. */
|
||
t = [connection _typeForSelector:selector remoteTarget:target];
|
||
coll_hash_add(&_method_types, (void*)selector, t);
|
||
}
|
||
return t;
|
||
}
|
||
#else /* NeXT_runtime */
|
||
return sel_get_type (selector);
|
||
#endif
|
||
}
|
||
|
||
- forward: (SEL)aSel :(arglist_t)frame
|
||
{
|
||
if (debug_proxy)
|
||
NSLog(@"NSDistantObject forwarding %s\n", sel_get_name(aSel));
|
||
|
||
if (![_connection isValid])
|
||
[NSException
|
||
raise: NSGenericException
|
||
format: @"Trying to send message to an invalid Proxy.\n"
|
||
@"You should request NSConnectionDidDieNotification's and\n"
|
||
@"release all references to the proxy's of invalid Connections."];
|
||
|
||
return [_connection forwardForProxy: self
|
||
selector: aSel
|
||
argFrame: frame];
|
||
}
|
||
|
||
- classForCoder
|
||
{
|
||
return object_get_class (self);
|
||
}
|
||
|
||
- classForPortCoder
|
||
{
|
||
return object_get_class (self);
|
||
}
|
||
|
||
- replacementObjectForCoder:(NSCoder*)aCoder
|
||
{
|
||
return self;
|
||
}
|
||
|
||
- replacementObjectForPortCoder:(NSPortCoder*)aCoder
|
||
{
|
||
return self;
|
||
}
|
||
@end
|
||
|
||
|
||
@implementation NSObject (NSDistantObject)
|
||
- (const char *) selectorTypeForProxy: (SEL)selector
|
||
{
|
||
#if NeXT_runtime
|
||
{
|
||
Method m = class_get_instance_method(isa, selector);
|
||
if (m)
|
||
return m->method_types;
|
||
else
|
||
return NULL;
|
||
}
|
||
#else
|
||
return sel_get_type (selector);
|
||
#endif
|
||
}
|
||
|
||
@end
|
||
|
||
@implementation Protocol (DistributedObjectsCoding)
|
||
|
||
- (Class) classForPortCoder
|
||
{
|
||
return [self class];
|
||
}
|
||
|
||
- replacementObjectForPortCoder: (NSPortCoder*)aRmc;
|
||
{
|
||
if ([aRmc isBycopy])
|
||
return self;
|
||
else
|
||
return [NSDistantObject proxyWithLocal: self
|
||
connection: [aRmc connection]];
|
||
}
|
||
|
||
@end
|
||
|