diff --git a/src/main/java/org/apache/hadoop/fs/glusterfs/GlusterFSXattr.java b/src/main/java/org/apache/hadoop/fs/glusterfs/GlusterFSXattr.java index 0fcfce5b..361339c9 100644 --- a/src/main/java/org/apache/hadoop/fs/glusterfs/GlusterFSXattr.java +++ b/src/main/java/org/apache/hadoop/fs/glusterfs/GlusterFSXattr.java @@ -22,6 +22,8 @@ import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; +import java.net.InetAddress; +import java.net.UnknownHostException; import java.util.ArrayList; import java.util.HashMap; import java.util.Iterator; @@ -41,7 +43,7 @@ public enum CMD { GET_HINTS, GET_REPLICATION, GET_BLOCK_SIZE, CHECK_FOR_QUICK_IO } - private static String hostname; + private static String hostname; private String getFattrCmdBase = null; @@ -49,6 +51,40 @@ public GlusterFSXattr(String getAttr) { getFattrCmdBase=getAttr; } + public String getRack(String host){ + // returns the rack associated with a host. + + return "default-rack"; + } + + private static String[] hostsToIp(String[] hosts){ + String[] ips = new String[hosts.length]; + for(int i=0;i> vol,HashMap> vol,HashMap