Skip to content

Commit 7afe5d2

Browse files
committed
(Raw)LocalFileSystem re-implementation of the gluster shim. Notable changes:
- LocalFileSystem is top level class and provides user space/"local" file system request dispatch. GlusterFileSystem extends LocalFileSystem - GlusterVolume extends RawLocalFileSystem and is the methods to access a single gluster volume in the local user space. - DFS / Gluster volume directories must be specified with glusterfs:// prefix. Local file systems SHOULD specify file://
1 parent 9fc4c8f commit 7afe5d2

15 files changed

+375
-1259
lines changed

src/main/java/org/apache/hadoop/fs/glusterfs/GlusterDebugFileSystem.java

Lines changed: 0 additions & 273 deletions
This file was deleted.

src/main/java/org/apache/hadoop/fs/glusterfs/GlusterFSBrickClass.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -49,7 +49,6 @@ public boolean isChunked(){
4949

5050
public String brickIsLocal(String hostname){
5151
String path=null;
52-
File f=null;
5352
if(host.equals(hostname))
5453
path=exportedFile;
5554

src/main/java/org/apache/hadoop/fs/glusterfs/GlusterFSBrickRepl.java

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -19,8 +19,6 @@
1919

2020
package org.apache.hadoop.fs.glusterfs;
2121

22-
import java.io.*;
23-
2422
public class GlusterFSBrickRepl{
2523
private String[] replHost;
2624
private long start;

src/main/java/org/apache/hadoop/fs/glusterfs/GlusterFSXattr.java

Lines changed: 10 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -19,16 +19,16 @@
1919

2020
package org.apache.hadoop.fs.glusterfs;
2121

22-
import java.net.*;
23-
import java.util.regex.Matcher;
24-
import java.util.regex.Pattern;
25-
import java.io.*;
26-
import java.util.HashMap;
27-
import java.util.TreeMap;
22+
import java.io.BufferedReader;
23+
import java.io.IOException;
24+
import java.io.InputStreamReader;
2825
import java.util.ArrayList;
26+
import java.util.HashMap;
2927
import java.util.Iterator;
28+
import java.util.TreeMap;
29+
import java.util.regex.Matcher;
30+
import java.util.regex.Pattern;
3031

31-
import org.apache.hadoop.conf.Configuration;
3232
import org.apache.hadoop.fs.BlockLocation;
3333

3434
public class GlusterFSXattr{
@@ -43,13 +43,9 @@ public enum CMD {
4343

4444
private static String hostname;
4545

46-
private String getFattrCmdBase;
47-
48-
public GlusterFSXattr(Configuration conf) {
49-
getFattrCmdBase=conf.get("fs.glusterfs.getfattrcmd",
50-
"getfattr -m . -n trusted.glusterfs.pathinfo");
51-
}
46+
private String getFattrCmdBase = "sudo getfattr -m . -n trusted.glusterfs.pathinfo";
5247

48+
5349
public String brick2host(String brick) throws IOException{
5450
String[] hf=null;
5551

@@ -456,4 +452,4 @@ public int getReplicationFromLayout(HashMap<String, ArrayList<String>> vol,HashM
456452

457453
return replication;
458454
}
459-
}
455+
}

0 commit comments

Comments
 (0)