|
@@ -77,14 +77,14 @@ public class BlockLocation implements Serializable {
|
|
new StorageType[0];
|
|
new StorageType[0];
|
|
|
|
|
|
/**
|
|
/**
|
|
- * Default Constructor
|
|
|
|
|
|
+ * Default Constructor.
|
|
*/
|
|
*/
|
|
public BlockLocation() {
|
|
public BlockLocation() {
|
|
this(EMPTY_STR_ARRAY, EMPTY_STR_ARRAY, 0L, 0L);
|
|
this(EMPTY_STR_ARRAY, EMPTY_STR_ARRAY, 0L, 0L);
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
/**
|
|
- * Copy constructor
|
|
|
|
|
|
+ * Copy constructor.
|
|
*/
|
|
*/
|
|
public BlockLocation(BlockLocation that) {
|
|
public BlockLocation(BlockLocation that) {
|
|
this.hosts = that.hosts;
|
|
this.hosts = that.hosts;
|
|
@@ -99,7 +99,7 @@ public class BlockLocation implements Serializable {
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
/**
|
|
- * Constructor with host, name, offset and length
|
|
|
|
|
|
+ * Constructor with host, name, offset and length.
|
|
*/
|
|
*/
|
|
public BlockLocation(String[] names, String[] hosts, long offset,
|
|
public BlockLocation(String[] names, String[] hosts, long offset,
|
|
long length) {
|
|
long length) {
|
|
@@ -107,7 +107,7 @@ public class BlockLocation implements Serializable {
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
/**
|
|
- * Constructor with host, name, offset, length and corrupt flag
|
|
|
|
|
|
+ * Constructor with host, name, offset, length and corrupt flag.
|
|
*/
|
|
*/
|
|
public BlockLocation(String[] names, String[] hosts, long offset,
|
|
public BlockLocation(String[] names, String[] hosts, long offset,
|
|
long length, boolean corrupt) {
|
|
long length, boolean corrupt) {
|
|
@@ -115,7 +115,7 @@ public class BlockLocation implements Serializable {
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
/**
|
|
- * Constructor with host, name, network topology, offset and length
|
|
|
|
|
|
+ * Constructor with host, name, network topology, offset and length.
|
|
*/
|
|
*/
|
|
public BlockLocation(String[] names, String[] hosts, String[] topologyPaths,
|
|
public BlockLocation(String[] names, String[] hosts, String[] topologyPaths,
|
|
long offset, long length) {
|
|
long offset, long length) {
|
|
@@ -124,7 +124,7 @@ public class BlockLocation implements Serializable {
|
|
|
|
|
|
/**
|
|
/**
|
|
* Constructor with host, name, network topology, offset, length
|
|
* Constructor with host, name, network topology, offset, length
|
|
- * and corrupt flag
|
|
|
|
|
|
+ * and corrupt flag.
|
|
*/
|
|
*/
|
|
public BlockLocation(String[] names, String[] hosts, String[] topologyPaths,
|
|
public BlockLocation(String[] names, String[] hosts, String[] topologyPaths,
|
|
long offset, long length, boolean corrupt) {
|
|
long offset, long length, boolean corrupt) {
|
|
@@ -176,21 +176,21 @@ public class BlockLocation implements Serializable {
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
/**
|
|
- * Get the list of hosts (hostname) hosting this block
|
|
|
|
|
|
+ * Get the list of hosts (hostname) hosting this block.
|
|
*/
|
|
*/
|
|
public String[] getHosts() throws IOException {
|
|
public String[] getHosts() throws IOException {
|
|
return hosts;
|
|
return hosts;
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
/**
|
|
- * Get the list of hosts (hostname) hosting a cached replica of the block
|
|
|
|
|
|
+ * Get the list of hosts (hostname) hosting a cached replica of the block.
|
|
*/
|
|
*/
|
|
public String[] getCachedHosts() {
|
|
public String[] getCachedHosts() {
|
|
- return cachedHosts;
|
|
|
|
|
|
+ return cachedHosts;
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
/**
|
|
- * Get the list of names (IP:xferPort) hosting this block
|
|
|
|
|
|
+ * Get the list of names (IP:xferPort) hosting this block.
|
|
*/
|
|
*/
|
|
public String[] getNames() throws IOException {
|
|
public String[] getNames() throws IOException {
|
|
return names;
|
|
return names;
|
|
@@ -219,14 +219,14 @@ public class BlockLocation implements Serializable {
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
/**
|
|
- * Get the start offset of file associated with this block
|
|
|
|
|
|
+ * Get the start offset of file associated with this block.
|
|
*/
|
|
*/
|
|
public long getOffset() {
|
|
public long getOffset() {
|
|
return offset;
|
|
return offset;
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
/**
|
|
- * Get the length of the block
|
|
|
|
|
|
+ * Get the length of the block.
|
|
*/
|
|
*/
|
|
public long getLength() {
|
|
public long getLength() {
|
|
return length;
|
|
return length;
|
|
@@ -247,14 +247,14 @@ public class BlockLocation implements Serializable {
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
/**
|
|
- * Set the start offset of file associated with this block
|
|
|
|
|
|
+ * Set the start offset of file associated with this block.
|
|
*/
|
|
*/
|
|
public void setOffset(long offset) {
|
|
public void setOffset(long offset) {
|
|
this.offset = offset;
|
|
this.offset = offset;
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
/**
|
|
- * Set the length of block
|
|
|
|
|
|
+ * Set the length of block.
|
|
*/
|
|
*/
|
|
public void setLength(long length) {
|
|
public void setLength(long length) {
|
|
this.length = length;
|
|
this.length = length;
|
|
@@ -268,7 +268,7 @@ public class BlockLocation implements Serializable {
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
/**
|
|
- * Set the hosts hosting this block
|
|
|
|
|
|
+ * Set the hosts hosting this block.
|
|
*/
|
|
*/
|
|
public void setHosts(String[] hosts) throws IOException {
|
|
public void setHosts(String[] hosts) throws IOException {
|
|
if (hosts == null) {
|
|
if (hosts == null) {
|
|
@@ -279,7 +279,7 @@ public class BlockLocation implements Serializable {
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
/**
|
|
- * Set the hosts hosting a cached replica of this block
|
|
|
|
|
|
+ * Set the hosts hosting a cached replica of this block.
|
|
*/
|
|
*/
|
|
public void setCachedHosts(String[] cachedHosts) {
|
|
public void setCachedHosts(String[] cachedHosts) {
|
|
if (cachedHosts == null) {
|
|
if (cachedHosts == null) {
|
|
@@ -290,7 +290,7 @@ public class BlockLocation implements Serializable {
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
/**
|
|
- * Set the names (host:port) hosting this block
|
|
|
|
|
|
+ * Set the names (host:port) hosting this block.
|
|
*/
|
|
*/
|
|
public void setNames(String[] names) throws IOException {
|
|
public void setNames(String[] names) throws IOException {
|
|
if (names == null) {
|
|
if (names == null) {
|
|
@@ -301,7 +301,7 @@ public class BlockLocation implements Serializable {
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
/**
|
|
- * Set the network topology paths of the hosts
|
|
|
|
|
|
+ * Set the network topology paths of the hosts.
|
|
*/
|
|
*/
|
|
public void setTopologyPaths(String[] topologyPaths) throws IOException {
|
|
public void setTopologyPaths(String[] topologyPaths) throws IOException {
|
|
if (topologyPaths == null) {
|
|
if (topologyPaths == null) {
|