1 /*
2 * Copyright (C) 2022 Huawei Device Co., Ltd.
3 * Licensed under the Apache License, Version 2.0 (the "License");
4 * you may not use this file except in compliance with the License.
5 * You may obtain a copy of the License at
6 *
7 * http://www.apache.org/licenses/LICENSE-2.0
8 *
9 * Unless required by applicable law or agreed to in writing, software
10 * distributed under the License is distributed on an "AS IS" BASIS,
11 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12 * See the License for the specific language governing permissions and
13 * limitations under the License.
14 */
15
16 #include "locator_event_manager.h"
17
18 #include <vector>
19
20 #include "constant_definition.h"
21
22 namespace OHOS {
23 namespace Location {
PutInt(const std::string & name,int value)24 void DftEvent::PutInt(const std::string& name, int value)
25 {
26 std::unique_lock<std::mutex> lock(mutex_);
27 intValues_.emplace(name, value);
28 }
29
GetInt(const std::string & name)30 int DftEvent::GetInt(const std::string& name)
31 {
32 std::unique_lock<std::mutex> lock(mutex_);
33 auto it = intValues_.find(name);
34 if (it == intValues_.end()) {
35 return 0;
36 }
37 return it->second;
38 }
39
DftHandler(const std::shared_ptr<AppExecFwk::EventRunner> & runner)40 DftHandler::DftHandler(const std::shared_ptr<AppExecFwk::EventRunner>& runner) : EventHandler(runner) {}
41
~DftHandler()42 DftHandler::~DftHandler() {}
43
ProcessEvent(const AppExecFwk::InnerEvent::Pointer & event)44 void DftHandler::ProcessEvent(const AppExecFwk::InnerEvent::Pointer& event)
45 {
46 }
47
GetInstance()48 LocatorDftManager* LocatorDftManager::GetInstance()
49 {
50 static LocatorDftManager data;
51 return &data;
52 }
53
LocatorDftManager()54 LocatorDftManager::LocatorDftManager()
55 {
56 distributeSissionCnt_ = 0;
57 distributeDisconnectCnt_ = 0;
58 }
59
~LocatorDftManager()60 LocatorDftManager::~LocatorDftManager() {}
61
Init()62 void LocatorDftManager::Init()
63 {
64 if (handler_ != nullptr) {
65 handler_->SendHighPriorityEvent(EVENT_SEND_DAILY_REPORT, 0, DAILY_INTERVAL);
66 }
67 }
68
IpcCallingErr(int error)69 void LocatorDftManager::IpcCallingErr(int error)
70 {
71 }
72
LocationSessionStart(std::shared_ptr<Request> request)73 void LocatorDftManager::LocationSessionStart(std::shared_ptr<Request> request)
74 {
75 std::shared_ptr<AppRequestCount> requestCount = nullptr;
76 if (request == nullptr) {
77 return;
78 }
79
80 std::unique_lock<std::mutex> lock(mutex_);
81 for (auto appRequest : appRequests_) {
82 if (appRequest->packageName.compare(request->GetPackageName()) == 0) {
83 requestCount = appRequest;
84 break;
85 }
86 }
87 if (requestCount == nullptr) {
88 requestCount = std::make_shared<AppRequestCount>();
89 requestCount->packageName = request->GetPackageName();
90 requestCount->requestType = std::vector<int>(DFT_APP_MAX_SIZE);
91 requestCount->count = std::vector<int>(DFT_APP_MAX_SIZE);
92 appRequests_.push_back(requestCount);
93 }
94
95 unsigned index = INVALID_VALUE;
96 if (request->GetRequestConfig() == nullptr) {
97 return;
98 }
99 int scenario = request->GetRequestConfig()->GetScenario();
100 int priority = request->GetRequestConfig()->GetPriority();
101 for (unsigned i = 0; i < requestCount->requestType.size(); i++) {
102 if (requestCount->requestType.at(i) == scenario || requestCount->requestType.at(i) == priority) {
103 index = i;
104 break;
105 }
106 }
107 if (index != INVALID_VALUE) {
108 requestCount->count.at(index)++;
109 } else {
110 if (scenario != SCENE_UNSET) {
111 requestCount->requestType.at(0) = scenario;
112 } else if (priority != PRIORITY_UNSET) {
113 requestCount->requestType.at(0) = priority;
114 } else {
115 return;
116 }
117 requestCount->count.at(0)++;
118 }
119 }
120
DistributionDisconnect()121 void LocatorDftManager::DistributionDisconnect()
122 {
123 if (distributeDisconnectCnt_ < COUNT_MAX) {
124 distributeDisconnectCnt_++;
125 }
126 }
127
DistributionSessionStart()128 void LocatorDftManager::DistributionSessionStart()
129 {
130 if (distributeSissionCnt_ < COUNT_MAX) {
131 distributeSissionCnt_++;
132 }
133 }
134
SendDistributionDailyCount()135 void LocatorDftManager::SendDistributionDailyCount()
136 {
137 }
138
SendRequestDailyCount()139 void LocatorDftManager::SendRequestDailyCount()
140 {
141 }
142
GetTopRequest()143 std::shared_ptr<AppRequestCount> LocatorDftManager::GetTopRequest()
144 {
145 std::shared_ptr<AppRequestCount> topRequest;
146 int topSum = 0;
147 std::unique_lock<std::mutex> lock(mutex_);
148 for (auto appRequest : appRequests_) {
149 int sum = 0;
150 for (unsigned i = 0; i < appRequest->count.size(); i++) {
151 sum = sum + appRequest->count.at(i);
152 }
153 if (sum > topSum) {
154 topSum = sum;
155 topRequest = appRequest;
156 }
157 }
158 return topRequest;
159 }
160 } // namespace Location
161 } // namespace OHOS