Function ParsePoolTopicKey

be/src/scheduling/admission-controller.cc:344–355

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.

// 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.
static inline bool ParsePoolTopicKey(
    const string& topic_key, string* pool_name, string* backend_id) {
  // Pool topic keys will look something like: poolname!hostname:22000
  size_t pos = topic_key.find_last_of(TOPIC_KEY_DELIMITER);
  if (pos == string::npos || pos >= topic_key.size() - 1) {
    VLOG_QUERY << "Invalid topic key for pool: " << topic_key;
    return false;
  }
  *pool_name = topic_key.substr(0, pos);
  *backend_id = topic_key.substr(pos + 1);
  return true;
}

// Checks a query will exceed the admission service process memory limit.
// If the limit is exceeded, returns true and the 'rejection_reason'.