import org.apache.hadoop.ipc.proto.GenericRefreshProtocolProtos.GenericRefreshResponseProto; //导入依赖的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.GenericRefreshResponseProto; //导入依赖的package包/类
private RefreshResponse unpack(GenericRefreshResponseProto proto) {
  // The default values
  String message = null;
  String sender = null;
  int returnCode = -1;

  // ... that can be overridden by data from the protobuf
  if (proto.hasUserMessage()) {
    message = proto.getUserMessage();
  }
  if (proto.hasExitStatus()) {
    returnCode = proto.getExitStatus();
  }
  if (proto.hasSenderName()) {
    sender = proto.getSenderName();
  }

  // ... and put into a RefreshResponse
  RefreshResponse response = new RefreshResponse(returnCode, message);
  response.setSenderName(sender);

  return response;
}