1 /*
2 * Copyright (C) 2018 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 #define DEBUG false // STOPSHIP if true
18 #include "Log.h"
19
20 #include "anomaly/AlarmTracker.h"
21 #include "anomaly/subscriber_util.h"
22 #include "HashableDimensionKey.h"
23 #include "stats_util.h"
24 #include "storage/StorageManager.h"
25
26 #include <statslog.h>
27 #include <time.h>
28
29 namespace android {
30 namespace os {
31 namespace statsd {
32
AlarmTracker(const int64_t startMillis,const int64_t currentMillis,const Alarm & alarm,const ConfigKey & configKey,const sp<AlarmMonitor> & alarmMonitor)33 AlarmTracker::AlarmTracker(const int64_t startMillis,
34 const int64_t currentMillis,
35 const Alarm& alarm, const ConfigKey& configKey,
36 const sp<AlarmMonitor>& alarmMonitor)
37 : mAlarmConfig(alarm),
38 mConfigKey(configKey),
39 mAlarmMonitor(alarmMonitor) {
40 VLOG("AlarmTracker() called");
41 mAlarmSec = (startMillis + mAlarmConfig.offset_millis()) / MS_PER_SEC;
42 // startMillis is the time statsd is created. We need to find the 1st alarm timestamp after
43 // the config is added to statsd.
44 mAlarmSec = findNextAlarmSec(currentMillis / MS_PER_SEC); // round up
45 mInternalAlarm = new InternalAlarm{static_cast<uint32_t>(mAlarmSec)};
46 VLOG("AlarmTracker sets the periodic alarm at: %lld", (long long)mAlarmSec);
47 if (mAlarmMonitor != nullptr) {
48 mAlarmMonitor->add(mInternalAlarm);
49 }
50 }
51
~AlarmTracker()52 AlarmTracker::~AlarmTracker() {
53 VLOG("~AlarmTracker() called");
54 if (mInternalAlarm != nullptr && mAlarmMonitor != nullptr) {
55 mAlarmMonitor->remove(mInternalAlarm);
56 }
57 }
58
addSubscription(const Subscription & subscription)59 void AlarmTracker::addSubscription(const Subscription& subscription) {
60 mSubscriptions.push_back(subscription);
61 }
62
findNextAlarmSec(int64_t currentTimeSec)63 int64_t AlarmTracker::findNextAlarmSec(int64_t currentTimeSec) {
64 if (currentTimeSec < mAlarmSec) {
65 return mAlarmSec;
66 }
67 int64_t periodsForward =
68 ((currentTimeSec - mAlarmSec) * MS_PER_SEC) / mAlarmConfig.period_millis() + 1;
69 return mAlarmSec + periodsForward * mAlarmConfig.period_millis() / MS_PER_SEC;
70 }
71
informAlarmsFired(const int64_t & timestampNs,unordered_set<sp<const InternalAlarm>,SpHash<InternalAlarm>> & firedAlarms)72 void AlarmTracker::informAlarmsFired(
73 const int64_t& timestampNs,
74 unordered_set<sp<const InternalAlarm>, SpHash<InternalAlarm>>& firedAlarms) {
75 if (firedAlarms.empty() || mInternalAlarm == nullptr ||
76 firedAlarms.find(mInternalAlarm) == firedAlarms.end()) {
77 return;
78 }
79 if (!mSubscriptions.empty()) {
80 VLOG("AlarmTracker triggers the subscribers.");
81 triggerSubscribers(mAlarmConfig.id(), 0 /*metricId N/A*/, DEFAULT_METRIC_DIMENSION_KEY,
82 0 /* metricValue N/A */, mConfigKey, mSubscriptions);
83 }
84 firedAlarms.erase(mInternalAlarm);
85 mAlarmSec = findNextAlarmSec((timestampNs-1) / NS_PER_SEC + 1); // round up
86 mInternalAlarm = new InternalAlarm{static_cast<uint32_t>(mAlarmSec)};
87 VLOG("AlarmTracker sets the periodic alarm at: %lld", (long long)mAlarmSec);
88 if (mAlarmMonitor != nullptr) {
89 mAlarmMonitor->add(mInternalAlarm);
90 }
91 }
92
93 } // namespace statsd
94 } // namespace os
95 } // namespace android
96