Function ParseTopicKey

be/src/scheduling/admission-controller.cc:325–340

Parses the topic key to separate the prefix that helps recognize the kind of update received.

// Parses the topic key to separate the prefix that helps recognize the kind of update
// received.
static inline bool ParseTopicKey(
    const string& topic_key, string* prefix, string* suffix) {
  // The prefix should always be present and the network address must be at least 3
  // characters (including ':' and if the hostname and port are each only 1 character).
  // Then the topic_key must be at least 8 characters (5 + 3).
  const int MIN_TOPIC_KEY_SIZE = 8;
  if (topic_key.length() < MIN_TOPIC_KEY_SIZE) {
    VLOG_QUERY << "Invalid topic key for pool: " << topic_key;
    return false;
  }
  DCHECK_EQ(TOPIC_KEY_POOL_PREFIX.size(), TOPIC_KEY_STAT_PREFIX.size())
      << "All admission topic key prefixes should be of the same size";
  *prefix = topic_key.substr(0, TOPIC_KEY_POOL_PREFIX.size());
  *suffix = topic_key.substr(TOPIC_KEY_POOL_PREFIX.size());
  return true;
}

// Parses the pool name and backend_id from the topic key if it is valid.
// Returns true if the topic key is valid and pool_name and backend_id are set.