@Override public GetDatanodeStorageReportResponseProto getDatanodeStorageReport( RpcController controller, GetDatanodeStorageReportRequestProto req) throws ServiceException { try { List<DatanodeStorageReportProto> reports = PBHelper.convertDatanodeStorageReports( server.getDatanodeStorageReport(PBHelper.convert(req.getType()))); return GetDatanodeStorageReportResponseProto.newBuilder() .addAllDatanodeStorageReports(reports) .build(); } catch (IOException e) { throw new ServiceException(e); } }
@Override public DatanodeStorageReport[] getDatanodeStorageReport(DatanodeReportType type) throws IOException { final GetDatanodeStorageReportRequestProto req = GetDatanodeStorageReportRequestProto.newBuilder() .setType(PBHelper.convert(type)).build(); try { return PBHelper.convertDatanodeStorageReports( rpcProxy.getDatanodeStorageReport(null, req).getDatanodeStorageReportsList()); } catch (ServiceException e) { throw ProtobufHelper.getRemoteException(e); } }
@Override public DatanodeStorageReport[] getDatanodeStorageReport( DatanodeReportType type) throws IOException { final GetDatanodeStorageReportRequestProto req = GetDatanodeStorageReportRequestProto.newBuilder() .setType(PBHelperClient.convert(type)).build(); try { return PBHelperClient.convertDatanodeStorageReports( rpcProxy.getDatanodeStorageReport(null, req) .getDatanodeStorageReportsList()); } catch (ServiceException e) { throw ProtobufHelper.getRemoteException(e); } }
@Override public GetDatanodeStorageReportResponseProto getDatanodeStorageReport( RpcController controller, GetDatanodeStorageReportRequestProto req) throws ServiceException { try { List<DatanodeStorageReportProto> reports = PBHelperClient.convertDatanodeStorageReports( server.getDatanodeStorageReport(PBHelperClient.convert(req.getType()))); return GetDatanodeStorageReportResponseProto.newBuilder() .addAllDatanodeStorageReports(reports) .build(); } catch (IOException e) { throw new ServiceException(e); } }