Joe Onorato | c4dfae5 | 2017-10-17 23:38:21 -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 | #pragma once |
| 18 | |
Yao Chen | 8a8d16c | 2018-02-08 14:50:40 -0800 | [diff] [blame] | 19 | #include "FieldValue.h" |
Joe Onorato | c4dfae5 | 2017-10-17 23:38:21 -0700 | [diff] [blame] | 20 | |
Howard Ro | a46b658 | 2018-09-18 16:45:02 -0700 | [diff] [blame] | 21 | #include <android/frameworks/stats/1.0/types.h> |
Chenjie Yu | 12e5e67 | 2018-09-14 15:54:59 -0700 | [diff] [blame] | 22 | #include <android/os/StatsLogEventWrapper.h> |
Yao Chen | 5110bed | 2017-10-23 12:50:02 -0700 | [diff] [blame] | 23 | #include <android/util/ProtoOutputStream.h> |
Joe Onorato | c4dfae5 | 2017-10-17 23:38:21 -0700 | [diff] [blame] | 24 | #include <log/log_event_list.h> |
| 25 | #include <log/log_read.h> |
Yao Chen | 8023540 | 2017-11-13 20:42:25 -0800 | [diff] [blame] | 26 | #include <private/android_logger.h> |
Yao Chen | 5110bed | 2017-10-23 12:50:02 -0700 | [diff] [blame] | 27 | #include <utils/Errors.h> |
Joe Onorato | c4dfae5 | 2017-10-17 23:38:21 -0700 | [diff] [blame] | 28 | |
| 29 | #include <string> |
| 30 | #include <vector> |
| 31 | |
Howard Ro | a46b658 | 2018-09-18 16:45:02 -0700 | [diff] [blame] | 32 | using namespace android::frameworks::stats::V1_0; |
| 33 | |
Joe Onorato | c4dfae5 | 2017-10-17 23:38:21 -0700 | [diff] [blame] | 34 | namespace android { |
| 35 | namespace os { |
| 36 | namespace statsd { |
| 37 | |
Yao Chen | 9c1debe | 2018-02-19 14:39:19 -0800 | [diff] [blame] | 38 | struct AttributionNodeInternal { |
| 39 | void set_uid(int32_t id) { |
| 40 | mUid = id; |
| 41 | } |
| 42 | |
| 43 | void set_tag(const std::string& value) { |
| 44 | mTag = value; |
| 45 | } |
| 46 | |
| 47 | int32_t uid() const { |
| 48 | return mUid; |
| 49 | } |
| 50 | |
| 51 | const std::string& tag() const { |
| 52 | return mTag; |
| 53 | } |
| 54 | |
| 55 | int32_t mUid; |
| 56 | std::string mTag; |
| 57 | }; |
Chenjie Yu | 97dbb20 | 2019-02-13 16:42:04 -0800 | [diff] [blame] | 58 | |
| 59 | struct InstallTrainInfo { |
| 60 | int64_t trainVersionCode; |
Muhammad Qureshi | f4ca824 | 2019-03-01 09:20:15 -0800 | [diff] [blame] | 61 | std::string trainName; |
| 62 | int32_t status; |
Chenjie Yu | 97dbb20 | 2019-02-13 16:42:04 -0800 | [diff] [blame] | 63 | std::vector<uint8_t> experimentIds; |
| 64 | }; |
Joe Onorato | c4dfae5 | 2017-10-17 23:38:21 -0700 | [diff] [blame] | 65 | /** |
| 66 | * Wrapper for the log_msg structure. |
| 67 | */ |
| 68 | class LogEvent { |
| 69 | public: |
| 70 | /** |
| 71 | * Read a LogEvent from a log_msg. |
| 72 | */ |
David Chen | a3bf050 | 2017-11-01 16:57:43 -0700 | [diff] [blame] | 73 | explicit LogEvent(log_msg& msg); |
Joe Onorato | c4dfae5 | 2017-10-17 23:38:21 -0700 | [diff] [blame] | 74 | |
Chenjie Yu | d7e3a22 | 2018-11-28 21:29:44 +0000 | [diff] [blame] | 75 | /** |
| 76 | * Creates LogEvent from StatsLogEventWrapper. |
| 77 | */ |
| 78 | static void createLogEvents(const StatsLogEventWrapper& statsLogEventWrapper, |
| 79 | std::vector<std::shared_ptr<LogEvent>>& logEvents); |
| 80 | |
| 81 | /** |
| 82 | * Construct one LogEvent from a StatsLogEventWrapper with the i-th work chain. -1 if no chain. |
| 83 | */ |
| 84 | explicit LogEvent(const StatsLogEventWrapper& statsLogEventWrapper, int workChainIndex); |
Chenjie Yu | 12e5e67 | 2018-09-14 15:54:59 -0700 | [diff] [blame] | 85 | |
Joe Onorato | c4dfae5 | 2017-10-17 23:38:21 -0700 | [diff] [blame] | 86 | /** |
Yao Chen | 8023540 | 2017-11-13 20:42:25 -0800 | [diff] [blame] | 87 | * Constructs a LogEvent with synthetic data for testing. Must call init() before reading. |
Joe Onorato | c4dfae5 | 2017-10-17 23:38:21 -0700 | [diff] [blame] | 88 | */ |
Yangster-mac | 330af58 | 2018-02-08 15:24:38 -0800 | [diff] [blame] | 89 | explicit LogEvent(int32_t tagId, int64_t wallClockTimestampNs, int64_t elapsedTimestampNs); |
| 90 | |
| 91 | // For testing. The timestamp is used as both elapsed real time and logd timestamp. |
| 92 | explicit LogEvent(int32_t tagId, int64_t timestampNs); |
David Chen | 1481fe1 | 2017-10-16 13:16:34 -0700 | [diff] [blame] | 93 | |
Howard Ro | 1a2a399 | 2018-10-22 22:51:57 -0700 | [diff] [blame] | 94 | // For testing. The timestamp is used as both elapsed real time and logd timestamp. |
| 95 | explicit LogEvent(int32_t tagId, int64_t timestampNs, int32_t uid); |
| 96 | |
Yangster-mac | 48b3d62 | 2018-08-18 12:38:11 -0700 | [diff] [blame] | 97 | /** |
| 98 | * Constructs a KeyValuePairsAtom LogEvent from value maps. |
| 99 | */ |
| 100 | explicit LogEvent(int32_t tagId, int64_t wallClockTimestampNs, int64_t elapsedTimestampNs, |
| 101 | int32_t uid, |
Howard Ro | 4078dd4 | 2018-09-27 17:41:08 -0700 | [diff] [blame] | 102 | const std::map<int32_t, int32_t>& int_map, |
| 103 | const std::map<int32_t, int64_t>& long_map, |
Yangster-mac | 48b3d62 | 2018-08-18 12:38:11 -0700 | [diff] [blame] | 104 | const std::map<int32_t, std::string>& string_map, |
| 105 | const std::map<int32_t, float>& float_map); |
| 106 | |
Chenjie Yu | 6b1667c | 2019-01-18 10:09:33 -0800 | [diff] [blame] | 107 | // Constructs a BinaryPushStateChanged LogEvent from API call. |
| 108 | explicit LogEvent(const std::string& trainName, int64_t trainVersionCode, bool requiresStaging, |
| 109 | bool rollbackEnabled, bool requiresLowLatencyMonitor, int32_t state, |
| 110 | const std::vector<uint8_t>& experimentIds, int32_t userId); |
| 111 | |
Howard Ro | a46b658 | 2018-09-18 16:45:02 -0700 | [diff] [blame] | 112 | explicit LogEvent(int64_t wallClockTimestampNs, int64_t elapsedTimestampNs, |
Maggie White | 58174da | 2019-01-18 15:23:35 -0800 | [diff] [blame] | 113 | const VendorAtom& vendorAtom); |
| 114 | |
Chenjie Yu | 97dbb20 | 2019-02-13 16:42:04 -0800 | [diff] [blame] | 115 | explicit LogEvent(int64_t wallClockTimestampNs, int64_t elapsedTimestampNs, |
| 116 | const InstallTrainInfo& installTrainInfo); |
| 117 | |
Joe Onorato | c4dfae5 | 2017-10-17 23:38:21 -0700 | [diff] [blame] | 118 | ~LogEvent(); |
| 119 | |
| 120 | /** |
| 121 | * Get the timestamp associated with this event. |
| 122 | */ |
Yangster-mac | 330af58 | 2018-02-08 15:24:38 -0800 | [diff] [blame] | 123 | inline int64_t GetLogdTimestampNs() const { return mLogdTimestampNs; } |
| 124 | inline int64_t GetElapsedTimestampNs() const { return mElapsedTimestampNs; } |
Joe Onorato | c4dfae5 | 2017-10-17 23:38:21 -0700 | [diff] [blame] | 125 | |
| 126 | /** |
| 127 | * Get the tag for this event. |
| 128 | */ |
Yangster-mac | 6898580 | 2018-01-21 10:05:09 -0800 | [diff] [blame] | 129 | inline int GetTagId() const { return mTagId; } |
Joe Onorato | c4dfae5 | 2017-10-17 23:38:21 -0700 | [diff] [blame] | 130 | |
Yangster-mac | 6898580 | 2018-01-21 10:05:09 -0800 | [diff] [blame] | 131 | inline uint32_t GetUid() const { |
Yao Chen | d10f7b1 | 2017-12-18 12:53:50 -0800 | [diff] [blame] | 132 | return mLogUid; |
| 133 | } |
| 134 | |
Joe Onorato | c4dfae5 | 2017-10-17 23:38:21 -0700 | [diff] [blame] | 135 | /** |
| 136 | * Get the nth value, starting at 1. |
| 137 | * |
| 138 | * Returns BAD_INDEX if the index is larger than the number of elements. |
| 139 | * Returns BAD_TYPE if the index is available but the data is the wrong type. |
| 140 | */ |
| 141 | int64_t GetLong(size_t key, status_t* err) const; |
Chenjie Yu | 80f9112 | 2018-01-31 20:24:50 -0800 | [diff] [blame] | 142 | int GetInt(size_t key, status_t* err) const; |
Joe Onorato | c4dfae5 | 2017-10-17 23:38:21 -0700 | [diff] [blame] | 143 | const char* GetString(size_t key, status_t* err) const; |
| 144 | bool GetBool(size_t key, status_t* err) const; |
| 145 | float GetFloat(size_t key, status_t* err) const; |
| 146 | |
| 147 | /** |
Yao Chen | 8023540 | 2017-11-13 20:42:25 -0800 | [diff] [blame] | 148 | * Write test data to the LogEvent. This can only be used when the LogEvent is constructed |
| 149 | * using LogEvent(tagId, timestampNs). You need to call init() before you can read from it. |
| 150 | */ |
| 151 | bool write(uint32_t value); |
| 152 | bool write(int32_t value); |
| 153 | bool write(uint64_t value); |
| 154 | bool write(int64_t value); |
Yao Chen | 9c1debe | 2018-02-19 14:39:19 -0800 | [diff] [blame] | 155 | bool write(const std::string& value); |
Yao Chen | 8023540 | 2017-11-13 20:42:25 -0800 | [diff] [blame] | 156 | bool write(float value); |
Yao Chen | 9c1debe | 2018-02-19 14:39:19 -0800 | [diff] [blame] | 157 | bool write(const std::vector<AttributionNodeInternal>& nodes); |
| 158 | bool write(const AttributionNodeInternal& node); |
Howard Ro | 1a2a399 | 2018-10-22 22:51:57 -0700 | [diff] [blame] | 159 | bool writeKeyValuePairs(int32_t uid, |
| 160 | const std::map<int32_t, int32_t>& int_map, |
Howard Ro | 4078dd4 | 2018-09-27 17:41:08 -0700 | [diff] [blame] | 161 | const std::map<int32_t, int64_t>& long_map, |
Yangster-mac | e124e42 | 2018-08-16 10:30:28 -0700 | [diff] [blame] | 162 | const std::map<int32_t, std::string>& string_map, |
| 163 | const std::map<int32_t, float>& float_map); |
Yao Chen | 8023540 | 2017-11-13 20:42:25 -0800 | [diff] [blame] | 164 | |
| 165 | /** |
Joe Onorato | c4dfae5 | 2017-10-17 23:38:21 -0700 | [diff] [blame] | 166 | * Return a string representation of this event. |
| 167 | */ |
Yao Chen | 9c1debe | 2018-02-19 14:39:19 -0800 | [diff] [blame] | 168 | std::string ToString() const; |
Joe Onorato | c4dfae5 | 2017-10-17 23:38:21 -0700 | [diff] [blame] | 169 | |
| 170 | /** |
Yao Chen | 5110bed | 2017-10-23 12:50:02 -0700 | [diff] [blame] | 171 | * Write this object to a ProtoOutputStream. |
Joe Onorato | c4dfae5 | 2017-10-17 23:38:21 -0700 | [diff] [blame] | 172 | */ |
Yao Chen | 5110bed | 2017-10-23 12:50:02 -0700 | [diff] [blame] | 173 | void ToProto(android::util::ProtoOutputStream& out) const; |
Joe Onorato | c4dfae5 | 2017-10-17 23:38:21 -0700 | [diff] [blame] | 174 | |
David Chen | 1481fe1 | 2017-10-16 13:16:34 -0700 | [diff] [blame] | 175 | /** |
David Chen | 1481fe1 | 2017-10-16 13:16:34 -0700 | [diff] [blame] | 176 | * Used with the constructor where tag is passed in. Converts the log_event_list to read mode |
| 177 | * and prepares the list for reading. |
| 178 | */ |
| 179 | void init(); |
| 180 | |
Chenjie Yu | a7259ab | 2017-12-10 08:31:05 -0800 | [diff] [blame] | 181 | /** |
Yangster-mac | 330af58 | 2018-02-08 15:24:38 -0800 | [diff] [blame] | 182 | * Set elapsed timestamp if the original timestamp is missing. |
Chenjie Yu | a7259ab | 2017-12-10 08:31:05 -0800 | [diff] [blame] | 183 | */ |
Yangster-mac | 330af58 | 2018-02-08 15:24:38 -0800 | [diff] [blame] | 184 | void setElapsedTimestampNs(int64_t timestampNs) { |
| 185 | mElapsedTimestampNs = timestampNs; |
| 186 | } |
| 187 | |
| 188 | /** |
| 189 | * Set the timestamp if the original logd timestamp is missing. |
| 190 | */ |
| 191 | void setLogdWallClockTimestampNs(int64_t timestampNs) { |
| 192 | mLogdTimestampNs = timestampNs; |
| 193 | } |
Chenjie Yu | a7259ab | 2017-12-10 08:31:05 -0800 | [diff] [blame] | 194 | |
Yangster-mac | 2087716 | 2017-12-22 17:19:39 -0800 | [diff] [blame] | 195 | inline int size() const { |
Yao Chen | 8a8d16c | 2018-02-08 14:50:40 -0800 | [diff] [blame] | 196 | return mValues.size(); |
Chenjie Yu | d9dfda7 | 2017-12-11 17:41:20 -0800 | [diff] [blame] | 197 | } |
| 198 | |
Yao Chen | 8a8d16c | 2018-02-08 14:50:40 -0800 | [diff] [blame] | 199 | const std::vector<FieldValue>& getValues() const { |
| 200 | return mValues; |
| 201 | } |
Yangster-mac | d40053e | 2018-01-09 16:29:22 -0800 | [diff] [blame] | 202 | |
Yao Chen | 8a8d16c | 2018-02-08 14:50:40 -0800 | [diff] [blame] | 203 | std::vector<FieldValue>* getMutableValues() { |
| 204 | return &mValues; |
| 205 | } |
Yangster-mac | 2087716 | 2017-12-22 17:19:39 -0800 | [diff] [blame] | 206 | |
Chenjie Yu | 0bd73db | 2018-12-16 07:37:04 -0800 | [diff] [blame] | 207 | inline LogEvent makeCopy() { |
| 208 | return LogEvent(*this); |
| 209 | } |
| 210 | |
Joe Onorato | c4dfae5 | 2017-10-17 23:38:21 -0700 | [diff] [blame] | 211 | private: |
| 212 | /** |
Chenjie Yu | 0bd73db | 2018-12-16 07:37:04 -0800 | [diff] [blame] | 213 | * Only use this if copy is absolutely needed. |
Joe Onorato | c4dfae5 | 2017-10-17 23:38:21 -0700 | [diff] [blame] | 214 | */ |
Chih-Hung Hsieh | 3227aab | 2018-12-20 13:42:28 -0800 | [diff] [blame] | 215 | LogEvent(const LogEvent&); |
Joe Onorato | c4dfae5 | 2017-10-17 23:38:21 -0700 | [diff] [blame] | 216 | |
| 217 | /** |
| 218 | * Parses a log_msg into a LogEvent object. |
| 219 | */ |
Yao Chen | 8023540 | 2017-11-13 20:42:25 -0800 | [diff] [blame] | 220 | void init(android_log_context context); |
Joe Onorato | c4dfae5 | 2017-10-17 23:38:21 -0700 | [diff] [blame] | 221 | |
Yao Chen | 8a8d16c | 2018-02-08 14:50:40 -0800 | [diff] [blame] | 222 | // The items are naturally sorted in DFS order as we read them. this allows us to do fast |
| 223 | // matching. |
| 224 | std::vector<FieldValue> mValues; |
Yao Chen | 8023540 | 2017-11-13 20:42:25 -0800 | [diff] [blame] | 225 | |
Yangster-mac | 2087716 | 2017-12-22 17:19:39 -0800 | [diff] [blame] | 226 | // This field is used when statsD wants to create log event object and write fields to it. After |
| 227 | // calling init() function, this object would be destroyed to save memory usage. |
| 228 | // When the log event is created from log msg, this field is never initiated. |
Yao Chen | 48d7518 | 2018-01-23 09:40:48 -0800 | [diff] [blame] | 229 | android_log_context mContext = NULL; |
Yao Chen | 93fe3a3 | 2017-11-02 13:52:59 -0700 | [diff] [blame] | 230 | |
Yangster-mac | 330af58 | 2018-02-08 15:24:38 -0800 | [diff] [blame] | 231 | // The timestamp set by the logd. |
| 232 | int64_t mLogdTimestampNs; |
| 233 | |
| 234 | // The elapsed timestamp set by statsd log writer. |
| 235 | int64_t mElapsedTimestampNs; |
Yao Chen | 93fe3a3 | 2017-11-02 13:52:59 -0700 | [diff] [blame] | 236 | |
Joe Onorato | c4dfae5 | 2017-10-17 23:38:21 -0700 | [diff] [blame] | 237 | int mTagId; |
Yao Chen | d10f7b1 | 2017-12-18 12:53:50 -0800 | [diff] [blame] | 238 | |
| 239 | uint32_t mLogUid; |
Joe Onorato | c4dfae5 | 2017-10-17 23:38:21 -0700 | [diff] [blame] | 240 | }; |
| 241 | |
| 242 | } // namespace statsd |
| 243 | } // namespace os |
| 244 | } // namespace android |
| 245 | |