You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by vo...@apache.org on 2016/06/08 12:19:51 UTC
[10/11] ignite git commit: IGNITE-3264: IGFS: Reworked output stream.
IGNITE-3264: IGFS: Reworked output stream.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/7761e5f5
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/7761e5f5
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/7761e5f5
Branch: refs/heads/master
Commit: 7761e5f573d9f39b5cc542f3d67bacab4e66609a
Parents: 177ebd5
Author: vozerov-gridgain <vo...@gridgain.com>
Authored: Wed Jun 8 15:13:33 2016 +0300
Committer: vozerov-gridgain <vo...@gridgain.com>
Committed: Wed Jun 8 15:13:33 2016 +0300
----------------------------------------------------------------------
.../ignite/internal/processors/igfs/IgfsDeleteWorker.java | 7 +++++--
1 file changed, 5 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/7761e5f5/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsDeleteWorker.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsDeleteWorker.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsDeleteWorker.java
index 3d41071..8dcccea 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsDeleteWorker.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsDeleteWorker.java
@@ -19,7 +19,6 @@ package org.apache.ignite.internal.processors.igfs;
import org.apache.ignite.IgniteCheckedException;
import org.apache.ignite.IgniteLogger;
-import org.apache.ignite.cluster.ClusterNode;
import org.apache.ignite.igfs.IgfsPath;
import org.apache.ignite.internal.IgniteFutureCancelledCheckedException;
import org.apache.ignite.internal.IgniteInterruptedCheckedException;
@@ -36,7 +35,6 @@ import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
-import static org.apache.ignite.internal.GridTopic.TOPIC_IGFS;
import static org.apache.ignite.events.EventType.EVT_IGFS_FILE_PURGED;
/**
@@ -49,6 +47,9 @@ public class IgfsDeleteWorker extends IgfsThread {
/** How many files/folders to delete at once (i.e in a single transaction). */
private static final int MAX_DELETE_BATCH = 100;
+ /** IGFS context. */
+ private final IgfsContext igfsCtx;
+
/** Metadata manager. */
private final IgfsMetaManager meta;
@@ -78,6 +79,8 @@ public class IgfsDeleteWorker extends IgfsThread {
IgfsDeleteWorker(IgfsContext igfsCtx) {
super("igfs-delete-worker%" + igfsCtx.igfs().name() + "%" + igfsCtx.kernalContext().localNodeId() + "%");
+ this.igfsCtx = igfsCtx;
+
meta = igfsCtx.meta();
data = igfsCtx.data();