Overrides & whitespace.

git-svn-id: svn+ssh://src.earth.threerings.net/narya/trunk@5421 542714f4-19e9-0310-aa3c-eee0fc999fb1
This commit is contained in:
Dave Hoover
2008-10-08 18:51:22 +00:00
parent d68aaec196
commit df42b4a013
3 changed files with 11 additions and 10 deletions
@@ -47,7 +47,7 @@ public class BureauLogRedirector
_bureauId = bureauId; _bureauId = bureauId;
_reader = new BufferedReader(new InputStreamReader(input)); _reader = new BufferedReader(new InputStreamReader(input));
Thread thread = new Thread(bureauId) { Thread thread = new Thread(bureauId) {
public void run () { @Override public void run () {
copyLoop(); copyLoop();
}}; }};
thread.setDaemon(true); thread.setDaemon(true);
@@ -325,7 +325,7 @@ public class PresentsClient
// clear out the client object so that we know the session is over // clear out the client object so that we know the session is over
_clobj = null; _clobj = null;
// Cancel overflow processing // Cancel overflow processing
if (_overflow != null) { if (_overflow != null) {
_overflow.stop(); _overflow.stop();
@@ -416,7 +416,7 @@ public class PresentsClient
handleThrottleExceeded(); handleThrottleExceeded();
} }
dispatch(message); dispatch(message);
} }
@@ -446,7 +446,7 @@ public class PresentsClient
dispatch(_overflow.dequeue()); dispatch(_overflow.dequeue());
} }
} }
protected void dispatch (UpstreamMessage message) protected void dispatch (UpstreamMessage message)
{ {
// we dispatch to a message dispatcher that is specialized for the particular class of // we dispatch to a message dispatcher that is specialized for the particular class of
@@ -1082,7 +1082,7 @@ public class PresentsClient
client.safeEndSession(); client.safeEndSession();
} }
} }
/** /**
* Contains information about message overflow. * Contains information about message overflow.
*/ */
@@ -1090,7 +1090,7 @@ public class PresentsClient
{ {
/** Maxmimum size of queue before disconnection. */ /** Maxmimum size of queue before disconnection. */
public int limit; public int limit;
/** /**
* Starts processing the overflowed messages every so often. * Starts processing the overflowed messages every so often.
*/ */
@@ -1098,7 +1098,7 @@ public class PresentsClient
{ {
if (_interval == null) { if (_interval == null) {
_interval = new Interval(_omgr) { _interval = new Interval(_omgr) {
public void expired () { @Override public void expired () {
handleOverflowMessages(); handleOverflowMessages();
} }
}; };
@@ -1147,7 +1147,7 @@ public class PresentsClient
/** Previously throttled messages waiting to be sent. */ /** Previously throttled messages waiting to be sent. */
protected LinkedList<UpstreamMessage> _queue = new LinkedList<UpstreamMessage>(); protected LinkedList<UpstreamMessage> _queue = new LinkedList<UpstreamMessage>();
} }
@Inject protected ClientManager _clmgr; @Inject protected ClientManager _clmgr;
@Inject protected ConnectionManager _conmgr; @Inject protected ConnectionManager _conmgr;
@Inject protected PresentsDObjectMgr _omgr; @Inject protected PresentsDObjectMgr _omgr;
@@ -35,7 +35,7 @@ public class VariableThrottle extends Throttle
{ {
super(operations, period); super(operations, period);
} }
/** /**
* Updates the number of operations for this throttle to a new maximum, retaining the current * Updates the number of operations for this throttle to a new maximum, retaining the current
* history of operations if the limit is being increased and truncating the oldest operations * history of operations if the limit is being increased and truncating the oldest operations
@@ -61,7 +61,8 @@ public class VariableThrottle extends Throttle
} }
_ops = ops; _ops = ops;
} }
@Override
public String toString () public String toString ()
{ {
return "VariableThrottle [" + _ops.length + " per " + _period + "ms]"; return "VariableThrottle [" + _ops.length + " per " + _period + "ms]";