IGNITE-80 - Code review.
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/8633fed9 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/8633fed9 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/8633fed9 Branch: refs/heads/ignite-80 Commit: 8633fed90bb5e287cf597ee41e5a49c9f88ede34 Parents: a1dbea6 Author: Alexey Goncharuk <agoncha...@gridgain.com> Authored: Mon Apr 27 16:28:46 2015 -0700 Committer: Alexey Goncharuk <agoncha...@gridgain.com> Committed: Mon Apr 27 16:28:46 2015 -0700 ---------------------------------------------------------------------- .../processors/cache/distributed/near/GridNearLockFuture.java | 1 - .../main/java/org/apache/ignite/internal/util/GridDebug.java | 6 ------ .../apache/ignite/internal/util/future/GridCompoundFuture.java | 1 - 3 files changed, 8 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8633fed9/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearLockFuture.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearLockFuture.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearLockFuture.java index b1b6f83..a427b65 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearLockFuture.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearLockFuture.java @@ -28,7 +28,6 @@ import org.apache.ignite.internal.processors.cache.distributed.dht.*; import org.apache.ignite.internal.processors.cache.transactions.*; import org.apache.ignite.internal.processors.cache.version.*; import org.apache.ignite.internal.processors.timeout.*; -import org.apache.ignite.internal.util.*; import org.apache.ignite.internal.util.future.*; import org.apache.ignite.internal.util.tostring.*; import org.apache.ignite.internal.util.typedef.*; http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8633fed9/modules/core/src/main/java/org/apache/ignite/internal/util/GridDebug.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/GridDebug.java b/modules/core/src/main/java/org/apache/ignite/internal/util/GridDebug.java index f782b9b..188d87e 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/GridDebug.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/GridDebug.java @@ -34,9 +34,6 @@ import java.util.concurrent.atomic.*; * Utility class for debugging. */ public class GridDebug { - /** Max queue size. */ - public static final int MAX_SIZE = 2_000; - /** */ private static final AtomicReference<ConcurrentLinkedQueue<Item>> que = new AtomicReference<>(new ConcurrentLinkedQueue<Item>()); @@ -128,9 +125,6 @@ public class GridDebug { if (q != null) q.add(new Item(x)); - - if (q.size() > MAX_SIZE) - q.poll(); } /** http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8633fed9/modules/core/src/main/java/org/apache/ignite/internal/util/future/GridCompoundFuture.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/future/GridCompoundFuture.java b/modules/core/src/main/java/org/apache/ignite/internal/util/future/GridCompoundFuture.java index 6ce1a3b..6469011 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/future/GridCompoundFuture.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/future/GridCompoundFuture.java @@ -42,7 +42,6 @@ public class GridCompoundFuture<T, R> extends GridFutureAdapter<R> { private final ConcurrentLinkedDeque8<IgniteInternalFuture<T>> futs = new ConcurrentLinkedDeque8<>(); /** Pending futures. */ - @GridToStringInclude private final Collection<IgniteInternalFuture<T>> pending = new ConcurrentLinkedDeque8<>(); /** Listener call count. */
