org.apache.hadoop.hdfs.protocolPB

Class DatanodeProtocolClientSideTranslatorPB

java.lang.Object

org.apache.hadoop.hdfs.protocolPB.DatanodeProtocolClientSideTranslatorPB

All Implemented Interfaces:

Closeable, AutoCloseable, DatanodeProtocol, ProtocolMetaInterface

@InterfaceAudience.Private
@InterfaceStability.Stable
public class DatanodeProtocolClientSideTranslatorPB
extends Object
implements ProtocolMetaInterface, DatanodeProtocol, Closeable

This class is the client side translator to translate the requests made on DatanodeProtocol interfaces to the RPC server implementing DatanodeProtocolPB.

Field Summary

Fields inherited from interface org.apache.hadoop.hdfs.server.protocol.DatanodeProtocol

DISK_ERROR, DNA_ACCESSKEYUPDATE, DNA_BALANCERBANDWIDTHUPDATE, DNA_FINALIZE, DNA_INVALIDATE, DNA_RECOVERBLOCK, DNA_REGISTER, DNA_SHUTDOWN, DNA_TRANSFER, DNA_UNKNOWN, FATAL_DISK_ERROR, INVALID_BLOCK, NOTIFY, versionID

Constructor Summary

Constructors

Constructor and Description
DatanodeProtocolClientSideTranslatorPB(InetSocketAddress nameNodeAddr, Configuration conf)

Method Summary

Methods

Modifier and Type	Method and Description
void	blockReceivedAndDeleted(DatanodeRegistration registration, String poolId, StorageReceivedDeletedBlocks[] receivedAndDeletedBlocks) blockReceivedAndDeleted() allows the DataNode to tell the NameNode about recently-received and -deleted block data.
DatanodeCommand	blockReport(DatanodeRegistration registration, String poolId, StorageBlockReport[] reports) blockReport() tells the NameNode about all the locally-stored blocks.
void	close()
void	commitBlockSynchronization(ExtendedBlock block, long newgenerationstamp, long newlength, boolean closeFile, boolean deleteblock, DatanodeID[] newtargets, String[] newtargetstorages) Commit block synchronization in lease recovery
void	errorReport(DatanodeRegistration registration, int errorCode, String msg) errorReport() tells the NameNode about something that has gone awry.
boolean	isMethodSupported(String methodName) Checks whether the given method name is supported by the server.
DatanodeRegistration	registerDatanode(DatanodeRegistration registration) Register Datanode.
void	reportBadBlocks(LocatedBlock[] blocks) same as ClientProtocol.reportBadBlocks(LocatedBlock[]) }
HeartbeatResponse	sendHeartbeat(DatanodeRegistration registration, StorageReport[] reports, int xmitsInProgress, int xceiverCount, int failedVolumes) sendHeartbeat() tells the NameNode that the DataNode is still alive and well.
NamespaceInfo	versionRequest()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DatanodeProtocolClientSideTranslatorPB

public DatanodeProtocolClientSideTranslatorPB(InetSocketAddress nameNodeAddr,
                                      Configuration conf)
                                       throws IOException

Throws:

IOException

Method Detail

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

registerDatanode

public DatanodeRegistration registerDatanode(DatanodeRegistration registration)
                                      throws IOException

Description copied from interface: DatanodeProtocol

Register Datanode.

Specified by:

registerDatanode in interface DatanodeProtocol

Parameters:

registration - datanode registration information

Returns:

the given DatanodeRegistration with updated registration information

Throws:

IOException

See Also:

FSNamesystem.registerDatanode(DatanodeRegistration)

sendHeartbeat

public HeartbeatResponse sendHeartbeat(DatanodeRegistration registration,
                              StorageReport[] reports,
                              int xmitsInProgress,
                              int xceiverCount,
                              int failedVolumes)
                                throws IOException

Description copied from interface: DatanodeProtocol

sendHeartbeat() tells the NameNode that the DataNode is still alive and well. Includes some status info, too. It also gives the NameNode a chance to return an array of "DatanodeCommand" objects in HeartbeatResponse. A DatanodeCommand tells the DataNode to invalidate local block(s), or to copy them to other DataNodes, etc.

Specified by:

sendHeartbeat in interface DatanodeProtocol

Parameters:

registration - datanode registration information

reports - utilization report per storage

xmitsInProgress - number of transfers from this datanode to others

xceiverCount - number of active transceiver threads

failedVolumes - number of failed volumes

Throws:

IOException - on error

blockReport

public DatanodeCommand blockReport(DatanodeRegistration registration,
                          String poolId,
                          StorageBlockReport[] reports)
                            throws IOException

Description copied from interface: DatanodeProtocol

blockReport() tells the NameNode about all the locally-stored blocks. The NameNode returns an array of Blocks that have become obsolete and should be deleted. This function is meant to upload *all* the locally-stored blocks. It's invoked upon startup and then infrequently afterwards.

Specified by:

blockReport in interface DatanodeProtocol

poolId - - the block pool ID for the blocks

reports - - report of blocks per storage Each finalized block is represented as 3 longs. Each under- construction replica is represented as 4 longs. This is done instead of Block[] to reduce memory used by block reports.

Returns:

- the next command for DN to process.

Throws:

IOException

blockReceivedAndDeleted

public void blockReceivedAndDeleted(DatanodeRegistration registration,
                           String poolId,
                           StorageReceivedDeletedBlocks[] receivedAndDeletedBlocks)
                             throws IOException

Description copied from interface: DatanodeProtocol

blockReceivedAndDeleted() allows the DataNode to tell the NameNode about recently-received and -deleted block data. For the case of received blocks, a hint for preferred replica to be deleted when there is any excessive blocks is provided. For example, whenever client code writes a new Block here, or another DataNode copies a Block to this DataNode, it will call blockReceived().

Specified by:

blockReceivedAndDeleted in interface DatanodeProtocol

Throws:

IOException

errorReport

public void errorReport(DatanodeRegistration registration,
               int errorCode,
               String msg)
                 throws IOException

Description copied from interface: DatanodeProtocol

errorReport() tells the NameNode about something that has gone awry. Useful for debugging.

Specified by:

errorReport in interface DatanodeProtocol

Throws:

IOException

versionRequest

public NamespaceInfo versionRequest()
                             throws IOException

Specified by:

versionRequest in interface DatanodeProtocol

Throws:

IOException

reportBadBlocks

public void reportBadBlocks(LocatedBlock[] blocks)
                     throws IOException

Description copied from interface: DatanodeProtocol

same as ClientProtocol.reportBadBlocks(LocatedBlock[]) }

Specified by:

reportBadBlocks in interface DatanodeProtocol

Throws:

IOException

commitBlockSynchronization

public void commitBlockSynchronization(ExtendedBlock block,
                              long newgenerationstamp,
                              long newlength,
                              boolean closeFile,
                              boolean deleteblock,
                              DatanodeID[] newtargets,
                              String[] newtargetstorages)
                                throws IOException

Description copied from interface: DatanodeProtocol

Commit block synchronization in lease recovery

Specified by:

commitBlockSynchronization in interface DatanodeProtocol

Throws:

IOException

isMethodSupported

public boolean isMethodSupported(String methodName)
                          throws IOException

Description copied from interface: ProtocolMetaInterface

Checks whether the given method name is supported by the server. It is assumed that all method names are unique for a protocol.

Specified by:

isMethodSupported in interface ProtocolMetaInterface

Parameters:

methodName - The name of the method

Returns:

true if method is supported, otherwise false.

Throws:

IOException