import org.apache.hadoop.ipc.proto.GenericRefreshProtocolProtos.GenericRefreshResponseCollectionProto; //导入依赖的package包/类
@Override
public GenericRefreshResponseCollectionProto refresh(
    RpcController controller, GenericRefreshRequestProto request)
    throws ServiceException {
  try {
    List<String> argList = request.getArgsList();
    String[] args = argList.toArray(new String[argList.size()]);

    if (!request.hasIdentifier()) {
      throw new ServiceException("Request must contain identifier");
    }

    Collection<RefreshResponse> results = impl.refresh(request.getIdentifier(), args);

    return pack(results);
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}
 

import org.apache.hadoop.ipc.proto.GenericRefreshProtocolProtos.GenericRefreshResponseCollectionProto; //导入依赖的package包/类
private GenericRefreshResponseCollectionProto pack(
  Collection<RefreshResponse> responses) {
  GenericRefreshResponseCollectionProto.Builder b =
    GenericRefreshResponseCollectionProto.newBuilder();

  for (RefreshResponse response : responses) {
    GenericRefreshResponseProto.Builder respBuilder =
      GenericRefreshResponseProto.newBuilder();
    respBuilder.setExitStatus(response.getReturnCode());
    respBuilder.setUserMessage(response.getMessage());
    respBuilder.setSenderName(response.getSenderName());

    // Add to collection
    b.addResponses(respBuilder);
  }

  return b.build();
}
 

import org.apache.hadoop.ipc.proto.GenericRefreshProtocolProtos.GenericRefreshResponseCollectionProto; //导入依赖的package包/类
@Override
public Collection<RefreshResponse> refresh(String identifier, String[] args) throws IOException {
  List<String> argList = Arrays.asList(args);

  try {
    GenericRefreshRequestProto request = GenericRefreshRequestProto.newBuilder()
      .setIdentifier(identifier)
      .addAllArgs(argList)
      .build();

    GenericRefreshResponseCollectionProto resp = rpcProxy.refresh(NULL_CONTROLLER, request);
    return unpack(resp);
  } catch (ServiceException se) {
    throw ProtobufHelper.getRemoteException(se);
  }
}
 

import org.apache.hadoop.ipc.proto.GenericRefreshProtocolProtos.GenericRefreshResponseCollectionProto; //导入依赖的package包/类
private Collection<RefreshResponse> unpack(GenericRefreshResponseCollectionProto collection) {
  List<GenericRefreshResponseProto> responseProtos = collection.getResponsesList();
  List<RefreshResponse> responses = new ArrayList<RefreshResponse>();

  for (GenericRefreshResponseProto rp : responseProtos) {
    RefreshResponse response = unpack(rp);
    responses.add(response);
  }

  return responses;
}