Widening.

git-svn-id: svn+ssh://src.earth.threerings.net/narya/trunk@4684 542714f4-19e9-0310-aa3c-eee0fc999fb1
This commit is contained in:
Michael Bayne
2007-05-04 22:02:03 +00:00
parent 63c5449b00
commit 3036bcb70d
@@ -36,8 +36,8 @@ import com.threerings.presents.dobj.DObjectManager;
import com.threerings.presents.dobj.InvocationResponseEvent; import com.threerings.presents.dobj.InvocationResponseEvent;
/** /**
* Provides a base from which all invocation service marshallers extend. * Provides a base from which all invocation service marshallers extend. Handles functionality
* Handles functionality common to all marshallers. * common to all marshallers.
*/ */
public class InvocationMarshaller public class InvocationMarshaller
implements Streamable, InvocationService implements Streamable, InvocationService
@@ -48,8 +48,7 @@ public class InvocationMarshaller
public static class ListenerMarshaller public static class ListenerMarshaller
implements Streamable, InvocationListener implements Streamable, InvocationListener
{ {
/** The method id used to dispatch a {@link #requestFailed} /** The method id used to dispatch a {@link #requestFailed} response. */
* response. */
public static final int REQUEST_FAILED_RSPID = 0; public static final int REQUEST_FAILED_RSPID = 0;
/** The oid of the invocation service requester. */ /** The oid of the invocation service requester. */
@@ -58,21 +57,21 @@ public class InvocationMarshaller
/** The request id associated with this listener. */ /** The request id associated with this listener. */
public short requestId; public short requestId;
/** The actual invocation listener associated with this /** The actual invocation listener associated with this marshalling listener. This is only
* marshalling listener. This is only valid on the client. */ * valid on the client. */
public transient InvocationListener listener; public transient InvocationListener listener;
/** The time at which this listener marshaller was registered. /** The time at which this listener marshaller was registered. This is only valid on the
* This is only valid on the client. */ * client. */
public transient long mapStamp; public transient long mapStamp;
/** The distributed object manager to use when dispatching proxied /** The distributed object manager to use when dispatching proxied responses. This is only
* responses. This is only valid on the server. */ * valid on the server. */
public transient DObjectManager omgr; public transient DObjectManager omgr;
/** /**
* Set an identifier for the invocation that this listener * Set an identifier for the invocation that this listener is used for, so we can report it
* is used for, so we can report it if we are never responded-to. * if we are never responded-to.
*/ */
public void setInvocationId (String name) public void setInvocationId (String name)
{ {
@@ -80,13 +79,11 @@ public class InvocationMarshaller
} }
/** /**
* Indicates that this listener will not be responded-to, and that * Indicates that this listener will not be responded-to, and that this is normal behavior.
* this is normal behavior.
*/ */
public void setNoResponse () public void setNoResponse ()
{ {
// we enact this by merely doing the same thing that we normally // we enact this by merely doing the same thing that we normally do during a response.
// do during a response.
_invId = null; _invId = null;
} }
@@ -95,13 +92,11 @@ public class InvocationMarshaller
{ {
_invId = null; _invId = null;
omgr.postEvent(new InvocationResponseEvent( omgr.postEvent(new InvocationResponseEvent(
callerOid, requestId, REQUEST_FAILED_RSPID, callerOid, requestId, REQUEST_FAILED_RSPID, new Object[] { cause }));
new Object[] { cause }));
} }
/** /**
* Called to dispatch an invocation response to our target * Called to dispatch an invocation response to our target listener.
* listener.
*/ */
public void dispatchResponse (int methodId, Object[] args) public void dispatchResponse (int methodId, Object[] args)
{ {
@@ -109,9 +104,8 @@ public class InvocationMarshaller
listener.requestFailed((String)args[0]); listener.requestFailed((String)args[0]);
} else { } else {
Log.warning("Requested to dispatch unknown invocation " + Log.warning("Requested to dispatch unknown invocation response " +
"response [listener=" + listener + "[listener=" + listener + ", methodId=" + methodId +
", methodId=" + methodId +
", args=" + StringUtil.toString(args) + "]."); ", args=" + StringUtil.toString(args) + "].");
} }
} }
@@ -130,8 +124,7 @@ public class InvocationMarshaller
throws Throwable throws Throwable
{ {
if (_invId != null && getClass() != ListenerMarshaller.class) { if (_invId != null && getClass() != ListenerMarshaller.class) {
Log.warning("Invocation listener never responded to: " + Log.warning("Invocation listener never responded to: " + _invId);
_invId);
} }
super.finalize(); super.finalize();
} }
@@ -146,17 +139,15 @@ public class InvocationMarshaller
public static class ConfirmMarshaller extends ListenerMarshaller public static class ConfirmMarshaller extends ListenerMarshaller
implements ConfirmListener implements ConfirmListener
{ {
/** The method id used to dispatch {@link #requestProcessed} /** The method id used to dispatch {@link #requestProcessed} responses. */
* responses. */
public static final int REQUEST_PROCESSED = 1; public static final int REQUEST_PROCESSED = 1;
// documentation inherited from interface // documentation inherited from interface
public void requestProcessed () public void requestProcessed ()
{ {
_invId = null; _invId = null;
omgr.postEvent(new InvocationResponseEvent( omgr.postEvent(
callerOid, requestId, REQUEST_PROCESSED, new InvocationResponseEvent(callerOid, requestId, REQUEST_PROCESSED, null));
null));
} }
// documentation inherited // documentation inherited
@@ -179,8 +170,7 @@ public class InvocationMarshaller
public static class ResultMarshaller extends ListenerMarshaller public static class ResultMarshaller extends ListenerMarshaller
implements ResultListener implements ResultListener
{ {
/** The method id used to dispatch {@link #requestProcessed} /** The method id used to dispatch {@link #requestProcessed} responses. */
* responses. */
public static final int REQUEST_PROCESSED = 1; public static final int REQUEST_PROCESSED = 1;
// documentation inherited from interface // documentation inherited from interface
@@ -188,8 +178,7 @@ public class InvocationMarshaller
{ {
_invId = null; _invId = null;
omgr.postEvent(new InvocationResponseEvent( omgr.postEvent(new InvocationResponseEvent(
callerOid, requestId, REQUEST_PROCESSED, callerOid, requestId, REQUEST_PROCESSED, new Object[] { result }));
new Object[] { result }));
} }
// documentation inherited // documentation inherited
@@ -197,8 +186,7 @@ public class InvocationMarshaller
{ {
switch (methodId) { switch (methodId) {
case REQUEST_PROCESSED: case REQUEST_PROCESSED:
((ResultListener)listener).requestProcessed( ((ResultListener)listener).requestProcessed(args[0]);
args[0]);
return; return;
default: default:
@@ -208,10 +196,9 @@ public class InvocationMarshaller
} }
/** /**
* Initializes this invocation marshaller instance with the requisite * Initializes this invocation marshaller instance with the requisite information to allow it
* information to allow it to operate in the wide world. This is * to operate in the wide world. This is called by the invocation manager when an invocation
* called by the invocation manager when an invocation provider is * provider is registered and should not be called otherwise.
* registered and should not be called otherwise.
*/ */
public void init (int invOid, int invCode) public void init (int invOid, int invCode)
{ {
@@ -220,9 +207,8 @@ public class InvocationMarshaller
} }
/** /**
* Sets the invocation oid to which this marshaller should send its * Sets the invocation oid to which this marshaller should send its invocation service
* invocation service requests. This is called by the invocation * requests. This is called by the invocation manager in certain initialization circumstances.
* manager in certain initialization circumstances.
*/ */
public void setInvocationOid (int invOid) public void setInvocationOid (int invOid)
{ {
@@ -238,8 +224,8 @@ public class InvocationMarshaller
} }
/** /**
* A convenience method to indicate that the listener is not going * A convenience method to indicate that the listener is not going to be responded-to, and that
* to be responded-to, and that this is ok. * this is ok.
*/ */
public static void setNoResponse (InvocationListener listener) public static void setNoResponse (InvocationListener listener)
{ {
@@ -249,13 +235,12 @@ public class InvocationMarshaller
} }
/** /**
* Called by generated invocation marshaller code; packages up and * Called by generated invocation marshaller code; packages up and sends the specified
* sends the specified invocation service request. * invocation service request.
*/ */
protected void sendRequest (Client client, int methodId, Object[] args) protected void sendRequest (Client client, int methodId, Object[] args)
{ {
client.getInvocationDirector().sendRequest( client.getInvocationDirector().sendRequest(_invOid, _invCode, methodId, args);
_invOid, _invCode, methodId, args);
} }
/** /**
@@ -263,15 +248,13 @@ public class InvocationMarshaller
*/ */
public String toString () public String toString ()
{ {
return "[invOid=" + _invOid + ", code=" + _invCode + return "[invOid=" + _invOid + ", code=" + _invCode + ", type=" + getClass().getName() + "]";
", type=" + getClass().getName() + "]";
} }
/** The oid of the invocation object, where invocation service /** The oid of the invocation object, where invocation service requests are sent. */
* requests are sent. */
protected int _invOid; protected int _invOid;
/** The invocation service code assigned to this service when it was /** The invocation service code assigned to this service when it was registered on the
* registered on the server. */ * server. */
protected int _invCode; protected int _invCode;
} }