blob: dbafffe303086d7308986e27d91e903b230a8892 [file] [log] [blame]
/*
* Copyright (C) 2017 The Android Open Source Project
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
#include "SensorDeviceUtils.h"
#include <android/hardware/sensors/1.0/ISensors.h>
#include <utils/Log.h>
#include <chrono>
#include <thread>
using ::android::hardware::Void;
using namespace android::hardware::sensors::V1_0;
namespace android {
namespace SensorDeviceUtils {
HidlServiceRegistrationWaiter::HidlServiceRegistrationWaiter() {
}
void HidlServiceRegistrationWaiter::onFirstRef() {
// Creating sp<...>(this) in the constructor should be avoided, hence
// registerForNotifications is called in onFirstRef callback.
mRegistered = ISensors::registerForNotifications("default", this);
}
Return<void> HidlServiceRegistrationWaiter::onRegistration(
const hidl_string &fqName, const hidl_string &name, bool preexisting) {
ALOGV("onRegistration fqName %s, name %s, preexisting %d",
fqName.c_str(), name.c_str(), preexisting);
{
std::lock_guard<std::mutex> lk(mLock);
mRestartObserved = true;
}
mCondition.notify_all();
return Void();
}
void HidlServiceRegistrationWaiter::reset() {
std::lock_guard<std::mutex> lk(mLock);
mRestartObserved = false;
}
bool HidlServiceRegistrationWaiter::wait() {
constexpr int DEFAULT_WAIT_MS = 100;
constexpr int TIMEOUT_MS = 1000;
if (!mRegistered) {
ALOGW("Cannot register service notification, use default wait(%d ms)", DEFAULT_WAIT_MS);
std::this_thread::sleep_for(std::chrono::milliseconds(DEFAULT_WAIT_MS));
// not sure if service is actually restarted
return false;
}
std::unique_lock<std::mutex> lk(mLock);
return mCondition.wait_for(lk, std::chrono::milliseconds(TIMEOUT_MS),
[this]{return mRestartObserved;});
}
} // namespace SensorDeviceUtils
} // namespace android