import com.google.protos.ipc.invalidation.JavaClient.BatcherState; //导入依赖的package包/类
/** Creates a batcher from {@code marshalledState}. */
Batcher(SystemResources resources, Statistics statistics, BatcherState marshalledState) {
  this(resources, statistics);
  for (ObjectIdP registration : marshalledState.getRegistrationList()) {
    pendingRegistrations.put(ProtoWrapper.of(registration), RegistrationP.OpType.REGISTER);
  }
  for (ObjectIdP unregistration : marshalledState.getUnregistrationList()) {
    pendingRegistrations.put(ProtoWrapper.of(unregistration), RegistrationP.OpType.UNREGISTER);
  }
  for (InvalidationP ack : marshalledState.getAcknowledgementList()) {
    pendingAckedInvalidations.add(ProtoWrapper.of(ack));
  }
  for (RegistrationSubtree subtree : marshalledState.getRegistrationSubtreeList()) {
    pendingRegSubtrees.add(ProtoWrapper.of(subtree));
  }
  if (marshalledState.hasInitializeMessage()) {
    pendingInitializeMessage = marshalledState.getInitializeMessage();
  }
  if (marshalledState.hasInfoMessage()) {
    pendingInfoMessage = marshalledState.getInfoMessage();
  }
}
 

import com.google.protos.ipc.invalidation.JavaClient.BatcherState; //导入依赖的package包/类
@Override
public BatcherState marshal() {
  BatcherState.Builder builder = BatcherState.newBuilder();

  // Marshall (un)registrations.
  for (Map.Entry<ProtoWrapper<ObjectIdP>, RegistrationP.OpType> entry :
      pendingRegistrations.entrySet()) {
    OpType opType = entry.getValue();
    ObjectIdP oid = entry.getKey().getProto();
    switch (opType) {
      case REGISTER:
        builder.addRegistration(oid);
        break;
      case UNREGISTER:
        builder.addUnregistration(oid);
        break;
      default:
        throw new IllegalArgumentException(opType.toString());
    }
  }

  // Marshall acks.
  for (ProtoWrapper<InvalidationP> ack : pendingAckedInvalidations) {
    builder.addAcknowledgement(ack.getProto());
  }

  // Marshall registration subtrees.
  for (ProtoWrapper<RegistrationSubtree> subtree : pendingRegSubtrees) {
    builder.addRegistrationSubtree(subtree.getProto());
  }

  // Marshall initialize and info messages if present.
  if (pendingInitializeMessage != null) {
    builder.setInitializeMessage(pendingInitializeMessage);
  }
  if (pendingInfoMessage != null) {
    builder.setInfoMessage(pendingInfoMessage);
  }
  return builder.build();
}