mirror of
https://github.com/gnustep/libs-base.git
synced 2025-04-20 23:11:59 +00:00
Corrected FSF location layout. All very cosmetic git-svn-id: svn+ssh://svn.gna.org/svn/gnustep/libs/base/branches/mswin-ng@23929 72102866-910b-0410-8b05-ffd578937521
1010 lines
28 KiB
Objective-C
1010 lines
28 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., 51 Franklin Street, Fifth Floor,
|
||
Boston, MA 02111 USA.
|
||
|
||
<title>NSDistantObject class reference</title>
|
||
$Date$ $Revision$
|
||
*/
|
||
|
||
#include "config.h"
|
||
#include "GNUstepBase/preface.h"
|
||
#include "GNUstepBase/DistributedObjects.h"
|
||
#include "GNUstepBase/GSObjCRuntime.h"
|
||
#include "Foundation/NSDebug.h"
|
||
#include "Foundation/NSLock.h"
|
||
#include "Foundation/NSPort.h"
|
||
#include "Foundation/NSMethodSignature.h"
|
||
#include "Foundation/NSException.h"
|
||
#include "Foundation/NSObjCRuntime.h"
|
||
#include "Foundation/NSInvocation.h"
|
||
#include <objc/Protocol.h>
|
||
|
||
|
||
@interface NSDistantObject(GNUstepExtensions) <GCFinalization>
|
||
- (Class) classForPortCoder;
|
||
- (const char *) selectorTypeForProxy: (SEL)selector;
|
||
- (id) forward: (SEL)aSel :(arglist_t)frame;
|
||
- (void) gcFinalize;
|
||
@end
|
||
|
||
#define DO_FORWARD_INVOCATION(_SELX, _ARG1) ({ \
|
||
sig = [self methodSignatureForSelector: @selector(_SELX)]; \
|
||
if (sig != nil) \
|
||
{ \
|
||
inv = [NSInvocation invocationWithMethodSignature: sig]; \
|
||
[inv setSelector: @selector(_SELX)]; \
|
||
[inv setTarget: self]; \
|
||
[inv setArgument: (void*)&_ARG1 atIndex: 2]; \
|
||
[self forwardInvocation: inv]; \
|
||
[inv getReturnValue: &m]; \
|
||
} \
|
||
else \
|
||
{ \
|
||
NSWarnLog(@"DO_FORWARD_INVOCATION failed, got nil signature for '%@'.", \
|
||
NSStringFromSelector(@selector(_SELX))); \
|
||
}})
|
||
|
||
|
||
static int debug_proxy = 0;
|
||
static Class placeHolder = 0;
|
||
static Class distantObjectClass = 0;
|
||
|
||
typedef struct {
|
||
@defs(NSDistantObject)
|
||
} NSDO;
|
||
|
||
@interface Object (NSConformsToProtocolNamed)
|
||
- (BOOL) _conformsToProtocolNamed: (char*)aName;
|
||
@end
|
||
@interface NSObject (NSConformsToProtocolNamed)
|
||
- (BOOL) _conformsToProtocolNamed: (char*)aName;
|
||
@end
|
||
/*
|
||
* Evil hack ... if a remote system wants to know if we conform
|
||
* to a protocol we pretend we have a local protocol with the same name.
|
||
*/
|
||
typedef struct {
|
||
@defs(Protocol)
|
||
} Proto;
|
||
@implementation Object (NSConformsToProtocolNamed)
|
||
- (BOOL) _conformsToProtocolNamed: (char*)aName
|
||
{
|
||
Proto p;
|
||
p.protocol_name = (char*)aName;
|
||
return [self conformsTo: (Protocol*)&p];
|
||
}
|
||
@end
|
||
@implementation NSObject (NSConformsToProtocolNamed)
|
||
- (BOOL) _conformsToProtocolNamed: (char*)aName
|
||
{
|
||
Proto p;
|
||
p.protocol_name = (char*)aName;
|
||
return [self conformsToProtocol: (Protocol*)&p];
|
||
}
|
||
@end
|
||
|
||
@interface NSConnection (DistantObjectHacks)
|
||
- (void) acquireProxyForTarget: (unsigned)target;
|
||
- (NSDistantObject*) retainOrAddLocal: (NSDistantObject*)aProxy
|
||
forObject: (id)anObject;
|
||
- (NSDistantObject*) retainOrAddProxy: (NSDistantObject*)aProxy
|
||
forTarget: (unsigned)aTarget;
|
||
- (void) removeProxy: (id)obj;
|
||
- (void) vendLocal: (NSDistantObject*)aProxy;
|
||
@end
|
||
|
||
/* 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 proxyLocation
|
||
{
|
||
PROXY_LOCAL_FOR_RECEIVER = 0,
|
||
PROXY_LOCAL_FOR_SENDER,
|
||
PROXY_REMOTE_FOR_BOTH
|
||
};
|
||
|
||
|
||
|
||
/*
|
||
* 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) initWithCoder: (NSCoder*)aCoder;
|
||
+ (id) initWithLocal: (id)anObject connection: (NSConnection*)aConnection;
|
||
+ (id) initWithTarget: (unsigned)target connection: (NSConnection*)aConnection;
|
||
+ (void) autorelease;
|
||
+ (void) release;
|
||
+ (id) retain;
|
||
+ (BOOL) respondsToSelector: (SEL)sel;
|
||
@end
|
||
|
||
@implementation GSDistantObjectPlaceHolder
|
||
|
||
+ (void) autorelease
|
||
{
|
||
}
|
||
|
||
+ (void) release
|
||
{
|
||
}
|
||
|
||
+ (id) retain
|
||
{
|
||
return self;
|
||
}
|
||
|
||
+ (void) initialize
|
||
{
|
||
if (self == GSClassFromName("GSDistantObjectPlaceHolder"))
|
||
{
|
||
distantObjectClass = [NSDistantObject class];
|
||
}
|
||
}
|
||
|
||
+ (BOOL) respondsToSelector: (SEL)sel
|
||
{
|
||
return GSGetMethod(self, sel, NO, YES) != (GSMethod)0;
|
||
}
|
||
|
||
+ (id) initWithCoder: (NSCoder*)aCoder
|
||
{
|
||
uint8_t proxy_tag;
|
||
unsigned target;
|
||
id decoder_connection;
|
||
NSDistantObject *o;
|
||
|
||
/*
|
||
if ([aCoder isKindOfClass: [NSPortCoder class]] == NO)
|
||
{
|
||
[NSException raise: NSGenericException
|
||
format: @"NSDistantObject objects only decode with "
|
||
@"NSPortCoder class"];
|
||
}
|
||
*/
|
||
|
||
decoder_connection = [(NSPortCoder*)aCoder connection];
|
||
NSAssert(decoder_connection, NSInternalInconsistencyException);
|
||
|
||
/* First get the tag, so we know what values need to be decoded. */
|
||
[aCoder decodeValueOfObjCType: @encode(typeof(proxy_tag))
|
||
at: &proxy_tag];
|
||
|
||
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 decodeValueOfObjCType: @encode(typeof(target))
|
||
at: &target];
|
||
|
||
if (debug_proxy)
|
||
NSLog(@"Receiving a proxy for local object 0x%x "
|
||
@"connection 0x%x\n", target, (uintptr_t)decoder_connection);
|
||
|
||
o = [decoder_connection locateLocalTarget: target];
|
||
if (o == nil)
|
||
{
|
||
[NSException raise: @"ProxyDecodedBadTarget"
|
||
format: @"No local object with given target (0x%x)",
|
||
target];
|
||
}
|
||
else
|
||
{
|
||
if (debug_proxy)
|
||
{
|
||
NSLog(@"Local object is 0x%x (0x%x)\n",
|
||
(uintptr_t)o, (uintptr_t)o ? ((NSDO*)o)->_object : 0);
|
||
}
|
||
return RETAIN(((NSDO*)o)->_object);
|
||
}
|
||
|
||
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 decodeValueOfObjCType: @encode(typeof(target))
|
||
at: &target];
|
||
if (debug_proxy)
|
||
NSLog(@"Receiving a proxy, was local 0x%x connection 0x%x\n",
|
||
target, (uintptr_t)decoder_connection);
|
||
o = [self initWithTarget: target
|
||
connection: decoder_connection];
|
||
return o;
|
||
|
||
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 NSPort object that we
|
||
* will use to talk directly to this third host. We send
|
||
* [NSConnection +connectionWithReceivePort:sendPort:]; this
|
||
* will either return the connection already created for this
|
||
* inPort/outPort pair, or create a new connection if necessary.
|
||
*/
|
||
{
|
||
NSConnection *proxy_connection;
|
||
NSPort *proxy_connection_out_port = nil;
|
||
unsigned intermediary;
|
||
|
||
/*
|
||
* There is an object on the intermediary host that is keeping
|
||
* that hosts proxy for the original object retained, thus
|
||
* ensuring that the original is not released. We create a
|
||
* proxy for that intermediate proxy. When we release this
|
||
* proxy, the intermediary will be free to release it's proxy
|
||
* and the original can then be released. Of course, by that
|
||
* time we will have obtained our own proxy for the original
|
||
* object ...
|
||
*/
|
||
[aCoder decodeValueOfObjCType: @encode(typeof(intermediary))
|
||
at: &intermediary];
|
||
AUTORELEASE([self initWithTarget: intermediary
|
||
connection: decoder_connection]);
|
||
|
||
/*
|
||
* Now we get the target number and port for the orignal object
|
||
* and (if necessary) get the originating process to retain the
|
||
* object for us.
|
||
*/
|
||
[aCoder decodeValueOfObjCType: @encode(typeof(target))
|
||
at: &target];
|
||
|
||
[aCoder decodeValueOfObjCType: @encode(id)
|
||
at: &proxy_connection_out_port];
|
||
|
||
NSAssert(proxy_connection_out_port, NSInternalInconsistencyException);
|
||
/*
|
||
# 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]
|
||
connectionWithReceivePort: [decoder_connection receivePort]
|
||
sendPort: proxy_connection_out_port];
|
||
|
||
if (debug_proxy)
|
||
NSLog(@"Receiving a triangle-connection proxy 0x%x "
|
||
@"connection 0x%x\n", target, (uintptr_t)proxy_connection);
|
||
|
||
NSAssert(proxy_connection != decoder_connection,
|
||
NSInternalInconsistencyException);
|
||
NSAssert([proxy_connection isValid],
|
||
NSInternalInconsistencyException);
|
||
|
||
/*
|
||
* We may not already have a proxy for the object on the
|
||
* remote system, we must tell the connection to make sure
|
||
* the other end knows we are creating one.
|
||
*/
|
||
[proxy_connection acquireProxyForTarget: target];
|
||
|
||
/*
|
||
* Finally - we get a proxy via a direct connection to the
|
||
* originating server. We have also created a proxy to an
|
||
* intermediate object - but this proxy has not been retained
|
||
* and will therefore go away when the current autorelease
|
||
* pool is destroyed.
|
||
*/
|
||
o = [self initWithTarget: target
|
||
connection: proxy_connection];
|
||
return o;
|
||
}
|
||
|
||
default:
|
||
/* xxx This should be something different than NSGenericException. */
|
||
[NSException raise: NSGenericException
|
||
format: @"Bad proxy tag"];
|
||
}
|
||
/* Not reached. */
|
||
return nil;
|
||
}
|
||
|
||
+ (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.
|
||
*/
|
||
proxy = [aConnection retainOrAddLocal: nil forObject: anObject];
|
||
if (proxy == nil)
|
||
{
|
||
proxy = (NSDistantObject*)NSAllocateObject(distantObjectClass,
|
||
0, NSDefaultMallocZone());
|
||
proxy = [proxy initWithLocal: anObject connection: aConnection];
|
||
}
|
||
return proxy;
|
||
}
|
||
|
||
+ (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.
|
||
*/
|
||
proxy = [aConnection retainOrAddProxy: nil forTarget: target];
|
||
if (proxy == nil)
|
||
{
|
||
proxy = (NSDistantObject*)NSAllocateObject(distantObjectClass,
|
||
0, NSDefaultMallocZone());
|
||
proxy = [proxy initWithTarget: target connection: aConnection];
|
||
}
|
||
return proxy;
|
||
}
|
||
@end
|
||
|
||
@interface NSDistantObject (Debug)
|
||
+ (void) setDebug: (int)val;
|
||
@end
|
||
|
||
@implementation NSDistantObject (Debug)
|
||
+ (void) setDebug: (int)val
|
||
{
|
||
debug_proxy = val;
|
||
}
|
||
@end
|
||
|
||
/**
|
||
* Instances of this class act as proxies to remote objects using
|
||
* the Distributed Objects system. They also hold references to
|
||
* local objects which are vended to remote processes.
|
||
*/
|
||
@implementation NSDistantObject
|
||
|
||
+ (void) initialize
|
||
{
|
||
if (self == [NSDistantObject class])
|
||
{
|
||
placeHolder = GSClassFromName("GSDistantObjectPlaceHolder");
|
||
}
|
||
}
|
||
|
||
+ (id) allocWithZone: (NSZone*)z
|
||
{
|
||
return placeHolder;
|
||
}
|
||
|
||
/**
|
||
* Creates and returns a proxy associated with aConnection
|
||
* which will hold a reference to the local object anObject.
|
||
*/
|
||
+ (NSDistantObject*) proxyWithLocal: (id)anObject
|
||
connection: (NSConnection*)aConnection
|
||
{
|
||
return AUTORELEASE([placeHolder initWithLocal: anObject
|
||
connection: aConnection]);
|
||
}
|
||
|
||
/**
|
||
* Creates and returns a proxy associated with aConnection
|
||
* which will provide a link to a remote object whose reference
|
||
* locally is anObject.
|
||
*/
|
||
+ (NSDistantObject*) proxyWithTarget: (unsigned)anObject
|
||
connection: (NSConnection*)aConnection
|
||
{
|
||
return AUTORELEASE([placeHolder initWithTarget: anObject
|
||
connection: aConnection]);
|
||
}
|
||
|
||
/**
|
||
* Returns the [NSConnection] instance with which the receiver is
|
||
* associated.
|
||
*/
|
||
- (NSConnection*) connectionForProxy
|
||
{
|
||
return _connection;
|
||
}
|
||
|
||
- (void) dealloc
|
||
{
|
||
[self gcFinalize];
|
||
[super dealloc];
|
||
}
|
||
|
||
- (void) encodeWithCoder: (NSCoder*)aRmc
|
||
{
|
||
unsigned proxy_target;
|
||
uint8_t proxy_tag;
|
||
NSConnection *encoder_connection;
|
||
|
||
/*
|
||
if ([aRmc isKindOfClass: [NSPortCoder class]] == NO)
|
||
{
|
||
[NSException raise: NSGenericException
|
||
format: @"NSDistantObject objects only "
|
||
@"encode with NSPortCoder 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",
|
||
proxy_target, (uintptr_t)_connection);
|
||
|
||
[aRmc encodeValueOfObjCType: @encode(typeof(proxy_tag))
|
||
at: &proxy_tag];
|
||
|
||
[aRmc encodeValueOfObjCType: @encode(typeof(proxy_target))
|
||
at: &proxy_target];
|
||
/*
|
||
* Tell connection this object is being vended.
|
||
*/
|
||
[_connection vendLocal: self];
|
||
}
|
||
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",
|
||
proxy_target, (uintptr_t)_connection);
|
||
|
||
[aRmc encodeValueOfObjCType: @encode(typeof(proxy_tag))
|
||
at: &proxy_tag];
|
||
|
||
[aRmc encodeValueOfObjCType: @encode(typeof(proxy_target))
|
||
at: &proxy_target];
|
||
}
|
||
}
|
||
else
|
||
{
|
||
/*
|
||
* This proxy will still be remote on the other side
|
||
*/
|
||
NSPort *proxy_connection_out_port = [_connection sendPort];
|
||
NSDistantObject *localProxy;
|
||
|
||
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;
|
||
|
||
/*
|
||
* Get a proxy to refer to self - we send this to the other
|
||
* side so we will be retained until the other side has
|
||
* obtained a proxy to the original object via a connection
|
||
* to the original vendor.
|
||
*/
|
||
localProxy = [NSDistantObject proxyWithLocal: self
|
||
connection: encoder_connection];
|
||
|
||
if (debug_proxy)
|
||
NSLog(@"Sending triangle-connection proxy 0x%x "
|
||
@"proxy-conn 0x%x to-proxy 0x%x to-conn 0x%x\n",
|
||
localProxy->_handle, (uintptr_t)localProxy->_connection,
|
||
proxy_target, (uintptr_t)_connection);
|
||
|
||
/*
|
||
* It's remote here, so we need to tell other side where to form
|
||
* triangle connection to
|
||
*/
|
||
[aRmc encodeValueOfObjCType: @encode(typeof(proxy_tag))
|
||
at: &proxy_tag];
|
||
|
||
[aRmc encodeValueOfObjCType: @encode(typeof(localProxy->_handle))
|
||
at: &localProxy->_handle];
|
||
|
||
[aRmc encodeValueOfObjCType: @encode(typeof(proxy_target))
|
||
at: &proxy_target];
|
||
|
||
[aRmc encodeBycopyObject: proxy_connection_out_port];
|
||
|
||
/*
|
||
* Tell connection that localProxy is being vended.
|
||
*/
|
||
[encoder_connection vendLocal: localProxy];
|
||
}
|
||
}
|
||
|
||
/*
|
||
* This method needs to be implemented to actually do anything.
|
||
*/
|
||
- (void) forwardInvocation: (NSInvocation*)anInvocation
|
||
{
|
||
if (debug_proxy)
|
||
NSLog(@"NSDistantObject forwardInvocation: %@\n", anInvocation);
|
||
|
||
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."];
|
||
|
||
[_connection forwardInvocation: anInvocation forProxy: self];
|
||
}
|
||
|
||
- (id) initWithCoder: (NSCoder*)aCoder
|
||
{
|
||
DESTROY(self);
|
||
[NSException raise: NSGenericException
|
||
format: @"NSDistantObject decodes from placeholder"];
|
||
return nil;
|
||
}
|
||
|
||
/**
|
||
* Initialises and returns a proxy associated with aConnection
|
||
* which will hold a reference to the local object anObject.
|
||
*/
|
||
- (id) initWithLocal: (id)anObject connection: (NSConnection*)aConnection
|
||
{
|
||
NSAssert([aConnection isValid], NSInternalInconsistencyException);
|
||
|
||
_object = RETAIN(anObject);
|
||
_handle = 0;
|
||
_connection = RETAIN(aConnection);
|
||
self = [_connection retainOrAddLocal: self forObject: anObject];
|
||
|
||
if (debug_proxy)
|
||
NSLog(@"Created new local=0x%x object 0x%x target 0x%x connection 0x%x\n",
|
||
(uintptr_t)self, (uintptr_t)_object, _handle, (uintptr_t)_connection);
|
||
|
||
return self;
|
||
}
|
||
|
||
/**
|
||
* Initialises and returns a proxy associated with aConnection
|
||
* which will provide a link to a remote object whose reference
|
||
* locally is target.
|
||
*/
|
||
- (id) initWithTarget: (unsigned)target connection: (NSConnection*)aConnection
|
||
{
|
||
NSAssert([aConnection isValid], NSInternalInconsistencyException);
|
||
|
||
_object = nil;
|
||
_handle = target;
|
||
_connection = RETAIN(aConnection);
|
||
|
||
/*
|
||
* We register this object with the connection using it.
|
||
* Conceivably this could result in self being changed.
|
||
*/
|
||
self = [_connection retainOrAddProxy: self forTarget: target];
|
||
|
||
if (debug_proxy)
|
||
NSLog(@"Created new proxy=0x%x target 0x%x connection 0x%x\n",
|
||
(uintptr_t)self, _handle, (uintptr_t)_connection);
|
||
|
||
return self;
|
||
}
|
||
|
||
/**
|
||
* <p>Returns the method signature describing the arguments and return
|
||
* types of the method in the object referred to by the receiver
|
||
* which implements the aSelector message.
|
||
* </p>
|
||
* <p>This method may need to refer to another process (causing relatively
|
||
* slow network communication) and approximately double the time taken for
|
||
* sending a distributed objects message, so you are advised to use the
|
||
* -setProtocolForProxy: method to avoid this occurring.
|
||
* </p>
|
||
*/
|
||
- (NSMethodSignature*) methodSignatureForSelector: (SEL)aSelector
|
||
{
|
||
if (_object != nil)
|
||
{
|
||
return [_object methodSignatureForSelector: aSelector];
|
||
}
|
||
else
|
||
{
|
||
/*
|
||
* Evil hack to prevent recursion - if we are asking a remote
|
||
* object for a method signature, we can't ask it for the
|
||
* signature of methodSignatureForSelector:, so we hack in
|
||
* the signature required manually :-(
|
||
*/
|
||
if (sel_eq(aSelector, _cmd))
|
||
{
|
||
static NSMethodSignature *sig = nil;
|
||
|
||
if (sig == nil)
|
||
{
|
||
sig = [NSMethodSignature signatureWithObjCTypes: "@@::"];
|
||
RETAIN(sig);
|
||
}
|
||
return sig;
|
||
}
|
||
/*
|
||
* Simlarly, when we fetch a method signature from the remote end,
|
||
* we get a proxy, and when we build a local signature we need to
|
||
* ask the proxy for its types ... and must avoid recursion again.
|
||
*/
|
||
if (sel_eq(aSelector, @selector(methodType)))
|
||
{
|
||
static NSMethodSignature *sig = nil;
|
||
|
||
if (sig == nil)
|
||
{
|
||
sig = [NSMethodSignature signatureWithObjCTypes: "r*@:"];
|
||
RETAIN(sig);
|
||
}
|
||
return sig;
|
||
}
|
||
|
||
if (_protocol != nil)
|
||
{
|
||
const char *types = 0;
|
||
|
||
struct objc_method_description* mth;
|
||
|
||
/* Older gcc versions may not initialise Protocol objects properly
|
||
* so we have an evil hack which checks for a known bad value of
|
||
* the class pointer, and uses an internal function
|
||
* (implemented in NSObject.m) to examine the protocol contents
|
||
* without sending any ObjectiveC message to it.
|
||
*/
|
||
if ((uintptr_t)GSObjCClass(_protocol) == 0x2)
|
||
{
|
||
extern struct objc_method_description*
|
||
GSDescriptionForInstanceMethod();
|
||
mth = GSDescriptionForInstanceMethod(_protocol, aSelector);
|
||
}
|
||
else
|
||
{
|
||
mth = [_protocol descriptionForInstanceMethod: aSelector];
|
||
}
|
||
if (mth == 0)
|
||
{
|
||
if ((uintptr_t)GSObjCClass(_protocol) == 0x2)
|
||
{
|
||
extern struct objc_method_description*
|
||
GSDescriptionForClassMethod();
|
||
mth = GSDescriptionForClassMethod(_protocol, aSelector);
|
||
}
|
||
else
|
||
{
|
||
mth = [_protocol descriptionForClassMethod: aSelector];
|
||
}
|
||
}
|
||
if (mth != 0)
|
||
{
|
||
types = mth->types;
|
||
}
|
||
if (types)
|
||
return [NSMethodSignature signatureWithObjCTypes: types];
|
||
}
|
||
|
||
{
|
||
id m = nil;
|
||
#if defined(USE_FFCALL) || defined(USE_LIBFFI)
|
||
id inv;
|
||
id sig;
|
||
|
||
DO_FORWARD_INVOCATION(methodSignatureForSelector:, aSelector);
|
||
#else
|
||
arglist_t args;
|
||
void *retframe;
|
||
|
||
id retframe_id (void *rframe)
|
||
{
|
||
__builtin_return (rframe);
|
||
}
|
||
|
||
/*
|
||
* No protocol - so try forwarding the message.
|
||
*/
|
||
args = __builtin_apply_args();
|
||
retframe = [self forward: _cmd : args];
|
||
m = retframe_id(retframe);
|
||
#endif
|
||
if ([m isProxy] == YES)
|
||
{
|
||
const char *types = [m methodType];
|
||
|
||
m = [NSMethodSignature signatureWithObjCTypes: types];
|
||
}
|
||
return m;
|
||
}
|
||
}
|
||
}
|
||
|
||
/**
|
||
* <p>A key method for Distributed Objects performance. This sets the
|
||
* a protocol that the distant object referred to by the proxy should
|
||
* conform to. When messages in that protocol are sent to the proxy,
|
||
* the proxy knows that it does not need to ask the remote object for
|
||
* the method signature in order to send the message to it, but can
|
||
* send the message straight away based on the local method signature
|
||
* information obtained from the protocol.
|
||
* </p>
|
||
* <example>
|
||
* if ([anObj isProxy] == YES)
|
||
* {
|
||
* [anObj setProtocolForProxy: @protocol(MyProtocol)];
|
||
* }
|
||
* </example>
|
||
* <p>It is <em>highly recommended</em> that you make use of this facility,
|
||
* but you must beware that versions of the compiler prior to 3.3 suffer a
|
||
* serious bug with respect to the @protocol directive. If the protocol
|
||
* referred to is not declared and implemented in the file where @protocol
|
||
* is used to refer to the protocol by name, a runtime error will occur
|
||
* when you try to use it.
|
||
* </p>
|
||
* <p>Beware, if you don't use this method to set the protocol, the system
|
||
* might well ask the remote process for method signature information, and
|
||
* the remote process might get it <em>wrong</em>. This is because the
|
||
* class of the remote object needs to have been declared to conform to the
|
||
* protocol in order for it to know about any protocol qualifiers (the
|
||
* keywords <code>bycopy, byref, in, out, inout,</code> and
|
||
* <code>oneway</code>). If the author of the server process forgot to do
|
||
* this, the type information returned from that process may not be what
|
||
* you are expecting.
|
||
* </p>
|
||
* The class of the server object should be declared like this ...
|
||
* <example>
|
||
* @interface MyServerClass : NSObject <MyProtocol>
|
||
* ...
|
||
* @end
|
||
* </example>
|
||
*/
|
||
- (void) setProtocolForProxy: (Protocol*)aProtocol
|
||
{
|
||
_protocol = aProtocol;
|
||
}
|
||
|
||
@end
|
||
|
||
/**
|
||
* Adds some backwards-compatibility and other methods.
|
||
*/
|
||
@implementation NSDistantObject(GNUstepExtensions)
|
||
|
||
/**
|
||
* Used by the garbage collection system to tidy up when a proxy is destroyed.
|
||
*/
|
||
- (void) gcFinalize
|
||
{
|
||
if (_connection)
|
||
{
|
||
if (debug_proxy > 3)
|
||
NSLog(@"retain count for connection (0x%x) is now %u\n",
|
||
(uintptr_t)_connection, [_connection retainCount]);
|
||
/*
|
||
* A proxy for local object retains its target - so we release it.
|
||
* For a local object the connection also retains this proxy, so we
|
||
* can't be deallocated unless we are already removed from the
|
||
* connection, and there is no need to remove self from connection.
|
||
*
|
||
* A proxy has a nil local object, and retains it's connection so
|
||
* that the connection will continue to exist as long as there is
|
||
* a something to use it.
|
||
* So we release our reference to the connection here just as soon
|
||
* as we have removed ourself from the connection.
|
||
*/
|
||
if (_object == nil)
|
||
[_connection removeProxy: self];
|
||
else
|
||
DESTROY(_object);
|
||
RELEASE(_connection);
|
||
}
|
||
}
|
||
|
||
static inline BOOL class_is_kind_of (Class self, Class aClassObject)
|
||
{
|
||
Class class;
|
||
|
||
for (class = self; class!=Nil; class = GSObjCSuper(class))
|
||
if (class==aClassObject)
|
||
return YES;
|
||
return NO;
|
||
}
|
||
|
||
|
||
|
||
/**
|
||
* For backward compatibility ... do not use this method.<br />
|
||
* Returns the type information ... the modern way of doing this is
|
||
* with the -methodSignatureForSelector: method.
|
||
*/
|
||
- (const char *) selectorTypeForProxy: (SEL)selector
|
||
{
|
||
#if NeXT_RUNTIME
|
||
/* This isn't what we want, unless the remote machine has
|
||
the same architecture as us. */
|
||
const char *t;
|
||
t = [_connection typeForSelector: selector remoteTarget: _handle];
|
||
return t;
|
||
#else /* NeXT_runtime */
|
||
return sel_get_type (selector);
|
||
#endif
|
||
}
|
||
|
||
/**
|
||
* For backward compatibility ... do not use this method.<br />
|
||
* Handle old fashioned forwarding to the proxy.
|
||
*/
|
||
- (id) forward: (SEL)aSel :(arglist_t)frame
|
||
{
|
||
if (debug_proxy)
|
||
NSLog(@"NSDistantObject forwarding %s\n", GSNameFromSelector(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];
|
||
}
|
||
|
||
- (Class) classForCoder
|
||
{
|
||
return object_get_class (self);
|
||
}
|
||
|
||
/**
|
||
* Returns the class of the receiver.
|
||
*/
|
||
- (Class) classForPortCoder
|
||
{
|
||
return object_get_class (self);
|
||
}
|
||
|
||
/**
|
||
* If a protocol has been set for the receiver, this method tests to
|
||
* see that the set protocol conforms to aProtocol. Otherwise, the
|
||
* remote object is checked to see whether it conforms to aProtocol.
|
||
*/
|
||
- (BOOL) conformsToProtocol: (Protocol*)aProtocol
|
||
{
|
||
if (_protocol != nil)
|
||
{
|
||
return [_protocol conformsTo: aProtocol];
|
||
}
|
||
else
|
||
{
|
||
return [(id)self _conformsToProtocolNamed: (char*)[aProtocol name]];
|
||
}
|
||
}
|
||
|
||
- (BOOL) respondsToSelector: (SEL)aSelector
|
||
{
|
||
#if defined(USE_FFCALL) || defined(USE_LIBFFI)
|
||
BOOL m = NO;
|
||
id inv, sig;
|
||
DO_FORWARD_INVOCATION(respondsToSelector:, aSelector);
|
||
return m;
|
||
#else
|
||
arglist_t args;
|
||
void *retframe;
|
||
|
||
BOOL retframe_bool (void *rframe)
|
||
{
|
||
__builtin_return (rframe);
|
||
}
|
||
|
||
/*
|
||
* Try forwarding the message.
|
||
*/
|
||
args = __builtin_apply_args();
|
||
retframe = [self forward: _cmd : args];
|
||
return retframe_bool(retframe);
|
||
#endif
|
||
}
|
||
|
||
- (id) replacementObjectForCoder: (NSCoder*)aCoder
|
||
{
|
||
return self;
|
||
}
|
||
|
||
- (id) replacementObjectForPortCoder: (NSPortCoder*)aCoder
|
||
{
|
||
return self;
|
||
}
|
||
@end
|
||
|
||
|
||
@implementation NSObject (NSDistantObject)
|
||
- (const char *) selectorTypeForProxy: (SEL)selector
|
||
{
|
||
#if NeXT_runtime
|
||
{
|
||
Method m = GSGetInstanceMethod(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];
|
||
}
|
||
|
||
- (id) replacementObjectForPortCoder: (NSPortCoder*)aRmc;
|
||
{
|
||
if ([aRmc isBycopy])
|
||
return self;
|
||
else
|
||
return [NSDistantObject proxyWithLocal: self
|
||
connection: [aRmc connection]];
|
||
}
|
||
|
||
@end
|
||
|