@Override public void setQuota(String path, long namespaceQuota, long storagespaceQuota, StorageType type) throws AccessControlException, FileNotFoundException, UnresolvedLinkException, IOException { final SetQuotaRequestProto.Builder builder = SetQuotaRequestProto.newBuilder() .setPath(path) .setNamespaceQuota(namespaceQuota) .setStoragespaceQuota(storagespaceQuota); if (type != null) { builder.setStorageType(PBHelper.convertStorageType(type)); } final SetQuotaRequestProto req = builder.build(); try { rpcProxy.setQuota(null, req); } catch (ServiceException e) { throw ProtobufHelper.getRemoteException(e); } }
@Override public void setQuota(String path, long namespaceQuota, long storagespaceQuota, StorageType type) throws IOException { final SetQuotaRequestProto.Builder builder = SetQuotaRequestProto.newBuilder() .setPath(path) .setNamespaceQuota(namespaceQuota) .setStoragespaceQuota(storagespaceQuota); if (type != null) { builder.setStorageType(PBHelperClient.convertStorageType(type)); } final SetQuotaRequestProto req = builder.build(); try { rpcProxy.setQuota(null, req); } catch (ServiceException e) { throw ProtobufHelper.getRemoteException(e); } }
@Override public SetQuotaResponseProto setQuota(RpcController controller, SetQuotaRequestProto req) throws ServiceException { try { server.setQuota(req.getPath(), req.getNamespaceQuota(), req.getStoragespaceQuota(), req.hasStorageType() ? PBHelper.convertStorageType(req.getStorageType()): null); return VOID_SETQUOTA_RESPONSE; } catch (IOException e) { throw new ServiceException(e); } }
@Override public SetQuotaResponseProto setQuota(RpcController controller, SetQuotaRequestProto req) throws ServiceException { try { server.setQuota(req.getPath(), req.getNamespaceQuota(), req.getStoragespaceQuota(), req.hasStorageType() ? PBHelperClient.convertStorageType(req.getStorageType()): null); return VOID_SETQUOTA_RESPONSE; } catch (IOException e) { throw new ServiceException(e); } }
@Override public SetQuotaResponseProto setQuota(RpcController controller, SetQuotaRequestProto req) throws ServiceException { try { server.setQuota(req.getPath(), req.getNamespaceQuota(), req.getDiskspaceQuota()); return VOID_SETQUOTA_RESPONSE; } catch (IOException e) { throw new ServiceException(e); } }
@Override public void setQuota(String path, long namespaceQuota, long diskspaceQuota) throws AccessControlException, FileNotFoundException, UnresolvedLinkException, IOException { SetQuotaRequestProto req = SetQuotaRequestProto.newBuilder() .setPath(path) .setNamespaceQuota(namespaceQuota) .setDiskspaceQuota(diskspaceQuota) .build(); try { rpcProxy.setQuota(null, req); } catch (ServiceException e) { throw ProtobufHelper.getRemoteException(e); } }
@Override public void setQuota(String path, long namespaceQuota, long diskspaceQuota) throws AccessControlException, FileNotFoundException, UnresolvedLinkException, IOException { SetQuotaRequestProto req = SetQuotaRequestProto.newBuilder().setPath(path) .setNamespaceQuota(namespaceQuota).setDiskspaceQuota(diskspaceQuota) .build(); try { rpcProxy.setQuota(null, req); } catch (ServiceException e) { throw ProtobufHelper.getRemoteException(e); } }