Package org.apache.hadoop.hdfs.protocolPB

Class InterDatanodeProtocolTranslatorPB

java.lang.Object

org.apache.hadoop.hdfs.protocolPB.InterDatanodeProtocolTranslatorPB

All Implemented Interfaces:

Closeable, AutoCloseable, InterDatanodeProtocol, org.apache.hadoop.ipc.ProtocolMetaInterface

@Private
@Stable
public class InterDatanodeProtocolTranslatorPB
extends Object
implements org.apache.hadoop.ipc.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	Description
InterDatanodeProtocolTranslatorPB(InetSocketAddress addr, org.apache.hadoop.security.UserGroupInformation ugi, org.apache.hadoop.conf.Configuration conf, SocketFactory factory, int socketTimeout)

Method Summary

Modifier and Type	Method	Description
void	close()
ReplicaRecoveryInfo	initReplicaRecovery(BlockRecoveryCommand.RecoveringBlock rBlock)	Initialize a replica recovery.
boolean	isMethodSupported(String methodName)
String	updateReplicaUnderRecovery(org.apache.hadoop.hdfs.protocol.ExtendedBlock oldBlock, long recoveryId, long newBlockId, 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 Details

InterDatanodeProtocolTranslatorPB

public InterDatanodeProtocolTranslatorPB(InetSocketAddress addr,
 org.apache.hadoop.security.UserGroupInformation ugi,
 org.apache.hadoop.conf.Configuration conf,
 SocketFactory factory,
 int socketTimeout)
                                  throws IOException

Throws:

IOException

Method Details

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

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(org.apache.hadoop.hdfs.protocol.ExtendedBlock oldBlock,
 long recoveryId,
 long newBlockId,
 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

Specified by:

isMethodSupported in interface org.apache.hadoop.ipc.ProtocolMetaInterface

Throws:

IOException