|
@@ -18,7 +18,6 @@
|
|
package org.apache.hadoop.hdfs.protocolPB;
|
|
package org.apache.hadoop.hdfs.protocolPB;
|
|
|
|
|
|
import java.io.IOException;
|
|
import java.io.IOException;
|
|
-import java.util.Arrays;
|
|
|
|
import java.util.List;
|
|
import java.util.List;
|
|
|
|
|
|
import org.apache.hadoop.classification.InterfaceAudience;
|
|
import org.apache.hadoop.classification.InterfaceAudience;
|
|
@@ -38,8 +37,6 @@ import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.AddBlo
|
|
import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.AddBlockResponseProto;
|
|
import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.AddBlockResponseProto;
|
|
import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.AppendRequestProto;
|
|
import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.AppendRequestProto;
|
|
import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.AppendResponseProto;
|
|
import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.AppendResponseProto;
|
|
-import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.CancelDelegationTokenRequestProto;
|
|
|
|
-import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.CancelDelegationTokenResponseProto;
|
|
|
|
import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.CompleteRequestProto;
|
|
import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.CompleteRequestProto;
|
|
import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.CompleteResponseProto;
|
|
import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.CompleteResponseProto;
|
|
import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.ConcatRequestProto;
|
|
import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.ConcatRequestProto;
|
|
@@ -65,8 +62,6 @@ import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.GetCon
|
|
import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.GetContentSummaryResponseProto;
|
|
import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.GetContentSummaryResponseProto;
|
|
import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.GetDatanodeReportRequestProto;
|
|
import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.GetDatanodeReportRequestProto;
|
|
import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.GetDatanodeReportResponseProto;
|
|
import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.GetDatanodeReportResponseProto;
|
|
-import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.GetDelegationTokenRequestProto;
|
|
|
|
-import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.GetDelegationTokenResponseProto;
|
|
|
|
import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.GetFileInfoRequestProto;
|
|
import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.GetFileInfoRequestProto;
|
|
import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.GetFileInfoResponseProto;
|
|
import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.GetFileInfoResponseProto;
|
|
import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.GetFileLinkInfoRequestProto;
|
|
import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.GetFileLinkInfoRequestProto;
|
|
@@ -95,8 +90,6 @@ import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.Rename
|
|
import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.Rename2ResponseProto;
|
|
import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.Rename2ResponseProto;
|
|
import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.RenameRequestProto;
|
|
import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.RenameRequestProto;
|
|
import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.RenameResponseProto;
|
|
import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.RenameResponseProto;
|
|
-import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.RenewDelegationTokenRequestProto;
|
|
|
|
-import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.RenewDelegationTokenResponseProto;
|
|
|
|
import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.RenewLeaseRequestProto;
|
|
import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.RenewLeaseRequestProto;
|
|
import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.RenewLeaseResponseProto;
|
|
import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.RenewLeaseResponseProto;
|
|
import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.ReportBadBlocksRequestProto;
|
|
import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.ReportBadBlocksRequestProto;
|
|
@@ -125,12 +118,19 @@ import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.Update
|
|
import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.UpdateBlockForPipelineResponseProto;
|
|
import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.UpdateBlockForPipelineResponseProto;
|
|
import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.UpdatePipelineRequestProto;
|
|
import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.UpdatePipelineRequestProto;
|
|
import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.UpdatePipelineResponseProto;
|
|
import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.UpdatePipelineResponseProto;
|
|
-import org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.BlockTokenIdentifierProto;
|
|
|
|
import org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DatanodeIDProto;
|
|
import org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DatanodeIDProto;
|
|
import org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DatanodeInfoProto;
|
|
import org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DatanodeInfoProto;
|
|
import org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.LocatedBlockProto;
|
|
import org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.LocatedBlockProto;
|
|
import org.apache.hadoop.hdfs.security.token.block.DataEncryptionKey;
|
|
import org.apache.hadoop.hdfs.security.token.block.DataEncryptionKey;
|
|
|
|
+import org.apache.hadoop.hdfs.security.token.delegation.DelegationTokenIdentifier;
|
|
import org.apache.hadoop.io.Text;
|
|
import org.apache.hadoop.io.Text;
|
|
|
|
+import org.apache.hadoop.security.proto.SecurityProtos.CancelDelegationTokenRequestProto;
|
|
|
|
+import org.apache.hadoop.security.proto.SecurityProtos.CancelDelegationTokenResponseProto;
|
|
|
|
+import org.apache.hadoop.security.proto.SecurityProtos.GetDelegationTokenRequestProto;
|
|
|
|
+import org.apache.hadoop.security.proto.SecurityProtos.GetDelegationTokenResponseProto;
|
|
|
|
+import org.apache.hadoop.security.proto.SecurityProtos.RenewDelegationTokenRequestProto;
|
|
|
|
+import org.apache.hadoop.security.proto.SecurityProtos.RenewDelegationTokenResponseProto;
|
|
|
|
+import org.apache.hadoop.security.token.Token;
|
|
|
|
|
|
import com.google.protobuf.RpcController;
|
|
import com.google.protobuf.RpcController;
|
|
import com.google.protobuf.ServiceException;
|
|
import com.google.protobuf.ServiceException;
|
|
@@ -148,6 +148,78 @@ public class ClientNamenodeProtocolServerSideTranslatorPB implements
|
|
ClientNamenodeProtocolPB {
|
|
ClientNamenodeProtocolPB {
|
|
final private ClientProtocol server;
|
|
final private ClientProtocol server;
|
|
|
|
|
|
|
|
+ private static final CreateResponseProto VOID_CREATE_RESPONSE =
|
|
|
|
+ CreateResponseProto.newBuilder().build();
|
|
|
|
+
|
|
|
|
+ private static final AppendResponseProto VOID_APPEND_RESPONSE =
|
|
|
|
+ AppendResponseProto.newBuilder().build();
|
|
|
|
+
|
|
|
|
+ private static final SetPermissionResponseProto VOID_SET_PERM_RESPONSE =
|
|
|
|
+ SetPermissionResponseProto.newBuilder().build();
|
|
|
|
+
|
|
|
|
+ private static final SetOwnerResponseProto VOID_SET_OWNER_RESPONSE =
|
|
|
|
+ SetOwnerResponseProto.newBuilder().build();
|
|
|
|
+
|
|
|
|
+ private static final AbandonBlockResponseProto VOID_ADD_BLOCK_RESPONSE =
|
|
|
|
+ AbandonBlockResponseProto.newBuilder().build();
|
|
|
|
+
|
|
|
|
+ private static final ReportBadBlocksResponseProto VOID_REP_BAD_BLOCK_RESPONSE =
|
|
|
|
+ ReportBadBlocksResponseProto.newBuilder().build();
|
|
|
|
+
|
|
|
|
+ private static final ConcatResponseProto VOID_CONCAT_RESPONSE =
|
|
|
|
+ ConcatResponseProto.newBuilder().build();
|
|
|
|
+
|
|
|
|
+ private static final Rename2ResponseProto VOID_RENAME2_RESPONSE =
|
|
|
|
+ Rename2ResponseProto.newBuilder().build();
|
|
|
|
+
|
|
|
|
+ private static final GetListingResponseProto VOID_GETLISTING_RESPONSE =
|
|
|
|
+ GetListingResponseProto.newBuilder().build();
|
|
|
|
+
|
|
|
|
+ private static final RenewLeaseResponseProto VOID_RENEWLEASE_RESPONSE =
|
|
|
|
+ RenewLeaseResponseProto.newBuilder().build();
|
|
|
|
+
|
|
|
|
+ private static final SaveNamespaceResponseProto VOID_SAVENAMESPACE_RESPONSE =
|
|
|
|
+ SaveNamespaceResponseProto.newBuilder().build();
|
|
|
|
+
|
|
|
|
+ private static final RefreshNodesResponseProto VOID_REFRESHNODES_RESPONSE =
|
|
|
|
+ RefreshNodesResponseProto.newBuilder().build();
|
|
|
|
+
|
|
|
|
+ private static final FinalizeUpgradeResponseProto VOID_FINALIZEUPGRADE_RESPONSE =
|
|
|
|
+ FinalizeUpgradeResponseProto.newBuilder().build();
|
|
|
|
+
|
|
|
|
+ private static final MetaSaveResponseProto VOID_METASAVE_RESPONSE =
|
|
|
|
+ MetaSaveResponseProto.newBuilder().build();
|
|
|
|
+
|
|
|
|
+ private static final GetFileInfoResponseProto VOID_GETFILEINFO_RESPONSE =
|
|
|
|
+ GetFileInfoResponseProto.newBuilder().build();
|
|
|
|
+
|
|
|
|
+ private static final GetFileLinkInfoResponseProto VOID_GETFILELINKINFO_RESPONSE =
|
|
|
|
+ GetFileLinkInfoResponseProto.newBuilder().build();
|
|
|
|
+
|
|
|
|
+ private static final SetQuotaResponseProto VOID_SETQUOTA_RESPONSE =
|
|
|
|
+ SetQuotaResponseProto.newBuilder().build();
|
|
|
|
+
|
|
|
|
+ private static final FsyncResponseProto VOID_FSYNC_RESPONSE =
|
|
|
|
+ FsyncResponseProto.newBuilder().build();
|
|
|
|
+
|
|
|
|
+ private static final SetTimesResponseProto VOID_SETTIMES_RESPONSE =
|
|
|
|
+ SetTimesResponseProto.newBuilder().build();
|
|
|
|
+
|
|
|
|
+ private static final CreateSymlinkResponseProto VOID_CREATESYMLINK_RESPONSE =
|
|
|
|
+ CreateSymlinkResponseProto.newBuilder().build();
|
|
|
|
+
|
|
|
|
+ private static final UpdatePipelineResponseProto
|
|
|
|
+ VOID_UPDATEPIPELINE_RESPONSE =
|
|
|
|
+ UpdatePipelineResponseProto.newBuilder().build();
|
|
|
|
+
|
|
|
|
+ private static final CancelDelegationTokenResponseProto
|
|
|
|
+ VOID_CANCELDELEGATIONTOKEN_RESPONSE =
|
|
|
|
+ CancelDelegationTokenResponseProto.newBuilder().build();
|
|
|
|
+
|
|
|
|
+ private static final SetBalancerBandwidthResponseProto
|
|
|
|
+ VOID_SETBALANCERBANDWIDTH_RESPONSE =
|
|
|
|
+ SetBalancerBandwidthResponseProto.newBuilder().build();
|
|
|
|
+
|
|
/**
|
|
/**
|
|
* Constructor
|
|
* Constructor
|
|
*
|
|
*
|
|
@@ -192,9 +264,6 @@ public class ClientNamenodeProtocolServerSideTranslatorPB implements
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
- static final CreateResponseProto VOID_CREATE_RESPONSE =
|
|
|
|
- CreateResponseProto.newBuilder().build();
|
|
|
|
-
|
|
|
|
@Override
|
|
@Override
|
|
public CreateResponseProto create(RpcController controller,
|
|
public CreateResponseProto create(RpcController controller,
|
|
CreateRequestProto req) throws ServiceException {
|
|
CreateRequestProto req) throws ServiceException {
|
|
@@ -209,9 +278,6 @@ public class ClientNamenodeProtocolServerSideTranslatorPB implements
|
|
return VOID_CREATE_RESPONSE;
|
|
return VOID_CREATE_RESPONSE;
|
|
}
|
|
}
|
|
|
|
|
|
- static final AppendResponseProto NULL_APPEND_RESPONSE =
|
|
|
|
- AppendResponseProto.newBuilder().build();
|
|
|
|
-
|
|
|
|
@Override
|
|
@Override
|
|
public AppendResponseProto append(RpcController controller,
|
|
public AppendResponseProto append(RpcController controller,
|
|
AppendRequestProto req) throws ServiceException {
|
|
AppendRequestProto req) throws ServiceException {
|
|
@@ -221,7 +287,7 @@ public class ClientNamenodeProtocolServerSideTranslatorPB implements
|
|
return AppendResponseProto.newBuilder()
|
|
return AppendResponseProto.newBuilder()
|
|
.setBlock(PBHelper.convert(result)).build();
|
|
.setBlock(PBHelper.convert(result)).build();
|
|
}
|
|
}
|
|
- return NULL_APPEND_RESPONSE;
|
|
|
|
|
|
+ return VOID_APPEND_RESPONSE;
|
|
} catch (IOException e) {
|
|
} catch (IOException e) {
|
|
throw new ServiceException(e);
|
|
throw new ServiceException(e);
|
|
}
|
|
}
|
|
@@ -240,9 +306,6 @@ public class ClientNamenodeProtocolServerSideTranslatorPB implements
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
- static final SetPermissionResponseProto VOID_SET_PERM_RESPONSE =
|
|
|
|
- SetPermissionResponseProto.newBuilder().build();
|
|
|
|
-
|
|
|
|
@Override
|
|
@Override
|
|
public SetPermissionResponseProto setPermission(RpcController controller,
|
|
public SetPermissionResponseProto setPermission(RpcController controller,
|
|
SetPermissionRequestProto req) throws ServiceException {
|
|
SetPermissionRequestProto req) throws ServiceException {
|
|
@@ -254,9 +317,6 @@ public class ClientNamenodeProtocolServerSideTranslatorPB implements
|
|
return VOID_SET_PERM_RESPONSE;
|
|
return VOID_SET_PERM_RESPONSE;
|
|
}
|
|
}
|
|
|
|
|
|
- static final SetOwnerResponseProto VOID_SET_OWNER_RESPONSE =
|
|
|
|
- SetOwnerResponseProto.newBuilder().build();
|
|
|
|
-
|
|
|
|
@Override
|
|
@Override
|
|
public SetOwnerResponseProto setOwner(RpcController controller,
|
|
public SetOwnerResponseProto setOwner(RpcController controller,
|
|
SetOwnerRequestProto req) throws ServiceException {
|
|
SetOwnerRequestProto req) throws ServiceException {
|
|
@@ -270,9 +330,6 @@ public class ClientNamenodeProtocolServerSideTranslatorPB implements
|
|
return VOID_SET_OWNER_RESPONSE;
|
|
return VOID_SET_OWNER_RESPONSE;
|
|
}
|
|
}
|
|
|
|
|
|
- static final AbandonBlockResponseProto VOID_ADD_BLOCK_RESPONSE =
|
|
|
|
- AbandonBlockResponseProto.newBuilder().build();
|
|
|
|
-
|
|
|
|
@Override
|
|
@Override
|
|
public AbandonBlockResponseProto abandonBlock(RpcController controller,
|
|
public AbandonBlockResponseProto abandonBlock(RpcController controller,
|
|
AbandonBlockRequestProto req) throws ServiceException {
|
|
AbandonBlockRequestProto req) throws ServiceException {
|
|
@@ -338,9 +395,6 @@ public class ClientNamenodeProtocolServerSideTranslatorPB implements
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
- static final ReportBadBlocksResponseProto VOID_REP_BAD_BLOCK_RESPONSE =
|
|
|
|
- ReportBadBlocksResponseProto.newBuilder().build();
|
|
|
|
-
|
|
|
|
@Override
|
|
@Override
|
|
public ReportBadBlocksResponseProto reportBadBlocks(RpcController controller,
|
|
public ReportBadBlocksResponseProto reportBadBlocks(RpcController controller,
|
|
ReportBadBlocksRequestProto req) throws ServiceException {
|
|
ReportBadBlocksRequestProto req) throws ServiceException {
|
|
@@ -354,9 +408,6 @@ public class ClientNamenodeProtocolServerSideTranslatorPB implements
|
|
return VOID_REP_BAD_BLOCK_RESPONSE;
|
|
return VOID_REP_BAD_BLOCK_RESPONSE;
|
|
}
|
|
}
|
|
|
|
|
|
- static final ConcatResponseProto VOID_CONCAT_RESPONSE =
|
|
|
|
- ConcatResponseProto.newBuilder().build();
|
|
|
|
-
|
|
|
|
@Override
|
|
@Override
|
|
public ConcatResponseProto concat(RpcController controller,
|
|
public ConcatResponseProto concat(RpcController controller,
|
|
ConcatRequestProto req) throws ServiceException {
|
|
ConcatRequestProto req) throws ServiceException {
|
|
@@ -380,9 +431,6 @@ public class ClientNamenodeProtocolServerSideTranslatorPB implements
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
- static final Rename2ResponseProto VOID_RENAME2_RESPONSE =
|
|
|
|
- Rename2ResponseProto.newBuilder().build();
|
|
|
|
-
|
|
|
|
@Override
|
|
@Override
|
|
public Rename2ResponseProto rename2(RpcController controller,
|
|
public Rename2ResponseProto rename2(RpcController controller,
|
|
Rename2RequestProto req) throws ServiceException {
|
|
Rename2RequestProto req) throws ServiceException {
|
|
@@ -419,8 +467,6 @@ public class ClientNamenodeProtocolServerSideTranslatorPB implements
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
- static final GetListingResponseProto NULL_GETLISTING_RESPONSE =
|
|
|
|
- GetListingResponseProto.newBuilder().build();
|
|
|
|
@Override
|
|
@Override
|
|
public GetListingResponseProto getListing(RpcController controller,
|
|
public GetListingResponseProto getListing(RpcController controller,
|
|
GetListingRequestProto req) throws ServiceException {
|
|
GetListingRequestProto req) throws ServiceException {
|
|
@@ -432,16 +478,13 @@ public class ClientNamenodeProtocolServerSideTranslatorPB implements
|
|
return GetListingResponseProto.newBuilder().setDirList(
|
|
return GetListingResponseProto.newBuilder().setDirList(
|
|
PBHelper.convert(result)).build();
|
|
PBHelper.convert(result)).build();
|
|
} else {
|
|
} else {
|
|
- return NULL_GETLISTING_RESPONSE;
|
|
|
|
|
|
+ return VOID_GETLISTING_RESPONSE;
|
|
}
|
|
}
|
|
} catch (IOException e) {
|
|
} catch (IOException e) {
|
|
throw new ServiceException(e);
|
|
throw new ServiceException(e);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
- static final RenewLeaseResponseProto VOID_RENEWLEASE_RESPONSE =
|
|
|
|
- RenewLeaseResponseProto.newBuilder().build();
|
|
|
|
-
|
|
|
|
@Override
|
|
@Override
|
|
public RenewLeaseResponseProto renewLease(RpcController controller,
|
|
public RenewLeaseResponseProto renewLease(RpcController controller,
|
|
RenewLeaseRequestProto req) throws ServiceException {
|
|
RenewLeaseRequestProto req) throws ServiceException {
|
|
@@ -492,10 +535,10 @@ public class ClientNamenodeProtocolServerSideTranslatorPB implements
|
|
RpcController controller, GetDatanodeReportRequestProto req)
|
|
RpcController controller, GetDatanodeReportRequestProto req)
|
|
throws ServiceException {
|
|
throws ServiceException {
|
|
try {
|
|
try {
|
|
- DatanodeInfoProto[] result = PBHelper.convert(server
|
|
|
|
|
|
+ List<? extends DatanodeInfoProto> result = PBHelper.convert(server
|
|
.getDatanodeReport(PBHelper.convert(req.getType())));
|
|
.getDatanodeReport(PBHelper.convert(req.getType())));
|
|
return GetDatanodeReportResponseProto.newBuilder()
|
|
return GetDatanodeReportResponseProto.newBuilder()
|
|
- .addAllDi(Arrays.asList(result)).build();
|
|
|
|
|
|
+ .addAllDi(result).build();
|
|
} catch (IOException e) {
|
|
} catch (IOException e) {
|
|
throw new ServiceException(e);
|
|
throw new ServiceException(e);
|
|
}
|
|
}
|
|
@@ -526,9 +569,6 @@ public class ClientNamenodeProtocolServerSideTranslatorPB implements
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
- static final SaveNamespaceResponseProto VOID_SAVENAMESPACE_RESPONSE =
|
|
|
|
- SaveNamespaceResponseProto.newBuilder().build();
|
|
|
|
-
|
|
|
|
@Override
|
|
@Override
|
|
public SaveNamespaceResponseProto saveNamespace(RpcController controller,
|
|
public SaveNamespaceResponseProto saveNamespace(RpcController controller,
|
|
SaveNamespaceRequestProto req) throws ServiceException {
|
|
SaveNamespaceRequestProto req) throws ServiceException {
|
|
@@ -555,9 +595,6 @@ public class ClientNamenodeProtocolServerSideTranslatorPB implements
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
- static final RefreshNodesResponseProto VOID_REFRESHNODES_RESPONSE =
|
|
|
|
- RefreshNodesResponseProto.newBuilder().build();
|
|
|
|
-
|
|
|
|
@Override
|
|
@Override
|
|
public RefreshNodesResponseProto refreshNodes(RpcController controller,
|
|
public RefreshNodesResponseProto refreshNodes(RpcController controller,
|
|
RefreshNodesRequestProto req) throws ServiceException {
|
|
RefreshNodesRequestProto req) throws ServiceException {
|
|
@@ -570,9 +607,6 @@ public class ClientNamenodeProtocolServerSideTranslatorPB implements
|
|
|
|
|
|
}
|
|
}
|
|
|
|
|
|
- static final FinalizeUpgradeResponseProto VOID_FINALIZEUPGRADE_RESPONSE =
|
|
|
|
- FinalizeUpgradeResponseProto.newBuilder().build();
|
|
|
|
-
|
|
|
|
@Override
|
|
@Override
|
|
public FinalizeUpgradeResponseProto finalizeUpgrade(RpcController controller,
|
|
public FinalizeUpgradeResponseProto finalizeUpgrade(RpcController controller,
|
|
FinalizeUpgradeRequestProto req) throws ServiceException {
|
|
FinalizeUpgradeRequestProto req) throws ServiceException {
|
|
@@ -599,9 +633,6 @@ public class ClientNamenodeProtocolServerSideTranslatorPB implements
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
- static final MetaSaveResponseProto VOID_METASAVE_RESPONSE =
|
|
|
|
- MetaSaveResponseProto.newBuilder().build();
|
|
|
|
-
|
|
|
|
@Override
|
|
@Override
|
|
public MetaSaveResponseProto metaSave(RpcController controller,
|
|
public MetaSaveResponseProto metaSave(RpcController controller,
|
|
MetaSaveRequestProto req) throws ServiceException {
|
|
MetaSaveRequestProto req) throws ServiceException {
|
|
@@ -614,8 +645,6 @@ public class ClientNamenodeProtocolServerSideTranslatorPB implements
|
|
|
|
|
|
}
|
|
}
|
|
|
|
|
|
- static final GetFileInfoResponseProto NULL_GETFILEINFO_RESPONSE =
|
|
|
|
- GetFileInfoResponseProto.newBuilder().build();
|
|
|
|
@Override
|
|
@Override
|
|
public GetFileInfoResponseProto getFileInfo(RpcController controller,
|
|
public GetFileInfoResponseProto getFileInfo(RpcController controller,
|
|
GetFileInfoRequestProto req) throws ServiceException {
|
|
GetFileInfoRequestProto req) throws ServiceException {
|
|
@@ -626,14 +655,12 @@ public class ClientNamenodeProtocolServerSideTranslatorPB implements
|
|
return GetFileInfoResponseProto.newBuilder().setFs(
|
|
return GetFileInfoResponseProto.newBuilder().setFs(
|
|
PBHelper.convert(result)).build();
|
|
PBHelper.convert(result)).build();
|
|
}
|
|
}
|
|
- return NULL_GETFILEINFO_RESPONSE;
|
|
|
|
|
|
+ return VOID_GETFILEINFO_RESPONSE;
|
|
} catch (IOException e) {
|
|
} catch (IOException e) {
|
|
throw new ServiceException(e);
|
|
throw new ServiceException(e);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
- static final GetFileLinkInfoResponseProto NULL_GETFILELINKINFO_RESPONSE =
|
|
|
|
- GetFileLinkInfoResponseProto.newBuilder().build();
|
|
|
|
@Override
|
|
@Override
|
|
public GetFileLinkInfoResponseProto getFileLinkInfo(RpcController controller,
|
|
public GetFileLinkInfoResponseProto getFileLinkInfo(RpcController controller,
|
|
GetFileLinkInfoRequestProto req) throws ServiceException {
|
|
GetFileLinkInfoRequestProto req) throws ServiceException {
|
|
@@ -645,7 +672,7 @@ public class ClientNamenodeProtocolServerSideTranslatorPB implements
|
|
PBHelper.convert(result)).build();
|
|
PBHelper.convert(result)).build();
|
|
} else {
|
|
} else {
|
|
System.out.println("got null result for getFileLinkInfo for " + req.getSrc());
|
|
System.out.println("got null result for getFileLinkInfo for " + req.getSrc());
|
|
- return NULL_GETFILELINKINFO_RESPONSE;
|
|
|
|
|
|
+ return VOID_GETFILELINKINFO_RESPONSE;
|
|
}
|
|
}
|
|
|
|
|
|
} catch (IOException e) {
|
|
} catch (IOException e) {
|
|
@@ -666,9 +693,6 @@ public class ClientNamenodeProtocolServerSideTranslatorPB implements
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
- static final SetQuotaResponseProto VOID_SETQUOTA_RESPONSE =
|
|
|
|
- SetQuotaResponseProto.newBuilder().build();
|
|
|
|
-
|
|
|
|
@Override
|
|
@Override
|
|
public SetQuotaResponseProto setQuota(RpcController controller,
|
|
public SetQuotaResponseProto setQuota(RpcController controller,
|
|
SetQuotaRequestProto req) throws ServiceException {
|
|
SetQuotaRequestProto req) throws ServiceException {
|
|
@@ -681,9 +705,6 @@ public class ClientNamenodeProtocolServerSideTranslatorPB implements
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
- static final FsyncResponseProto VOID_FSYNC_RESPONSE =
|
|
|
|
- FsyncResponseProto.newBuilder().build();
|
|
|
|
-
|
|
|
|
@Override
|
|
@Override
|
|
public FsyncResponseProto fsync(RpcController controller,
|
|
public FsyncResponseProto fsync(RpcController controller,
|
|
FsyncRequestProto req) throws ServiceException {
|
|
FsyncRequestProto req) throws ServiceException {
|
|
@@ -695,9 +716,6 @@ public class ClientNamenodeProtocolServerSideTranslatorPB implements
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
- static final SetTimesResponseProto VOID_SETTIMES_RESPONSE =
|
|
|
|
- SetTimesResponseProto.newBuilder().build();
|
|
|
|
-
|
|
|
|
@Override
|
|
@Override
|
|
public SetTimesResponseProto setTimes(RpcController controller,
|
|
public SetTimesResponseProto setTimes(RpcController controller,
|
|
SetTimesRequestProto req) throws ServiceException {
|
|
SetTimesRequestProto req) throws ServiceException {
|
|
@@ -709,9 +727,6 @@ public class ClientNamenodeProtocolServerSideTranslatorPB implements
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
- static final CreateSymlinkResponseProto VOID_CREATESYMLINK_RESPONSE =
|
|
|
|
- CreateSymlinkResponseProto.newBuilder().build();
|
|
|
|
-
|
|
|
|
@Override
|
|
@Override
|
|
public CreateSymlinkResponseProto createSymlink(RpcController controller,
|
|
public CreateSymlinkResponseProto createSymlink(RpcController controller,
|
|
CreateSymlinkRequestProto req) throws ServiceException {
|
|
CreateSymlinkRequestProto req) throws ServiceException {
|
|
@@ -729,8 +744,12 @@ public class ClientNamenodeProtocolServerSideTranslatorPB implements
|
|
GetLinkTargetRequestProto req) throws ServiceException {
|
|
GetLinkTargetRequestProto req) throws ServiceException {
|
|
try {
|
|
try {
|
|
String result = server.getLinkTarget(req.getPath());
|
|
String result = server.getLinkTarget(req.getPath());
|
|
- return GetLinkTargetResponseProto.newBuilder().setTargetPath(result)
|
|
|
|
- .build();
|
|
|
|
|
|
+ GetLinkTargetResponseProto.Builder builder = GetLinkTargetResponseProto
|
|
|
|
+ .newBuilder();
|
|
|
|
+ if (result != null) {
|
|
|
|
+ builder.setTargetPath(result);
|
|
|
|
+ }
|
|
|
|
+ return builder.build();
|
|
} catch (IOException e) {
|
|
} catch (IOException e) {
|
|
throw new ServiceException(e);
|
|
throw new ServiceException(e);
|
|
}
|
|
}
|
|
@@ -751,9 +770,6 @@ public class ClientNamenodeProtocolServerSideTranslatorPB implements
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
- static final UpdatePipelineResponseProto VOID_UPDATEPIPELINE_RESPONSE =
|
|
|
|
- UpdatePipelineResponseProto.newBuilder().build();
|
|
|
|
-
|
|
|
|
@Override
|
|
@Override
|
|
public UpdatePipelineResponseProto updatePipeline(RpcController controller,
|
|
public UpdatePipelineResponseProto updatePipeline(RpcController controller,
|
|
UpdatePipelineRequestProto req) throws ServiceException {
|
|
UpdatePipelineRequestProto req) throws ServiceException {
|
|
@@ -774,10 +790,14 @@ public class ClientNamenodeProtocolServerSideTranslatorPB implements
|
|
RpcController controller, GetDelegationTokenRequestProto req)
|
|
RpcController controller, GetDelegationTokenRequestProto req)
|
|
throws ServiceException {
|
|
throws ServiceException {
|
|
try {
|
|
try {
|
|
- BlockTokenIdentifierProto result = PBHelper.convert(server
|
|
|
|
- .getDelegationToken(new Text(req.getRenewer())));
|
|
|
|
- return GetDelegationTokenResponseProto.newBuilder().setToken(result)
|
|
|
|
- .build();
|
|
|
|
|
|
+ Token<DelegationTokenIdentifier> token = server
|
|
|
|
+ .getDelegationToken(new Text(req.getRenewer()));
|
|
|
|
+ GetDelegationTokenResponseProto.Builder rspBuilder =
|
|
|
|
+ GetDelegationTokenResponseProto.newBuilder();
|
|
|
|
+ if (token != null) {
|
|
|
|
+ rspBuilder.setToken(PBHelper.convert(token));
|
|
|
|
+ }
|
|
|
|
+ return rspBuilder.build();
|
|
} catch (IOException e) {
|
|
} catch (IOException e) {
|
|
throw new ServiceException(e);
|
|
throw new ServiceException(e);
|
|
}
|
|
}
|
|
@@ -791,16 +811,12 @@ public class ClientNamenodeProtocolServerSideTranslatorPB implements
|
|
long result = server.renewDelegationToken(PBHelper
|
|
long result = server.renewDelegationToken(PBHelper
|
|
.convertDelegationToken(req.getToken()));
|
|
.convertDelegationToken(req.getToken()));
|
|
return RenewDelegationTokenResponseProto.newBuilder()
|
|
return RenewDelegationTokenResponseProto.newBuilder()
|
|
- .setNewExireTime(result).build();
|
|
|
|
|
|
+ .setNewExpiryTime(result).build();
|
|
} catch (IOException e) {
|
|
} catch (IOException e) {
|
|
throw new ServiceException(e);
|
|
throw new ServiceException(e);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
- static final CancelDelegationTokenResponseProto
|
|
|
|
- VOID_CANCELDELEGATIONTOKEN_RESPONSE =
|
|
|
|
- CancelDelegationTokenResponseProto.newBuilder().build();
|
|
|
|
-
|
|
|
|
@Override
|
|
@Override
|
|
public CancelDelegationTokenResponseProto cancelDelegationToken(
|
|
public CancelDelegationTokenResponseProto cancelDelegationToken(
|
|
RpcController controller, CancelDelegationTokenRequestProto req)
|
|
RpcController controller, CancelDelegationTokenRequestProto req)
|
|
@@ -814,10 +830,6 @@ public class ClientNamenodeProtocolServerSideTranslatorPB implements
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
- static final SetBalancerBandwidthResponseProto
|
|
|
|
- VOID_SETBALANCERBANDWIDTH_RESPONSE =
|
|
|
|
- SetBalancerBandwidthResponseProto.newBuilder().build();
|
|
|
|
-
|
|
|
|
@Override
|
|
@Override
|
|
public SetBalancerBandwidthResponseProto setBalancerBandwidth(
|
|
public SetBalancerBandwidthResponseProto setBalancerBandwidth(
|
|
RpcController controller, SetBalancerBandwidthRequestProto req)
|
|
RpcController controller, SetBalancerBandwidthRequestProto req)
|
|
@@ -835,10 +847,13 @@ public class ClientNamenodeProtocolServerSideTranslatorPB implements
|
|
RpcController controller, GetDataEncryptionKeyRequestProto request)
|
|
RpcController controller, GetDataEncryptionKeyRequestProto request)
|
|
throws ServiceException {
|
|
throws ServiceException {
|
|
try {
|
|
try {
|
|
|
|
+ GetDataEncryptionKeyResponseProto.Builder builder =
|
|
|
|
+ GetDataEncryptionKeyResponseProto.newBuilder();
|
|
DataEncryptionKey encryptionKey = server.getDataEncryptionKey();
|
|
DataEncryptionKey encryptionKey = server.getDataEncryptionKey();
|
|
- return GetDataEncryptionKeyResponseProto.newBuilder()
|
|
|
|
- .setDataEncryptionKey(PBHelper.convert(encryptionKey))
|
|
|
|
- .build();
|
|
|
|
|
|
+ if (encryptionKey != null) {
|
|
|
|
+ builder.setDataEncryptionKey(PBHelper.convert(encryptionKey));
|
|
|
|
+ }
|
|
|
|
+ return builder.build();
|
|
} catch (IOException e) {
|
|
} catch (IOException e) {
|
|
throw new ServiceException(e);
|
|
throw new ServiceException(e);
|
|
}
|
|
}
|