Donate to e Foundation | Murena handsets with /e/OS | Own a part of Murena! Learn more

Commit 6e2e92d9 authored by tsaichristine's avatar tsaichristine
Browse files

Pass initial conditions to combination conditions and metrics 

SimplePredicates have a configurable initial value that can be set to
unknown or false. Previously, CombinationPredicates and MetricProducers
were automatically initialized with an unknown condition value instead
of being synced with the conditions of the SimplePredicates that they
rely on.

An initial condition cache is used to store initial conditions of
ConditionTrackers after they are initialized.
CombinationConditionTrackers evaluate their initial condition based on
the initial conditions of their child SimpleConditionTrackers.
MetricProducers also use the initial condition cache to set its
condition during initialization.

Added unit tests in SimpleConditionTracker_test to check that
SimpleConditionTrackers have the correct initial conditions based on
what the InitialValue is set to and the condition is updated properly
after the first few condition change events.

Added unit test in MetricsManager_test to check that all
ConditionTrackers and MetricProducers have the correct initial
conditions.

Test: m statsd_test && adb sync data && adb shell
data/nativetest64/statsd_test/statsd_test64
Bug: b/156762672

Change-Id: I9f6088f8c92fb18eb2ca8632aaa338fb0ed8e679
parent ca83d455

cmds/statsd/src/condition/CombinationConditionTracker.cpp

+10 −4
Original line number Diff line number Diff line
@@ -37,7 +37,8 @@ CombinationConditionTracker::~CombinationConditionTracker() { 
bool CombinationConditionTracker::init(const vector<Predicate>& allConditionConfig,

                                       const vector<sp<ConditionTracker>>& allConditionTrackers,

                                       const unordered_map<int64_t, int>& conditionIdIndexMap,

                                       vector<bool>& stack) {

                                       vector<bool>& stack,

                                       vector<ConditionState>& initialConditionCache) {

    VLOG("Combination predicate init() %lld", (long long)mConditionId);

    if (mInitialized) {

        return true;
@@ -73,9 +74,9 @@ bool CombinationConditionTracker::init(const vector<Predicate>& allConditionConf 
            return false;

        }





        bool initChildSucceeded = childTracker->init(allConditionConfig, allConditionTrackers,

                                                     conditionIdIndexMap, stack);

        bool initChildSucceeded =

                childTracker->init(allConditionConfig, allConditionTrackers, conditionIdIndexMap,

                                   stack, initialConditionCache);



        if (!initChildSucceeded) {

            ALOGW("Child initialization failed %lld ", (long long)child);
@@ -95,6 +96,11 @@ bool CombinationConditionTracker::init(const vector<Predicate>& allConditionConf 
                             childTracker->getLogTrackerIndex().end());

    }



    mUnSlicedPartCondition = evaluateCombinationCondition(mUnSlicedChildren, mLogicalOperation,

                                                          initialConditionCache);

    initialConditionCache[mIndex] =

            evaluateCombinationCondition(mChildren, mLogicalOperation, initialConditionCache);



    // unmark this node in the recursion stack.

    stack[mIndex] = false;

cmds/statsd/src/condition/CombinationConditionTracker.h

+2 −2
Original line number Diff line number Diff line
@@ -32,8 +32,8 @@ public: 


    bool init(const std::vector<Predicate>& allConditionConfig,

              const std::vector<sp<ConditionTracker>>& allConditionTrackers,

              const std::unordered_map<int64_t, int>& conditionIdIndexMap,

              std::vector<bool>& stack) override;

              const std::unordered_map<int64_t, int>& conditionIdIndexMap, std::vector<bool>& stack,

              std::vector<ConditionState>& initialConditionCache) override;



    void evaluateCondition(const LogEvent& event,

                           const std::vector<MatchingState>& eventMatcherValues,

cmds/statsd/src/condition/ConditionTracker.h

+3 −1
Original line number Diff line number Diff line
@@ -51,10 +51,12 @@ public: 
    //                       need to call init() on children conditions)

    // conditionIdIndexMap: the mapping from condition id to its index.

    // stack: a bit map to keep track which nodes have been visited on the stack in the recursion.

    // initialConditionCache: tracks initial conditions of all ConditionTrackers.

    virtual bool init(const std::vector<Predicate>& allConditionConfig,

                      const std::vector<sp<ConditionTracker>>& allConditionTrackers,

                      const std::unordered_map<int64_t, int>& conditionIdIndexMap,

                      std::vector<bool>& stack) = 0;

                      std::vector<bool>& stack,

                      std::vector<ConditionState>& initialConditionCache) = 0;



    // evaluate current condition given the new event.

    // event: the new log event

cmds/statsd/src/condition/SimpleConditionTracker.cpp

+3 −1
Original line number Diff line number Diff line
@@ -95,9 +95,11 @@ SimpleConditionTracker::~SimpleConditionTracker() { 
bool SimpleConditionTracker::init(const vector<Predicate>& allConditionConfig,

                                  const vector<sp<ConditionTracker>>& allConditionTrackers,

                                  const unordered_map<int64_t, int>& conditionIdIndexMap,

                                  vector<bool>& stack) {

                                  vector<bool>& stack,

                                  vector<ConditionState>& initialConditionCache) {

    // SimpleConditionTracker does not have dependency on other conditions, thus we just return

    // if the initialization was successful.

    initialConditionCache[mIndex] = mInitialValue;

    return mInitialized;

}

cmds/statsd/src/condition/SimpleConditionTracker.h

+2 −2
Original line number Diff line number Diff line
@@ -37,8 +37,8 @@ public: 


    bool init(const std::vector<Predicate>& allConditionConfig,

              const std::vector<sp<ConditionTracker>>& allConditionTrackers,

              const std::unordered_map<int64_t, int>& conditionIdIndexMap,

              std::vector<bool>& stack) override;

              const std::unordered_map<int64_t, int>& conditionIdIndexMap, std::vector<bool>& stack,

              std::vector<ConditionState>& initialConditionCache) override;



    void evaluateCondition(const LogEvent& event,

                           const std::vector<MatchingState>& eventMatcherValues,