incubator-blur-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From amccu...@apache.org
Subject [1/4] git commit: Removing some commented code.
Date Thu, 02 Jan 2014 15:45:39 GMT
Updated Branches:
  refs/heads/apache-blur-0.2 4f276ffa3 -> c0622345c


Removing some commented code.


Project: http://git-wip-us.apache.org/repos/asf/incubator-blur/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-blur/commit/e171c4e0
Tree: http://git-wip-us.apache.org/repos/asf/incubator-blur/tree/e171c4e0
Diff: http://git-wip-us.apache.org/repos/asf/incubator-blur/diff/e171c4e0

Branch: refs/heads/apache-blur-0.2
Commit: e171c4e05cbcc5cced99c0bfdc2dc048e8a6c379
Parents: 4f276ff
Author: Aaron McCurry <amccurry@gmail.com>
Authored: Tue Dec 31 19:31:51 2013 -0500
Committer: Aaron McCurry <amccurry@gmail.com>
Committed: Tue Dec 31 19:31:51 2013 -0500

----------------------------------------------------------------------
 .../apache/blur/store/hdfs/HdfsDirectory.java   | 37 +-------------------
 1 file changed, 1 insertion(+), 36 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/e171c4e0/blur-store/src/main/java/org/apache/blur/store/hdfs/HdfsDirectory.java
----------------------------------------------------------------------
diff --git a/blur-store/src/main/java/org/apache/blur/store/hdfs/HdfsDirectory.java b/blur-store/src/main/java/org/apache/blur/store/hdfs/HdfsDirectory.java
index 9a5020d..7ea7fe4 100644
--- a/blur-store/src/main/java/org/apache/blur/store/hdfs/HdfsDirectory.java
+++ b/blur-store/src/main/java/org/apache/blur/store/hdfs/HdfsDirectory.java
@@ -59,40 +59,6 @@ public class HdfsDirectory extends Directory implements LastModified {
 
   public static AtomicInteger fetchImpl = new AtomicInteger(3);
 
-  // static {
-  // Thread thread = new Thread(new Runnable() {
-  // @Override
-  // public void run() {
-  // while (true) {
-  // File file = new File("/tmp/fetch.impl");
-  // if (file.exists()) {
-  // try {
-  // BufferedReader reader = new BufferedReader(new InputStreamReader(new
-  // FileInputStream(file)));
-  // String line = reader.readLine();
-  // String trim = line.trim();
-  // int i = Integer.parseInt(trim);
-  // if (i != fetchImpl.get()) {
-  // LOG.info("Changing fetch impl [" + i + "]");
-  // fetchImpl.set(i);
-  // }
-  // reader.close();
-  // } catch (Exception e) {
-  // LOG.error("Unknown error", e);
-  // }
-  // }
-  // try {
-  // Thread.sleep(5000);
-  // } catch (InterruptedException e) {
-  // return;
-  // }
-  // }
-  // }
-  // });
-  // thread.setDaemon(true);
-  // thread.start();
-  // }
-
   /**
    * We keep the metrics separate per filesystem.
    */
@@ -318,7 +284,6 @@ public class HdfsDirectory extends Directory implements LastModified {
 
   @Override
   public void copy(Directory to, String src, String dest, IOContext context) throws IOException
{
-    LOG.warn("DANGEROUS copy [{0}] [{1}] [{2}] [{3}] [{4}]", to, src, dest, context, _path);
     if (to instanceof DirectoryDecorator) {
       copy(((DirectoryDecorator) to).getOriginalDirectory(), src, dest, context);
     } else if (to instanceof HdfsDirectory) {
@@ -327,7 +292,6 @@ public class HdfsDirectory extends Directory implements LastModified {
       }
     } else {
       slowCopy(to, src, dest, context);
-
     }
   }
 
@@ -336,6 +300,7 @@ public class HdfsDirectory extends Directory implements LastModified {
   }
 
   private boolean quickMove(Directory to, String src, String dest, IOContext context) throws
IOException {
+    LOG.warn("DANGEROUS copy [{0}] [{1}] [{2}] [{3}] [{4}]", to, src, dest, context, _path);
     HdfsDirectory simpleTo = (HdfsDirectory) to;
     if (ifSameCluster(simpleTo, this)) {
       Path newDest = simpleTo.getPath(dest);


Mime
View raw message