Function RecLookupMatchingRecords

src/records/RecCore.cc:549–596

}

RecErrT
RecLookupMatchingRecords(unsigned rec_type, const char *match, void (*callback)(const RecRecord *, void *), void *data,
                         bool /* lock ATS_UNUSED */)
{
  int num_records;
  DFA regex;

  if (!regex.compile(match, RE_CASE_INSENSITIVE | RE_UNANCHORED)) {
    return REC_ERR_FAIL;
  }

  if ((rec_type & (RECT_PROCESS | RECT_NODE | RECT_PLUGIN))) {
    // First find the new metrics, this is a bit of a hack, because we still use the old
    // librecords callback with a "pseudo" record.
    RecRecord tmp;

    tmp.rec_type  = RECT_PROCESS;
    tmp.data_type = RECD_INT;

    for (auto &&[name, val] : ts::Metrics::instance()) {
      if (regex.match(name.data()) >= 0) {
        tmp.name         = name.data();
        tmp.data.rec_int = val;
        callback(&tmp, data);
      }
    }
    // Fall through to return any matching string metrics
  }

  num_records = g_num_records;
  for (int i = 0; i < num_records; i++) {
    RecRecord *r = &(g_records[i]);

    if ((r->rec_type & rec_type) == 0) {
      continue;
    }

    if (regex.match(r->name) < 0) {
      continue;
    }

    rec_mutex_acquire(&(r->lock));
    callback(r, data);
    rec_mutex_release(&(r->lock));
  }

  return REC_ERR_OKAY;
}

RecErrT
RecGetRecordType(const char *name, RecT *rec_type, bool lock)