Comment fiddling.
git-svn-id: svn+ssh://src.earth.threerings.net/narya/trunk@218 542714f4-19e9-0310-aa3c-eee0fc999fb1
This commit is contained in:
@@ -1,5 +1,5 @@
|
|||||||
//
|
//
|
||||||
// $Id: PresentsClient.java,v 1.17 2001/08/07 21:25:13 mdb Exp $
|
// $Id: PresentsClient.java,v 1.18 2001/08/11 00:12:11 mdb Exp $
|
||||||
|
|
||||||
package com.threerings.cocktail.cher.server;
|
package com.threerings.cocktail.cher.server;
|
||||||
|
|
||||||
@@ -216,8 +216,8 @@ public class CherClient implements Subscriber, MessageHandler
|
|||||||
Enumeration enum = _subscrips.elements();
|
Enumeration enum = _subscrips.elements();
|
||||||
while (enum.hasMoreElements()) {
|
while (enum.hasMoreElements()) {
|
||||||
DObject object = (DObject)enum.nextElement();
|
DObject object = (DObject)enum.nextElement();
|
||||||
// Log.info("Clearing subscription [client=" + this +
|
// Log.info("Clearing subscription [client=" + this +
|
||||||
// ", obj=" + object + "].");
|
// ", obj=" + object + "].");
|
||||||
object.removeSubscriber(this);
|
object.removeSubscriber(this);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -479,8 +479,8 @@ public class CherClient implements Subscriber, MessageHandler
|
|||||||
public void dispatch (CherClient client, UpstreamMessage msg)
|
public void dispatch (CherClient client, UpstreamMessage msg)
|
||||||
{
|
{
|
||||||
SubscribeRequest req = (SubscribeRequest)msg;
|
SubscribeRequest req = (SubscribeRequest)msg;
|
||||||
// Log.info("Subscribing [client=" + client +
|
// Log.info("Subscribing [client=" + client +
|
||||||
// ", oid=" + req.getOid() + "].");
|
// ", oid=" + req.getOid() + "].");
|
||||||
|
|
||||||
// forward the subscribe request to the omgr for processing
|
// forward the subscribe request to the omgr for processing
|
||||||
CherServer.omgr.subscribeToObject(req.getOid(), client);
|
CherServer.omgr.subscribeToObject(req.getOid(), client);
|
||||||
@@ -495,8 +495,8 @@ public class CherClient implements Subscriber, MessageHandler
|
|||||||
public void dispatch (CherClient client, UpstreamMessage msg)
|
public void dispatch (CherClient client, UpstreamMessage msg)
|
||||||
{
|
{
|
||||||
UnsubscribeRequest req = (UnsubscribeRequest)msg;
|
UnsubscribeRequest req = (UnsubscribeRequest)msg;
|
||||||
// Log.info("Unsubscribing [client=" + client +
|
// Log.info("Unsubscribing [client=" + client +
|
||||||
// ", oid=" + req.getOid() + "].");
|
// ", oid=" + req.getOid() + "].");
|
||||||
|
|
||||||
// forward the unsubscribe request to the omgr for processing
|
// forward the unsubscribe request to the omgr for processing
|
||||||
CherServer.omgr.unsubscribeFromObject(req.getOid(), client);
|
CherServer.omgr.unsubscribeFromObject(req.getOid(), client);
|
||||||
@@ -518,8 +518,8 @@ public class CherClient implements Subscriber, MessageHandler
|
|||||||
// fill in the proper source oid
|
// fill in the proper source oid
|
||||||
fevt.setSourceOid(client.getClientObject().getOid());
|
fevt.setSourceOid(client.getClientObject().getOid());
|
||||||
|
|
||||||
// Log.info("Forwarding event [client=" + client +
|
// Log.info("Forwarding event [client=" + client +
|
||||||
// ", event=" + fevt + "].");
|
// ", event=" + fevt + "].");
|
||||||
|
|
||||||
// forward the event to the omgr for processing
|
// forward the event to the omgr for processing
|
||||||
CherServer.omgr.postEvent(fevt);
|
CherServer.omgr.postEvent(fevt);
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
//
|
//
|
||||||
// $Id: TestProvider.java,v 1.6 2001/08/11 00:05:58 mdb Exp $
|
// $Id: TestProvider.java,v 1.7 2001/08/11 00:12:11 mdb Exp $
|
||||||
|
|
||||||
package com.threerings.cocktail.cher.server.test;
|
package com.threerings.cocktail.cher.server.test;
|
||||||
|
|
||||||
@@ -30,6 +30,8 @@ public class TestProvider extends InvocationProvider
|
|||||||
|
|
||||||
public void handleGetTestOidRequest (ClientObject source, int invid)
|
public void handleGetTestOidRequest (ClientObject source, int invid)
|
||||||
{
|
{
|
||||||
|
Log.info("Handling get test oid [src=" + source.getOid() +
|
||||||
|
", invid=" + invid + "].");
|
||||||
int oid = TestServer.testobj.getOid();
|
int oid = TestServer.testobj.getOid();
|
||||||
sendResponse(source, invid, "GotTestOid", new Integer(oid));
|
sendResponse(source, invid, "GotTestOid", new Integer(oid));
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user