1 /*
2  * Copyright (C) 2020 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 LOG_TAG "GnssAntennaInfo"
18 
19 #include "v2_1/GnssAntennaInfo.h"
20 #include "Utils.h"
21 
22 #include <log/log.h>
23 
24 using ::android::hardware::gnss::common::Utils;
25 
26 namespace android::hardware::gnss::V2_1::implementation {
27 
28 sp<IGnssAntennaInfoCallback> GnssAntennaInfo::sCallback = nullptr;
29 
GnssAntennaInfo()30 GnssAntennaInfo::GnssAntennaInfo() : mMinIntervalMillis(1000) {}
31 
~GnssAntennaInfo()32 GnssAntennaInfo::~GnssAntennaInfo() {
33     stop();
34 }
35 
36 // Methods from ::android::hardware::gnss::V2_1::IGnssAntennaInfo follow.
setCallback(const sp<IGnssAntennaInfoCallback> & callback)37 Return<GnssAntennaInfo::GnssAntennaInfoStatus> GnssAntennaInfo::setCallback(
38         const sp<IGnssAntennaInfoCallback>& callback) {
39     ALOGD("setCallback");
40     std::unique_lock<std::mutex> lock(mMutex);
41     sCallback = callback;
42 
43     if (mIsActive) {
44         ALOGW("GnssAntennaInfo callback already set. Resetting the callback...");
45         stop();
46     }
47     start();
48 
49     return GnssAntennaInfoStatus::SUCCESS;
50 }
51 
close()52 Return<void> GnssAntennaInfo::close() {
53     ALOGD("close");
54     stop();
55     std::unique_lock<std::mutex> lock(mMutex);
56     sCallback = nullptr;
57     return Void();
58 }
59 
60 // Private methods
start()61 void GnssAntennaInfo::start() {
62     ALOGD("start");
63     mIsActive = true;
64     mThread = std::thread([this]() {
65         while (mIsActive == true) {
66             if (sCallback != nullptr) {
67                 auto antennaInfos = Utils::getMockAntennaInfos();
68                 this->reportAntennaInfo(antennaInfos);
69             }
70 
71             /** For mock implementation this is good. On real device, we should only report
72                 antennaInfo at start and when there is a configuration change. **/
73             std::this_thread::sleep_for(std::chrono::milliseconds(mMinIntervalMillis));
74         }
75     });
76 }
77 
stop()78 void GnssAntennaInfo::stop() {
79     ALOGD("stop");
80     mIsActive = false;
81     if (mThread.joinable()) {
82         mThread.join();
83     }
84 }
85 
reportAntennaInfo(const hidl_vec<IGnssAntennaInfoCallback::GnssAntennaInfo> & antennaInfo) const86 void GnssAntennaInfo::reportAntennaInfo(
87         const hidl_vec<IGnssAntennaInfoCallback::GnssAntennaInfo>& antennaInfo) const {
88     std::unique_lock<std::mutex> lock(mMutex);
89 
90     if (sCallback == nullptr) {
91         ALOGE("%s: No non-null callback", __func__);
92         return;
93     }
94 
95     auto ret = sCallback->gnssAntennaInfoCb(antennaInfo);
96     if (!ret.isOk()) {
97         ALOGE("%s: Unable to invoke callback", __func__);
98     }
99 }
100 
101 }  // namespace android::hardware::gnss::V2_1::implementation
102