blob: 4ed8289ab133dcd1cc77c8a457c8370507ce046f [file] [log] [blame]
/*
* Copyright (C) 2017 The Android Open Source Project
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
#include "MetricProducer.h"
namespace android {
namespace os {
namespace statsd {
using std::map;
void MetricProducer::onMatchedLogEventLocked(const size_t matcherIndex, const LogEvent& event) {
uint64_t eventTimeNs = event.GetTimestampNs();
// this is old event, maybe statsd restarted?
if (eventTimeNs < mStartTimeNs) {
return;
}
bool condition;
map<string, std::vector<HashableDimensionKey>> conditionKeys;
if (mConditionSliced) {
for (const auto& link : mConditionLinks) {
conditionKeys.insert(std::make_pair(link.condition(),
getDimensionKeysForCondition(event, link)));
}
if (mWizard->query(mConditionTrackerIndex, conditionKeys) != ConditionState::kTrue) {
condition = false;
} else {
condition = true;
}
} else {
condition = mCondition;
}
if (mDimensions.child_size() > 0) {
vector<DimensionsValue> dimensionValues = getDimensionKeys(event, mDimensions);
for (const DimensionsValue& dimensionValue : dimensionValues) {
onMatchedLogEventInternalLocked(
matcherIndex, HashableDimensionKey(dimensionValue), conditionKeys, condition, event);
}
} else {
onMatchedLogEventInternalLocked(
matcherIndex, DEFAULT_DIMENSION_KEY, conditionKeys, condition, event);
}
}
} // namespace statsd
} // namespace os
} // namespace android