AfflictionNetworks/narya
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Wee cleanup.

Browse Source 
git-svn-id: svn+ssh://src.earth.threerings.net/narya/trunk@5899 542714f4-19e9-0310-aa3c-eee0fc999fb1
This commit is contained in:
Ray Greenwell
2009-08-12 18:22:46 +00:00
parent 5aefb2a2a6
commit 4780fefb73
1 changed files with 4 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/java/com/threerings/presents/server/PresentsInvoker.java
+4 -5
View File
@@ -95,7 +95,7 @@ public class PresentsInvoker extends ReportingInvoker
* and the DObjectManager are all empty. * and the DObjectManager are all empty.
*/ */
protected class EmptyingUnit extends Unit { protected class EmptyingUnit extends Unit {
public EmptyingUnit(Runnable onEmpty) { public EmptyingUnit (Runnable onEmpty) {
_onEmpty = onEmpty; _onEmpty = onEmpty;
} }
@@ -124,7 +124,7 @@ public class PresentsInvoker extends ReportingInvoker
_loopCount = 0; _loopCount = 0;
// The invoker is empty and running this. Check if everything else is empty. // The invoker is empty and running this. Check if everything else is empty.
List<BlockingUnit> checkers = List<BlockingUnit> checkers =
Lists.newArrayListWithExpectedSize(_interdependentInvokers.size() + 1); Lists.newArrayListWithCapacity(_interdependentInvokers.size() + 1);
for (Invoker invoker : _interdependentInvokers) { for (Invoker invoker : _interdependentInvokers) {
checkers.add(new BlockingUnit(invoker)); checkers.add(new BlockingUnit(invoker));
} }
@@ -144,8 +144,8 @@ public class PresentsInvoker extends ReportingInvoker
long timeChecking = System.currentTimeMillis() - checkStart; long timeChecking = System.currentTimeMillis() - checkStart;
if (timeChecking >= FIVE_MINUTES) { if (timeChecking >= FIVE_MINUTES) {
log.warning("Waited 5 minutes for the all the blocking units to " log.warning("Waited 5 minutes for the all the blocking units to "
+ " to no avail. Running onEmpty while items may remain in " + "no avail. Running onEmpty while items may remain in "
+ "" + "the queue."); + "the queue.");
releaseCheckers(checkers); releaseCheckers(checkers);
_onEmpty.run(); _onEmpty.run();
return false; return false;
@@ -182,7 +182,6 @@ public class PresentsInvoker extends ReportingInvoker
return false; return false;
} }
} }
} }
} }
} }