import com.google.protos.ipc.invalidation.ClientProtocol.InfoMessage; //导入依赖的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);
  InfoMessage message = (InfoMessage) rawMessage;
  if (field == CLIENT_VERSION) {
    return message.hasClientVersion();
  }
  if (field == CONFIG_PARAMETER) {
    return message.getConfigParameterCount() > 0;
  }
  if (field == PERFORMANCE_COUNTER) {
    return message.getPerformanceCounterCount() > 0;
  }
  if (field == SERVER_REGISTRATION_SUMMARY_REQUESTED) {
    return message.hasServerRegistrationSummaryRequested();
  }
  if (field == CLIENT_CONFIG) {
    return message.hasClientConfig();
  }
  throw new IllegalArgumentException("Bad descriptor: " + field);
}
 

import com.google.protos.ipc.invalidation.ClientProtocol.InfoMessage; //导入依赖的package包/类
/** Returns the {@code field} from {@code message}. */
@Override
@SuppressWarnings("unchecked")
public Object getField(MessageLite rawMessage, Descriptor field) {
  Preconditions.checkNotNull(rawMessage);
  Preconditions.checkNotNull(field);
  InfoMessage message = (InfoMessage) rawMessage;
  if (field == CLIENT_VERSION) {
    return message.getClientVersion();
  }
  if (field == CONFIG_PARAMETER) {
    return message.getConfigParameterList();
  }
  if (field == PERFORMANCE_COUNTER) {
    return message.getPerformanceCounterList();
  }
  if (field == SERVER_REGISTRATION_SUMMARY_REQUESTED) {
    return message.getServerRegistrationSummaryRequested();
  }
  if (field == CLIENT_CONFIG) {
    return message.getClientConfig();
  }
  throw new IllegalArgumentException("Bad descriptor: " + field);
}
 

import com.google.protos.ipc.invalidation.ClientProtocol.InfoMessage; //导入依赖的package包/类
/** See spec in implementation notes. */
public static TextBuilder toCompactString(TextBuilder builder,
    InfoMessage infoMessage) {
  if (infoMessage == null) {
    return builder;
  }
  builder.appendFormat("InfoMsg: Platform = %s, Is_summary_requested = %s, Perf counters: ",
      infoMessage.getClientVersion().getPlatform(),
      infoMessage.getServerRegistrationSummaryRequested());
  boolean first = true;
  for (PropertyRecord record : infoMessage.getPerformanceCounterList()) {
    if (!first) {
      builder.append(", ");
    }
    builder.appendFormat("%s = %d", record.getName(), record.getValue());
    first = false;
  }
  return builder;
}
 

import com.google.protos.ipc.invalidation.ClientProtocol.InfoMessage; //导入依赖的package包/类
/**
 * Sends an info message to the server with the performance counters supplied
 * in {@code performanceCounters} and the config supplies in
 * {@code configParams}.
 *
 * @param requestServerRegistrationSummary indicates whether to request the
 *        server's registration summary
 */
void sendInfoMessage(List<SimplePair<String, Integer>> performanceCounters,
    ClientConfigP clientConfig, boolean requestServerRegistrationSummary,
    BatchingTask batchingTask) {
  Preconditions.checkState(internalScheduler.isRunningOnThread(), "Not on internal thread");
  InfoMessage.Builder infoMessage = InfoMessage.newBuilder()
      .setClientVersion(clientVersion);

  // Add configuration parameters.
  if (clientConfig != null) {
    infoMessage.setClientConfig(clientConfig);
  }

  // Add performance counters.
  for (SimplePair<String, Integer> performanceCounter : performanceCounters) {
    PropertyRecord counter =
        CommonProtos2.newPropertyRecord(performanceCounter.first, performanceCounter.second);
    infoMessage.addPerformanceCounter(counter);
  }

  // Indicate whether we want the server's registration summary sent back.
  infoMessage.setServerRegistrationSummaryRequested(requestServerRegistrationSummary);

  // Simply store the message in pendingInfoMessage and send it when the batching task runs.
  batcher.setInfoMessage(infoMessage.build());
  batchingTask.ensureScheduled("Send-info");
}
 

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

import com.google.protos.ipc.invalidation.ClientProtocol.InfoMessage; //导入依赖的package包/类
/** Sets the info message to be sent. */
void setInfoMessage(InfoMessage msg) {
  pendingInfoMessage = msg;
}