libs-base/Source/NSDistantObject.m
Sheldon Gill 00f6762e2d Merged GSVersionMacros.h change from trunk/HEAD
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
2006-10-21 09:49:18 +00:00

1010 lines
28 KiB
Objective-C
Raw Permalink Blame History

This file contains invisible Unicode characters

This file contains invisible Unicode characters that are indistinguishable to humans but may be processed differently by a computer. If you think that this is intentional, you can safely ignore this warning. Use the Escape button to reveal them.

/** 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 &lt;MyProtocol&gt;
* ...
* @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