Yao Chen | caf339d | 2017-10-06 16:01:10 -0700 | [diff] [blame] | 1 | /* |
| 2 | * Copyright (C) 2017 The Android Open Source Project |
| 3 | * |
| 4 | * Licensed under the Apache License, Version 2.0 (the "License"); |
| 5 | * you may not use this file except in compliance with the License. |
| 6 | * You may obtain a copy of the License at |
| 7 | * |
| 8 | * http://www.apache.org/licenses/LICENSE-2.0 |
| 9 | * |
| 10 | * Unless required by applicable law or agreed to in writing, software |
| 11 | * distributed under the License is distributed on an "AS IS" BASIS, |
| 12 | * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| 13 | * See the License for the specific language governing permissions and |
| 14 | * limitations under the License. |
| 15 | */ |
| 16 | |
| 17 | #ifndef SIMPLE_CONDITION_TRACKER_H |
| 18 | #define SIMPLE_CONDITION_TRACKER_H |
| 19 | |
Yao Chen | 967b205 | 2017-11-07 16:36:43 -0800 | [diff] [blame] | 20 | #include <gtest/gtest_prod.h> |
Yao Chen | caf339d | 2017-10-06 16:01:10 -0700 | [diff] [blame] | 21 | #include "ConditionTracker.h" |
Yao Chen | b356151 | 2017-11-21 18:07:17 -0800 | [diff] [blame] | 22 | #include "config/ConfigKey.h" |
Yao Chen | caf339d | 2017-10-06 16:01:10 -0700 | [diff] [blame] | 23 | #include "frameworks/base/cmds/statsd/src/statsd_config.pb.h" |
Yao Chen | 729093d | 2017-10-16 10:33:26 -0700 | [diff] [blame] | 24 | #include "stats_util.h" |
Yao Chen | caf339d | 2017-10-06 16:01:10 -0700 | [diff] [blame] | 25 | |
| 26 | namespace android { |
| 27 | namespace os { |
| 28 | namespace statsd { |
| 29 | |
| 30 | class SimpleConditionTracker : public virtual ConditionTracker { |
| 31 | public: |
Yangster-mac | 94e197c | 2018-01-02 16:03:03 -0800 | [diff] [blame] | 32 | SimpleConditionTracker(const ConfigKey& key, const int64_t& id, const int index, |
Stefan Lafon | 12d01fa | 2017-12-04 20:56:09 -0800 | [diff] [blame] | 33 | const SimplePredicate& simplePredicate, |
Yangster-mac | 94e197c | 2018-01-02 16:03:03 -0800 | [diff] [blame] | 34 | const std::unordered_map<int64_t, int>& trackerNameIndexMap); |
Yao Chen | caf339d | 2017-10-06 16:01:10 -0700 | [diff] [blame] | 35 | |
| 36 | ~SimpleConditionTracker(); |
| 37 | |
Stefan Lafon | 12d01fa | 2017-12-04 20:56:09 -0800 | [diff] [blame] | 38 | bool init(const std::vector<Predicate>& allConditionConfig, |
Yao Chen | caf339d | 2017-10-06 16:01:10 -0700 | [diff] [blame] | 39 | const std::vector<sp<ConditionTracker>>& allConditionTrackers, |
tsaichristine | 6e2e92d | 2020-05-18 14:39:45 -0700 | [diff] [blame] | 40 | const std::unordered_map<int64_t, int>& conditionIdIndexMap, std::vector<bool>& stack, |
| 41 | std::vector<ConditionState>& initialConditionCache) override; |
Yao Chen | caf339d | 2017-10-06 16:01:10 -0700 | [diff] [blame] | 42 | |
Yao Chen | 967b205 | 2017-11-07 16:36:43 -0800 | [diff] [blame] | 43 | void evaluateCondition(const LogEvent& event, |
Yao Chen | caf339d | 2017-10-06 16:01:10 -0700 | [diff] [blame] | 44 | const std::vector<MatchingState>& eventMatcherValues, |
| 45 | const std::vector<sp<ConditionTracker>>& mAllConditions, |
| 46 | std::vector<ConditionState>& conditionCache, |
Yao Chen | 967b205 | 2017-11-07 16:36:43 -0800 | [diff] [blame] | 47 | std::vector<bool>& changedCache) override; |
Yao Chen | 729093d | 2017-10-16 10:33:26 -0700 | [diff] [blame] | 48 | |
Yangster-mac | 2087716 | 2017-12-22 17:19:39 -0800 | [diff] [blame] | 49 | void isConditionMet(const ConditionKey& conditionParameters, |
Yao Chen | 729093d | 2017-10-16 10:33:26 -0700 | [diff] [blame] | 50 | const std::vector<sp<ConditionTracker>>& allConditions, |
Yangster | 13fb7e4 | 2018-03-07 17:30:49 -0800 | [diff] [blame] | 51 | const bool isPartialLink, |
tsaichristine | 7685337 | 2019-08-06 17:17:03 -0700 | [diff] [blame] | 52 | std::vector<ConditionState>& conditionCache) const override; |
Yao Chen | 729093d | 2017-10-16 10:33:26 -0700 | [diff] [blame] | 53 | |
Yao Chen | 580ea321 | 2018-02-26 14:21:54 -0800 | [diff] [blame] | 54 | virtual const std::set<HashableDimensionKey>* getChangedToTrueDimensions( |
| 55 | const std::vector<sp<ConditionTracker>>& allConditions) const { |
| 56 | if (mSliced) { |
| 57 | return &mLastChangedToTrueDimensions; |
| 58 | } else { |
| 59 | return nullptr; |
| 60 | } |
| 61 | } |
Yangster | 13fb7e4 | 2018-03-07 17:30:49 -0800 | [diff] [blame] | 62 | |
Yao Chen | 580ea321 | 2018-02-26 14:21:54 -0800 | [diff] [blame] | 63 | virtual const std::set<HashableDimensionKey>* getChangedToFalseDimensions( |
| 64 | const std::vector<sp<ConditionTracker>>& allConditions) const { |
| 65 | if (mSliced) { |
| 66 | return &mLastChangedToFalseDimensions; |
| 67 | } else { |
| 68 | return nullptr; |
| 69 | } |
| 70 | } |
| 71 | |
Yangster | 13fb7e4 | 2018-03-07 17:30:49 -0800 | [diff] [blame] | 72 | void getTrueSlicedDimensions( |
| 73 | const std::vector<sp<ConditionTracker>>& allConditions, |
| 74 | std::set<HashableDimensionKey>* dimensions) const override { |
| 75 | for (const auto& itr : mSlicedConditionState) { |
| 76 | if (itr.second > 0) { |
| 77 | dimensions->insert(itr.first); |
| 78 | } |
| 79 | } |
| 80 | } |
| 81 | |
| 82 | bool IsChangedDimensionTrackable() const override { return true; } |
| 83 | |
| 84 | bool IsSimpleCondition() const override { return true; } |
| 85 | |
| 86 | bool equalOutputDimensions( |
| 87 | const std::vector<sp<ConditionTracker>>& allConditions, |
| 88 | const vector<Matcher>& dimensions) const override { |
| 89 | return equalDimensions(mOutputDimensions, dimensions); |
| 90 | } |
| 91 | |
Yao Chen | caf339d | 2017-10-06 16:01:10 -0700 | [diff] [blame] | 92 | private: |
Yao Chen | b356151 | 2017-11-21 18:07:17 -0800 | [diff] [blame] | 93 | const ConfigKey mConfigKey; |
Yao Chen | caf339d | 2017-10-06 16:01:10 -0700 | [diff] [blame] | 94 | // The index of the LogEventMatcher which defines the start. |
| 95 | int mStartLogMatcherIndex; |
| 96 | |
| 97 | // The index of the LogEventMatcher which defines the end. |
| 98 | int mStopLogMatcherIndex; |
| 99 | |
| 100 | // if the start end needs to be nested. |
| 101 | bool mCountNesting; |
| 102 | |
| 103 | // The index of the LogEventMatcher which defines the stop all. |
| 104 | int mStopAllLogMatcherIndex; |
Yao Chen | 729093d | 2017-10-16 10:33:26 -0700 | [diff] [blame] | 105 | |
Yao Chen | 967b205 | 2017-11-07 16:36:43 -0800 | [diff] [blame] | 106 | ConditionState mInitialValue; |
Yao Chen | 729093d | 2017-10-16 10:33:26 -0700 | [diff] [blame] | 107 | |
Yao Chen | 8a8d16c | 2018-02-08 14:50:40 -0800 | [diff] [blame] | 108 | std::vector<Matcher> mOutputDimensions; |
| 109 | |
Yangster | 13fb7e4 | 2018-03-07 17:30:49 -0800 | [diff] [blame] | 110 | bool mContainANYPositionInInternalDimensions; |
| 111 | |
Yao Chen | 580ea321 | 2018-02-26 14:21:54 -0800 | [diff] [blame] | 112 | std::set<HashableDimensionKey> mLastChangedToTrueDimensions; |
| 113 | std::set<HashableDimensionKey> mLastChangedToFalseDimensions; |
| 114 | |
Yao Chen | 8a8d16c | 2018-02-08 14:50:40 -0800 | [diff] [blame] | 115 | int mDimensionTag; |
Yao Chen | 967b205 | 2017-11-07 16:36:43 -0800 | [diff] [blame] | 116 | |
| 117 | std::map<HashableDimensionKey, int> mSlicedConditionState; |
| 118 | |
| 119 | void handleStopAll(std::vector<ConditionState>& conditionCache, |
| 120 | std::vector<bool>& changedCache); |
| 121 | |
Yao Chen | 8a8d16c | 2018-02-08 14:50:40 -0800 | [diff] [blame] | 122 | void handleConditionEvent(const HashableDimensionKey& outputKey, bool matchStart, |
| 123 | ConditionState* conditionCache, bool* changedCache); |
Yao Chen | 967b205 | 2017-11-07 16:36:43 -0800 | [diff] [blame] | 124 | |
Yao Chen | b356151 | 2017-11-21 18:07:17 -0800 | [diff] [blame] | 125 | bool hitGuardRail(const HashableDimensionKey& newKey); |
| 126 | |
Yao Chen | 580ea321 | 2018-02-26 14:21:54 -0800 | [diff] [blame] | 127 | void dumpState(); |
| 128 | |
Yao Chen | 967b205 | 2017-11-07 16:36:43 -0800 | [diff] [blame] | 129 | FRIEND_TEST(SimpleConditionTrackerTest, TestSlicedCondition); |
| 130 | FRIEND_TEST(SimpleConditionTrackerTest, TestSlicedWithNoOutputDim); |
| 131 | FRIEND_TEST(SimpleConditionTrackerTest, TestStopAll); |
Yao Chen | caf339d | 2017-10-06 16:01:10 -0700 | [diff] [blame] | 132 | }; |
| 133 | |
| 134 | } // namespace statsd |
| 135 | } // namespace os |
| 136 | } // namespace android |
| 137 | |
| 138 | #endif // SIMPLE_CONDITION_TRACKER_H |