Apache
/
hadoop
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HDFS-8867. Enable optimized block reports. Contributed by Daryn Sharp.

This commit is contained in:
Jing Zhao 2015-08-19 10:36:56 -07:00
parent 9c3571ea60
commit f61120d964
3 changed files with 23 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
hadoop-hdfs-project/hadoop-hdfs/CHANGES.txt
View File

@ -1205,6 +1205,8 @@ Release 2.7.2 - UNRELEASED
HDFS-8852. HDFS architecture documentation of version 2.x is outdated
about append write support. (Ajith S via aajisaka)
HDFS-8867. Enable optimized block reports. (Daryn Sharp via jing9)
Release 2.7.1 - 2015-07-06
INCOMPATIBLE CHANGES

17
hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/protocol/NamespaceInfo.java
View File

@ -47,18 +47,27 @@ public class NamespaceInfo extends StorageInfo {
// only authoritative on the server-side to determine advertisement to
// clients. enum will update the supported values
private static long CAPABILITIES_SUPPORTED = 0;
private static final long CAPABILITIES_SUPPORTED = getSupportedCapabilities();
private static long getSupportedCapabilities() {
long mask = 0;
for (Capability c : Capability.values()) {
if (c.supported) {
mask |= c.mask;
}
}
return mask;
}
public enum Capability {
UNKNOWN(false),
STORAGE_BLOCK_REPORT_BUFFERS(true); // use optimized ByteString buffers
private final boolean supported;
private final long mask;
Capability(boolean isSupported) {
supported = isSupported;
int bits = ordinal() - 1;
mask = (bits < 0) ? 0 : (1L << bits);
if (isSupported) {
CAPABILITIES_SUPPORTED |= mask;
}
}
public long getMask() {
return mask;

7
hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/protocol/TestBlockListAsLongs.java
View File

@ -188,6 +188,13 @@ public class TestBlockListAsLongs {
assertTrue(reportReplicas.isEmpty());
}
@Test
public void testCapabilitiesInited() {
NamespaceInfo nsInfo = new NamespaceInfo();
assertTrue(
nsInfo.isCapabilitySupported(Capability.STORAGE_BLOCK_REPORT_BUFFERS));
}
@Test
public void testDatanodeDetect() throws ServiceException, IOException {
final AtomicReference<BlockReportRequestProto> request =