[大数据] Hadoop源码分析（八）

abandonBlock 的处理不是很复杂，首先检查租约（调用 checkLease 方法。block 对应的文件存在，文件处于构造状态，租约拥有者匹配），如果通过检查，调用 FSDirectory 的 removeBlock，从INodeFileUnderConstruction/BlocksMap/CorruptReplicasMap 中删除 block，然后通过 logOpenFile()记录变化。

public LocatedBlock addBlock(String src, String clientName) throws IOException;

如果数据块被写满，客户端可以通过 addBlock 创建新的数据块。allocateBlock 创建一个新的 Block 对象，然后调用 addBlock，检查参数后把数据块加到?BlocksMap 对象和对应的 INodeFile 对象中。allocateBlock 返回后，getAdditionalBlock 还会继续更新一些需要记录的信息，最后返回一个新构造的 LocatedBlock。

 public boolean complete(String src, String clientName) throws IOException;

当客户端完成对数据块的写操作后，调用 complete 完成写操作。方法 complete 如果返回是 false，那么，客户端需要继续调用 complete 方法。

public void reportBadBlocks(LocatedBlock[] blocks) throws IOException;

调用reportBadBlocks.

2.目录树

public boolean rename(String src, String dst) throws IOException;

更改文件名。调用 FSNamesystem 的 renameTo方法。

 public void finalizeUpgrade() throws IOException;

finalize 一个升级，确认客户端有超级用户权限以后，调用 FSImage.finalizeUpgrade()。

public void fsync(String src, String client) throws IOException;

将文件信息持久化。调用 FSDirectory 的 persistBlocks，将文件的原信息通过 logOpenFile(path, file)写日志。

public DatanodeRegistration register(DatanodeRegistration nodeReg
 ) throws IOException

用于?DataNode 向 NameNode 登记。输入和输出参数都是 DatanodeRegistration。

public DatanodeCommand sendHeartbeat(DatanodeRegistration nodeReg,
 long capacity,
 long dfsUsed,
 long remaining,
 int xmitsInProgress,
 int xceiverCount) throws IOException

DataNode收送到?NameNode 的心跳信息。

DataNode Command支持的命令：

DNA_TRANSFER ：拷贝数据块到其他 DataNode

DNA_INVALIDATE ：删除数据块

DNA_SHUTDOWN ：关闭 DataNode

DNA_REGISTER ：DataNode 重新注册

DNA_FINALIZE ：提交升级

DNA_RECOVERBLOCK ：恢复数据块

FSNamesystem.handleHeartbeat 的处理过程：

调用 getDatanode 方法找对应的 DatanodeDescriptor，保存在变量 nodeinfo（可能为 null）

中，如果现有 NameNode 上记彔的 StorageID 和请求的不一样，返回DatanodeCommand.REGISTER，让DataNode重新注册。

如果发现当前节点需要关闭（已经?isDecommissioned），抛异常

DisallowedDatanodeException。

[大数据]Hadoop源码分析（八）