import com.google.protos.ipc.invalidation.ClientProtocol.RegistrationSyncMessage; //导入依赖的package包/类
/** Returns whether {@code field} is present in {@code message}. */
@Override
@SuppressWarnings("unchecked")
public boolean hasField(MessageLite rawMessage, Descriptor field) {
  Preconditions.checkNotNull(rawMessage);
  Preconditions.checkNotNull(field);
  RegistrationSyncMessage message = (RegistrationSyncMessage) rawMessage;
  if (field == SUBTREE) {
    return message.getSubtreeCount() > 0;
  }
  throw new IllegalArgumentException("Bad descriptor: " + field);
}
 

import com.google.protos.ipc.invalidation.ClientProtocol.RegistrationSyncMessage; //导入依赖的package包/类
/** Returns the {@code field} from {@code message}. */
@Override
@SuppressWarnings("unchecked")
public Object getField(MessageLite rawMessage, Descriptor field) {
  Preconditions.checkNotNull(rawMessage);
  Preconditions.checkNotNull(field);
  RegistrationSyncMessage message = (RegistrationSyncMessage) rawMessage;
  if (field == SUBTREE) {
    return message.getSubtreeList();
  }
  throw new IllegalArgumentException("Bad descriptor: " + field);
}
 

import com.google.protos.ipc.invalidation.ClientProtocol.RegistrationSyncMessage; //导入依赖的package包/类
/** See spec in implementation notes. */
public static Object toLazyCompactString(final RegistrationSyncMessage syncMessage) {
  return LazyString.toLazyCompactString(syncMessage, new Receiver<TextBuilder>() {
    @Override
    public void accept(TextBuilder builder) {
      toCompactString(builder, syncMessage);
    }
  });
}
 

import com.google.protos.ipc.invalidation.ClientProtocol.RegistrationSyncMessage; //导入依赖的package包/类
/** See spec in implementation notes. */
public static TextBuilder toCompactString(TextBuilder builder,
    RegistrationSyncMessage syncMessage) {
  if (syncMessage == null) {
    return builder;
  }
  RegistrationSubtree subtree = syncMessage.getSubtree(0);
  builder.appendFormat("RegSyncMsg: Num regs: %d, Regs: ", subtree.getRegisteredObjectCount());
  toCompactStringForObjectIds(builder, subtree.getRegisteredObjectList());
  return builder;
}
 

import com.google.protos.ipc.invalidation.ClientProtocol.RegistrationSyncMessage; //导入依赖的package包/类
/**
 * Returns a builder for a {@link ClientToServerMessage} to be sent to the server. Crucially,
 * the builder does <b>NOT</b> include the message header.
 * @param hasClientToken whether the client currently holds a token
 */
ClientToServerMessage.Builder toBuilder(boolean hasClientToken) {
  ClientToServerMessage.Builder builder = ClientToServerMessage.newBuilder();
  if (pendingInitializeMessage != null) {
    statistics.recordSentMessage(SentMessageType.INITIALIZE);
    builder.setInitializeMessage(pendingInitializeMessage);
    pendingInitializeMessage = null;
  }

  // Note: Even if an initialize message is being sent, we can send additional
  // messages such as regisration messages, etc to the server. But if there is no token
  // and an initialize message is not being sent, we cannot send any other message.

  if (!hasClientToken && !builder.hasInitializeMessage()) {
    // Cannot send any message
    resources.getLogger().warning(
        "Cannot send message since no token and no initialize msg: %s", builder);
    statistics.recordError(ClientErrorType.TOKEN_MISSING_FAILURE);
    return null;
  }

  // Check for pending batched operations and add to message builder if needed.

  // Add reg, acks, reg subtrees - clear them after adding.
  if (!pendingAckedInvalidations.isEmpty()) {
    builder.setInvalidationAckMessage(createInvalidationAckMessage());
    statistics.recordSentMessage(SentMessageType.INVALIDATION_ACK);
  }

  // Check regs.
  if (!pendingRegistrations.isEmpty()) {
    builder.setRegistrationMessage(createRegistrationMessage());
    statistics.recordSentMessage(SentMessageType.REGISTRATION);
  }

  // Check reg substrees.
  if (!pendingRegSubtrees.isEmpty()) {
    for (ProtoWrapper<RegistrationSubtree> subtree : pendingRegSubtrees) {
      builder.setRegistrationSyncMessage(RegistrationSyncMessage.newBuilder()
          .addSubtree(subtree.getProto()));
    }
    pendingRegSubtrees.clear();
    statistics.recordSentMessage(SentMessageType.REGISTRATION_SYNC);
  }

  // Check if an info message has to be sent.
  if (pendingInfoMessage != null) {
    statistics.recordSentMessage(SentMessageType.INFO);
    builder.setInfoMessage(pendingInfoMessage);
    pendingInfoMessage = null;
  }
  return builder;
}
 

import com.google.protos.ipc.invalidation.ClientProtocol.RegistrationSyncMessage; //导入依赖的package包/类
public static RegistrationSyncMessage newRegistrationSyncMessage(
    List<RegistrationSubtree> subtrees) {
  return RegistrationSyncMessage.newBuilder().addAllSubtree(subtrees).build();
}