@Override public GetXAttrsResponseProto getXAttrs(RpcController controller, GetXAttrsRequestProto req) throws ServiceException { try { return PBHelper.convertXAttrsResponse(server.getXAttrs(req.getSrc(), PBHelper.convertXAttrs(req.getXAttrsList()))); } catch (IOException e) { throw new ServiceException(e); } }
@Override public List<XAttr> getXAttrs(String src, List<XAttr> xAttrs) throws IOException { GetXAttrsRequestProto.Builder builder = GetXAttrsRequestProto.newBuilder(); builder.setSrc(src); if (xAttrs != null) { builder.addAllXAttrs(PBHelper.convertXAttrProto(xAttrs)); } GetXAttrsRequestProto req = builder.build(); try { return PBHelper.convert(rpcProxy.getXAttrs(null, req)); } catch (ServiceException e) { throw ProtobufHelper.getRemoteException(e); } }
@Override public List<XAttr> getXAttrs(String src, List<XAttr> xAttrs) throws IOException { GetXAttrsRequestProto.Builder builder = GetXAttrsRequestProto.newBuilder(); builder.setSrc(src); if (xAttrs != null) { builder.addAllXAttrs(PBHelperClient.convertXAttrProto(xAttrs)); } GetXAttrsRequestProto req = builder.build(); try { return PBHelperClient.convert(rpcProxy.getXAttrs(null, req)); } catch (ServiceException e) { throw ProtobufHelper.getRemoteException(e); } }
@Override public GetXAttrsResponseProto getXAttrs(RpcController controller, GetXAttrsRequestProto req) throws ServiceException { try { return PBHelperClient.convertXAttrsResponse(server.getXAttrs(req.getSrc(), PBHelperClient.convertXAttrs(req.getXAttrsList()))); } catch (IOException e) { throw new ServiceException(e); } }