More style cleanup.
git-svn-id: svn+ssh://src.earth.threerings.net/narya/trunk@5249 542714f4-19e9-0310-aa3c-eee0fc999fb1
This commit is contained in:
@@ -457,7 +457,9 @@ public class BlockingCommunicator extends Communicator
|
|||||||
// of the frame from the network, in which case we simply call it again because we can't do
|
// of the frame from the network, in which case we simply call it again because we can't do
|
||||||
// anything until it has a whole frame; it will throw an exception if it hits EOF or if
|
// anything until it has a whole frame; it will throw an exception if it hits EOF or if
|
||||||
// something goes awry)
|
// something goes awry)
|
||||||
while (!_fin.readFrame(_channel));
|
while (!_fin.readFrame(_channel)) {
|
||||||
|
// noop!
|
||||||
|
}
|
||||||
|
|
||||||
try {
|
try {
|
||||||
DownstreamMessage msg = (DownstreamMessage)_oin.readObject();
|
DownstreamMessage msg = (DownstreamMessage)_oin.readObject();
|
||||||
@@ -977,7 +979,7 @@ public class BlockingCommunicator extends Communicator
|
|||||||
protected ClientDObjectMgr _omgr;
|
protected ClientDObjectMgr _omgr;
|
||||||
protected ClassLoader _loader;
|
protected ClassLoader _loader;
|
||||||
|
|
||||||
/** The number of times per port to try to establish a datagram "connection." */
|
/** The number of times per port to try to establish a datagram "connection". */
|
||||||
protected static final int DATAGRAM_ATTEMPTS_PER_PORT = 10;
|
protected static final int DATAGRAM_ATTEMPTS_PER_PORT = 10;
|
||||||
|
|
||||||
/** The number of milliseconds to wait for a response datagram. */
|
/** The number of milliseconds to wait for a response datagram. */
|
||||||
|
|||||||
@@ -62,7 +62,14 @@ public class ClientDObjectMgr
|
|||||||
_client = client;
|
_client = client;
|
||||||
|
|
||||||
// register a debug hook for dumping all objects in the distributed object table
|
// register a debug hook for dumping all objects in the distributed object table
|
||||||
DebugChords.registerHook(DUMP_OTABLE_MODMASK, DUMP_OTABLE_KEYCODE, DUMP_OTABLE_HOOK);
|
DebugChords.registerHook(DUMP_OTABLE_MODMASK, DUMP_OTABLE_KEYCODE, new DebugChords.Hook() {
|
||||||
|
public void invoke () {
|
||||||
|
log.info("Dumping " + _ocache.size() + " objects:");
|
||||||
|
for (DObject obj : _ocache.values()) {
|
||||||
|
log.info(obj.getClass().getName() + " " + obj);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
});
|
||||||
|
|
||||||
// register a flush interval
|
// register a flush interval
|
||||||
new Interval(client.getRunQueue()) {
|
new Interval(client.getRunQueue()) {
|
||||||
@@ -448,6 +455,7 @@ public class ClientDObjectMgr
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/** Represents a pending subscription request. */
|
||||||
protected static final class PendingRequest<T extends DObject>
|
protected static final class PendingRequest<T extends DObject>
|
||||||
{
|
{
|
||||||
public int oid;
|
public int oid;
|
||||||
@@ -504,16 +512,6 @@ public class ClientDObjectMgr
|
|||||||
/** A set of objects waiting to be flushed. */
|
/** A set of objects waiting to be flushed. */
|
||||||
protected HashIntMap<FlushRecord> _flushes = new HashIntMap<FlushRecord>();
|
protected HashIntMap<FlushRecord> _flushes = new HashIntMap<FlushRecord>();
|
||||||
|
|
||||||
/** A debug hook that allows the dumping of all objects in the object table out to the log. */
|
|
||||||
protected DebugChords.Hook DUMP_OTABLE_HOOK = new DebugChords.Hook() {
|
|
||||||
public void invoke () {
|
|
||||||
log.info("Dumping " + _ocache.size() + " objects:");
|
|
||||||
for (DObject obj : _ocache.values()) {
|
|
||||||
log.info(obj.getClass().getName() + " " + obj);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
};
|
|
||||||
|
|
||||||
/** The modifiers for our dump table debug hook (Alt+Shift). */
|
/** The modifiers for our dump table debug hook (Alt+Shift). */
|
||||||
protected static int DUMP_OTABLE_MODMASK = KeyEvent.ALT_DOWN_MASK|KeyEvent.SHIFT_DOWN_MASK;
|
protected static int DUMP_OTABLE_MODMASK = KeyEvent.ALT_DOWN_MASK|KeyEvent.SHIFT_DOWN_MASK;
|
||||||
|
|
||||||
|
|||||||
@@ -21,9 +21,6 @@
|
|||||||
|
|
||||||
package com.threerings.presents.client;
|
package com.threerings.presents.client;
|
||||||
|
|
||||||
import com.threerings.presents.client.Client;
|
|
||||||
import com.threerings.presents.client.InvocationService;
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Provides a means by which to obtain access to a time base object which can be used to convert
|
* Provides a means by which to obtain access to a time base object which can be used to convert
|
||||||
* delta times into absolute times.
|
* delta times into absolute times.
|
||||||
|
|||||||
Reference in New Issue
Block a user