Minors.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/197a5728 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/197a5728 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/197a5728 Branch: refs/heads/ignite-3553 Commit: 197a5728274b377496bc29e7ceba26f90dd73c93 Parents: 77d213e Author: vozerov-gridgain <voze...@gridgain.com> Authored: Tue Jul 26 15:03:42 2016 +0300 Committer: vozerov-gridgain <voze...@gridgain.com> Committed: Tue Jul 26 15:03:42 2016 +0300 ---------------------------------------------------------------------- .../processors/igfs/client/IgfsClientClosureManager.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/197a5728/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/client/IgfsClientClosureManager.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/client/IgfsClientClosureManager.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/client/IgfsClientClosureManager.java index 9e0f044..d37f741 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/client/IgfsClientClosureManager.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/client/IgfsClientClosureManager.java @@ -32,15 +32,15 @@ import java.util.concurrent.ConcurrentLinkedDeque; * Manager to handle IGFS client closures. */ public class IgfsClientClosureManager extends IgfsManager { - /** Busy lock. */ - private final GridStripedSpinBusyLock busyLock = new GridStripedSpinBusyLock(); - /** Pending closures received when manager is not started yet. */ private final ConcurrentLinkedDeque startupClos = new ConcurrentLinkedDeque(); /** Marshaller. */ private final Marshaller marsh; + /** Stopping flag. */ + private volatile boolean stopping; + /** * Constructor. *
