org.apache.hadoop.hdfs.protocolPB

Class InterDatanodeProtocolTranslatorPB

java.lang.Object

org.apache.hadoop.hdfs.protocolPB.InterDatanodeProtocolTranslatorPB

All Implemented Interfaces:

Closeable, AutoCloseable, InterDatanodeProtocol, ProtocolMetaInterface

@InterfaceAudience.Private
@InterfaceStability.Stable
public class InterDatanodeProtocolTranslatorPB
extends Object
implements ProtocolMetaInterface, InterDatanodeProtocol, Closeable

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

Field Summary

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

LOG, versionID

Constructor Summary

Constructors

Constructor and Description
InterDatanodeProtocolTranslatorPB(InetSocketAddress addr, UserGroupInformation ugi, Configuration conf, SocketFactory factory, int socketTimeout)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
ReplicaRecoveryInfo	initReplicaRecovery(BlockRecoveryCommand.RecoveringBlock rBlock) Initialize a replica recovery.
boolean	isMethodSupported(String methodName) Checks whether the given method name is supported by the server.
String	updateReplicaUnderRecovery(ExtendedBlock oldBlock, long recoveryId, long newLength) Update replica with the new generation stamp and length.

Methods inherited from class java.lang.Object

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

Constructor Detail

InterDatanodeProtocolTranslatorPB

public InterDatanodeProtocolTranslatorPB(InetSocketAddress addr,
                                 UserGroupInformation ugi,
                                 Configuration conf,
                                 SocketFactory factory,
                                 int socketTimeout)
                                  throws IOException

Throws:

IOException

Method Detail

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

initReplicaRecovery

public ReplicaRecoveryInfo initReplicaRecovery(BlockRecoveryCommand.RecoveringBlock rBlock)
                                        throws IOException

Description copied from interface: InterDatanodeProtocol

Initialize a replica recovery.

Specified by:

initReplicaRecovery in interface InterDatanodeProtocol

Returns:

actual state of the replica on this data-node or null if data-node does not have the replica.

Throws:

IOException

updateReplicaUnderRecovery

public String updateReplicaUnderRecovery(ExtendedBlock oldBlock,
                                long recoveryId,
                                long newLength)
                                  throws IOException

Description copied from interface: InterDatanodeProtocol

Update replica with the new generation stamp and length.

Specified by:

updateReplicaUnderRecovery in interface InterDatanodeProtocol

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