Merge "Move seq to header"
diff --git a/include/input/Input.h b/include/input/Input.h
index 194db1c..40d655f 100644
--- a/include/input/Input.h
+++ b/include/input/Input.h
@@ -342,6 +342,8 @@
void scale(float globalScale, float windowXScale, float windowYScale);
void applyOffset(float xOffset, float yOffset);
+ void transform(const ui::Transform& transform);
+
inline float getX() const {
return getAxisValue(AMOTION_EVENT_AXIS_X);
}
diff --git a/libs/input/Input.cpp b/libs/input/Input.cpp
index 31aa685..2ac079e 100644
--- a/libs/input/Input.cpp
+++ b/libs/input/Input.cpp
@@ -301,6 +301,11 @@
}
}
+void PointerCoords::transform(const ui::Transform& transform) {
+ vec2 newCoords = transform.transform(getX(), getY());
+ setAxisValue(AMOTION_EVENT_AXIS_X, newCoords.x);
+ setAxisValue(AMOTION_EVENT_AXIS_Y, newCoords.y);
+}
// --- PointerProperties ---
diff --git a/libs/ui/Transform.cpp b/libs/ui/Transform.cpp
index 06b6bfe..3bf3903 100644
--- a/libs/ui/Transform.cpp
+++ b/libs/ui/Transform.cpp
@@ -55,7 +55,6 @@
mMatrix[1][1] == other.mMatrix[1][1] && mMatrix[1][2] == other.mMatrix[1][2] &&
mMatrix[2][0] == other.mMatrix[2][0] && mMatrix[2][1] == other.mMatrix[2][1] &&
mMatrix[2][2] == other.mMatrix[2][2];
- ;
}
Transform Transform::operator * (const Transform& rhs) const
@@ -87,6 +86,19 @@
return r;
}
+Transform Transform::operator * (float value) const {
+ Transform r(*this);
+ const mat33& M(mMatrix);
+ mat33& R(r.mMatrix);
+ for (size_t i = 0; i < 3; i++) {
+ for (size_t j = 0; j < 2; j++) {
+ R[i][j] = M[i][j] * value;
+ }
+ }
+ r.type();
+ return r;
+}
+
Transform& Transform::operator=(const Transform& other) {
mMatrix = other.mMatrix;
mType = other.mType;
@@ -105,11 +117,19 @@
return mMatrix[2][1];
}
-float Transform::sx() const {
+float Transform::dsdx() const {
return mMatrix[0][0];
}
-float Transform::sy() const {
+float Transform::dtdx() const {
+ return mMatrix[1][0];
+}
+
+float Transform::dtdy() const {
+ return mMatrix[0][1];
+}
+
+float Transform::dsdy() const {
return mMatrix[1][1];
}
@@ -187,6 +207,15 @@
return NO_ERROR;
}
+void Transform::set(const std::array<float, 9>& matrix) {
+ mat33& M(mMatrix);
+ M[0][0] = matrix[0]; M[1][0] = matrix[1]; M[2][0] = matrix[2];
+ M[0][1] = matrix[3]; M[1][1] = matrix[4]; M[2][1] = matrix[5];
+ M[0][2] = matrix[6]; M[1][2] = matrix[7]; M[2][2] = matrix[8];
+ mType = UNKNOWN_TYPE;
+ type();
+}
+
vec2 Transform::transform(const vec2& v) const {
vec2 r;
const mat33& M(mMatrix);
@@ -204,9 +233,8 @@
return r;
}
-vec2 Transform::transform(int x, int y) const
-{
- return transform(vec2(x,y));
+vec2 Transform::transform(float x, float y) const {
+ return transform(vec2(x, y));
}
Rect Transform::makeBounds(int w, int h) const
diff --git a/libs/ui/include/ui/Transform.h b/libs/ui/include/ui/Transform.h
index 3e8caf4..cf59467 100644
--- a/libs/ui/include/ui/Transform.h
+++ b/libs/ui/include/ui/Transform.h
@@ -18,6 +18,7 @@
#include <stdint.h>
#include <sys/types.h>
+#include <array>
#include <ostream>
#include <string>
@@ -68,24 +69,28 @@
const vec3& operator [] (size_t i) const; // returns column i
float tx() const;
float ty() const;
- float sx() const;
- float sy() const;
+ float dsdx() const;
+ float dtdx() const;
+ float dtdy() const;
+ float dsdy() const;
// modify the transform
void reset();
void set(float tx, float ty);
void set(float a, float b, float c, float d);
status_t set(uint32_t flags, float w, float h);
+ void set(const std::array<float, 9>& matrix);
// transform data
Rect makeBounds(int w, int h) const;
- vec2 transform(int x, int y) const;
+ vec2 transform(float x, float y) const;
Region transform(const Region& reg) const;
Rect transform(const Rect& bounds,
bool roundOutwards = false) const;
FloatRect transform(const FloatRect& bounds) const;
Transform& operator = (const Transform& other);
Transform operator * (const Transform& rhs) const;
+ Transform operator * (float value) const;
// assumes the last row is < 0 , 0 , 1 >
vec2 transform(const vec2& v) const;
vec3 transform(const vec3& v) const;
diff --git a/services/surfaceflinger/Layer.cpp b/services/surfaceflinger/Layer.cpp
index 8cfb908..67becab 100644
--- a/services/surfaceflinger/Layer.cpp
+++ b/services/surfaceflinger/Layer.cpp
@@ -2385,8 +2385,8 @@
}
ui::Transform t = getTransform();
- const float xScale = t.sx();
- const float yScale = t.sy();
+ const float xScale = t.dsdx();
+ const float yScale = t.dsdy();
int32_t xSurfaceInset = info.surfaceInset;
int32_t ySurfaceInset = info.surfaceInset;
if (xScale != 1.0f || yScale != 1.0f) {
diff --git a/services/vibratorservice/VibratorHalController.cpp b/services/vibratorservice/VibratorHalController.cpp
index 896c162..03e51ae 100644
--- a/services/vibratorservice/VibratorHalController.cpp
+++ b/services/vibratorservice/VibratorHalController.cpp
@@ -47,105 +47,77 @@
static constexpr int MAX_RETRIES = 1;
-template <typename T>
-using hal_connect_fn = std::function<sp<T>()>;
-
-template <typename T>
-sp<T> connectToHal(bool* halExists, const hal_connect_fn<T>& connectFn, const char* halName) {
- if (!*halExists) {
+std::shared_ptr<HalWrapper> HalConnector::connect(std::shared_ptr<CallbackScheduler> scheduler) {
+ static bool gHalExists = true;
+ if (!gHalExists) {
+ // We already tried to connect to all of the vibrator HAL versions and none was available.
return nullptr;
}
- sp<T> hal = connectFn();
- if (hal) {
- ALOGV("Successfully connected to Vibrator HAL %s service.", halName);
- } else {
- ALOGV("Vibrator HAL %s service not available.", halName);
- *halExists = false;
- }
- return hal;
-}
-sp<Aidl::IVibrator> connectToAidl() {
- static bool gHalExists = true;
- static hal_connect_fn<Aidl::IVibrator> connectFn = []() {
- return waitForVintfService<Aidl::IVibrator>();
- };
- return connectToHal(&gHalExists, connectFn, "AIDL");
-}
-
-sp<V1_0::IVibrator> connectToHidl() {
- static bool gHalExists = true;
- static hal_connect_fn<V1_0::IVibrator> connectFn = []() {
- return V1_0::IVibrator::getService();
- };
- return connectToHal(&gHalExists, connectFn, "v1.0");
-}
-
-// -------------------------------------------------------------------------------------------------
-
-std::shared_ptr<HalWrapper> HalConnector::connect(std::shared_ptr<CallbackScheduler> scheduler) {
- sp<Aidl::IVibrator> aidlHal = connectToAidl();
+ sp<Aidl::IVibrator> aidlHal = waitForVintfService<Aidl::IVibrator>();
if (aidlHal) {
+ ALOGV("Successfully connected to Vibrator HAL AIDL service.");
return std::make_shared<AidlHalWrapper>(std::move(scheduler), aidlHal);
}
- sp<V1_0::IVibrator> halV1_0 = connectToHidl();
+
+ sp<V1_0::IVibrator> halV1_0 = V1_0::IVibrator::getService();
if (halV1_0 == nullptr) {
- // No Vibrator HAL service available.
+ ALOGV("Vibrator HAL service not available.");
+ gHalExists = false;
return nullptr;
}
+
sp<V1_3::IVibrator> halV1_3 = V1_3::IVibrator::castFrom(halV1_0);
if (halV1_3) {
- ALOGV("Successfully converted to Vibrator HAL v1.3 service.");
+ ALOGV("Successfully connected to Vibrator HAL v1.3 service.");
return std::make_shared<HidlHalWrapperV1_3>(std::move(scheduler), halV1_3);
}
sp<V1_2::IVibrator> halV1_2 = V1_2::IVibrator::castFrom(halV1_0);
if (halV1_2) {
- ALOGV("Successfully converted to Vibrator HAL v1.2 service.");
+ ALOGV("Successfully connected to Vibrator HAL v1.2 service.");
return std::make_shared<HidlHalWrapperV1_2>(std::move(scheduler), halV1_2);
}
sp<V1_1::IVibrator> halV1_1 = V1_1::IVibrator::castFrom(halV1_0);
if (halV1_1) {
- ALOGV("Successfully converted to Vibrator HAL v1.1 service.");
+ ALOGV("Successfully connected to Vibrator HAL v1.1 service.");
return std::make_shared<HidlHalWrapperV1_1>(std::move(scheduler), halV1_1);
}
+ ALOGV("Successfully connected to Vibrator HAL v1.0 service.");
return std::make_shared<HidlHalWrapperV1_0>(std::move(scheduler), halV1_0);
}
// -------------------------------------------------------------------------------------------------
-std::shared_ptr<HalWrapper> HalController::initHal() {
- std::lock_guard<std::mutex> lock(mConnectedHalMutex);
- if (mConnectedHal == nullptr) {
- mConnectedHal = mHalConnector->connect(mCallbackScheduler);
- }
- return mConnectedHal;
-}
-
template <typename T>
HalResult<T> HalController::processHalResult(HalResult<T> result, const char* functionName) {
if (result.isFailed()) {
ALOGE("%s failed: Vibrator HAL not available", functionName);
std::lock_guard<std::mutex> lock(mConnectedHalMutex);
- // Drop HAL handle. This will force future api calls to reconnect.
- mConnectedHal = nullptr;
+ mConnectedHal->tryReconnect();
}
return result;
}
template <typename T>
HalResult<T> HalController::apply(HalController::hal_fn<T>& halFn, const char* functionName) {
- std::shared_ptr<HalWrapper> hal = initHal();
- if (hal == nullptr) {
- ALOGV("Skipped %s because Vibrator HAL is not available", functionName);
- return HalResult<T>::unsupported();
+ std::shared_ptr<HalWrapper> hal = nullptr;
+ {
+ std::lock_guard<std::mutex> lock(mConnectedHalMutex);
+ if (mConnectedHal == nullptr) {
+ // Init was never called, so connect to HAL for the first time during this call.
+ mConnectedHal = mHalConnector->connect(mCallbackScheduler);
+
+ if (mConnectedHal == nullptr) {
+ ALOGV("Skipped %s because Vibrator HAL is not available", functionName);
+ return HalResult<T>::unsupported();
+ }
+ }
+ hal = mConnectedHal;
}
HalResult<T> ret = processHalResult(halFn(hal), functionName);
for (int i = 0; i < MAX_RETRIES && ret.isFailed(); i++) {
- hal = initHal();
- if (hal) {
- ret = processHalResult(halFn(hal), functionName);
- }
+ ret = processHalResult(halFn(hal), functionName);
}
return ret;
@@ -153,11 +125,27 @@
// -------------------------------------------------------------------------------------------------
+void HalController::init() {
+ std::lock_guard<std::mutex> lock(mConnectedHalMutex);
+ if (mConnectedHal == nullptr) {
+ mConnectedHal = mHalConnector->connect(mCallbackScheduler);
+ }
+}
+
HalResult<void> HalController::ping() {
hal_fn<void> pingFn = [](std::shared_ptr<HalWrapper> hal) { return hal->ping(); };
return apply(pingFn, "ping");
}
+void HalController::tryReconnect() {
+ std::lock_guard<std::mutex> lock(mConnectedHalMutex);
+ if (mConnectedHal == nullptr) {
+ mConnectedHal = mHalConnector->connect(mCallbackScheduler);
+ } else {
+ mConnectedHal->tryReconnect();
+ }
+}
+
HalResult<void> HalController::on(milliseconds timeout,
const std::function<void()>& completionCallback) {
hal_fn<void> onFn = [&](std::shared_ptr<HalWrapper> hal) {
diff --git a/services/vibratorservice/VibratorHalWrapper.cpp b/services/vibratorservice/VibratorHalWrapper.cpp
index 94db538..9d219ff 100644
--- a/services/vibratorservice/VibratorHalWrapper.cpp
+++ b/services/vibratorservice/VibratorHalWrapper.cpp
@@ -149,8 +149,16 @@
// -------------------------------------------------------------------------------------------------
HalResult<void> AidlHalWrapper::ping() {
- return IInterface::asBinder(mHandle)->pingBinder() ? HalResult<void>::ok()
- : HalResult<void>::failed();
+ return IInterface::asBinder(getHal())->pingBinder() ? HalResult<void>::ok()
+ : HalResult<void>::failed();
+}
+
+void AidlHalWrapper::tryReconnect() {
+ sp<Aidl::IVibrator> newHandle = checkVintfService<Aidl::IVibrator>();
+ if (newHandle) {
+ std::lock_guard<std::mutex> lock(mHandleMutex);
+ mHandle = std::move(newHandle);
+ }
}
HalResult<void> AidlHalWrapper::on(milliseconds timeout,
@@ -160,7 +168,7 @@
static_cast<int32_t>(capabilities.value() & Capabilities::ON_CALLBACK);
auto cb = supportsCallback ? new HalCallbackWrapper(completionCallback) : nullptr;
- auto ret = HalResult<void>::fromStatus(mHandle->on(timeout.count(), cb));
+ auto ret = HalResult<void>::fromStatus(getHal()->on(timeout.count(), cb));
if (!supportsCallback && ret.isOk()) {
mCallbackScheduler->schedule(completionCallback, timeout);
}
@@ -169,24 +177,24 @@
}
HalResult<void> AidlHalWrapper::off() {
- return HalResult<void>::fromStatus(mHandle->off());
+ return HalResult<void>::fromStatus(getHal()->off());
}
HalResult<void> AidlHalWrapper::setAmplitude(int32_t amplitude) {
float convertedAmplitude = static_cast<float>(amplitude) / std::numeric_limits<uint8_t>::max();
- return HalResult<void>::fromStatus(mHandle->setAmplitude(convertedAmplitude));
+ return HalResult<void>::fromStatus(getHal()->setAmplitude(convertedAmplitude));
}
HalResult<void> AidlHalWrapper::setExternalControl(bool enabled) {
- return HalResult<void>::fromStatus(mHandle->setExternalControl(enabled));
+ return HalResult<void>::fromStatus(getHal()->setExternalControl(enabled));
}
HalResult<void> AidlHalWrapper::alwaysOnEnable(int32_t id, Effect effect, EffectStrength strength) {
- return HalResult<void>::fromStatus(mHandle->alwaysOnEnable(id, effect, strength));
+ return HalResult<void>::fromStatus(getHal()->alwaysOnEnable(id, effect, strength));
}
HalResult<void> AidlHalWrapper::alwaysOnDisable(int32_t id) {
- return HalResult<void>::fromStatus(mHandle->alwaysOnDisable(id));
+ return HalResult<void>::fromStatus(getHal()->alwaysOnDisable(id));
}
HalResult<Capabilities> AidlHalWrapper::getCapabilities() {
@@ -210,7 +218,7 @@
auto cb = supportsCallback ? new HalCallbackWrapper(completionCallback) : nullptr;
int32_t lengthMs;
- auto result = mHandle->perform(effect, strength, cb, &lengthMs);
+ auto result = getHal()->perform(effect, strength, cb, &lengthMs);
milliseconds length = milliseconds(lengthMs);
auto ret = HalResult<milliseconds>::fromStatus(result, length);
@@ -226,31 +234,47 @@
const std::function<void()>& completionCallback) {
// This method should always support callbacks, so no need to double check.
auto cb = new HalCallbackWrapper(completionCallback);
- return HalResult<void>::fromStatus(mHandle->compose(primitiveEffects, cb));
+ return HalResult<void>::fromStatus(getHal()->compose(primitiveEffects, cb));
}
HalResult<Capabilities> AidlHalWrapper::getCapabilitiesInternal() {
int32_t capabilities = 0;
- auto result = mHandle->getCapabilities(&capabilities);
+ auto result = getHal()->getCapabilities(&capabilities);
return HalResult<Capabilities>::fromStatus(result, static_cast<Capabilities>(capabilities));
}
HalResult<std::vector<Effect>> AidlHalWrapper::getSupportedEffectsInternal() {
std::vector<Effect> supportedEffects;
- auto result = mHandle->getSupportedEffects(&supportedEffects);
+ auto result = getHal()->getSupportedEffects(&supportedEffects);
return HalResult<std::vector<Effect>>::fromStatus(result, supportedEffects);
}
+sp<Aidl::IVibrator> AidlHalWrapper::getHal() {
+ std::lock_guard<std::mutex> lock(mHandleMutex);
+ return mHandle;
+}
+
// -------------------------------------------------------------------------------------------------
-HalResult<void> HidlHalWrapperV1_0::ping() {
- auto result = mHandleV1_0->ping();
+template <typename I>
+HalResult<void> HidlHalWrapper<I>::ping() {
+ auto result = getHal()->ping();
return HalResult<void>::fromReturn(result);
}
-HalResult<void> HidlHalWrapperV1_0::on(milliseconds timeout,
- const std::function<void()>& completionCallback) {
- auto result = mHandleV1_0->on(timeout.count());
+template <typename I>
+void HidlHalWrapper<I>::tryReconnect() {
+ sp<I> newHandle = I::tryGetService();
+ if (newHandle) {
+ std::lock_guard<std::mutex> lock(mHandleMutex);
+ mHandle = std::move(newHandle);
+ }
+}
+
+template <typename I>
+HalResult<void> HidlHalWrapper<I>::on(milliseconds timeout,
+ const std::function<void()>& completionCallback) {
+ auto result = getHal()->on(timeout.count());
auto ret = HalResult<void>::fromStatus(result.withDefault(V1_0::Status::UNKNOWN_ERROR));
if (ret.isOk()) {
mCallbackScheduler->schedule(completionCallback, timeout);
@@ -258,69 +282,68 @@
return ret;
}
-HalResult<void> HidlHalWrapperV1_0::off() {
- auto result = mHandleV1_0->off();
+template <typename I>
+HalResult<void> HidlHalWrapper<I>::off() {
+ auto result = getHal()->off();
return HalResult<void>::fromStatus(result.withDefault(V1_0::Status::UNKNOWN_ERROR));
}
-HalResult<void> HidlHalWrapperV1_0::setAmplitude(int32_t amplitude) {
- auto result = mHandleV1_0->setAmplitude(static_cast<uint8_t>(amplitude));
+template <typename I>
+HalResult<void> HidlHalWrapper<I>::setAmplitude(int32_t amplitude) {
+ auto result = getHal()->setAmplitude(static_cast<uint8_t>(amplitude));
return HalResult<void>::fromStatus(result.withDefault(V1_0::Status::UNKNOWN_ERROR));
}
-HalResult<void> HidlHalWrapperV1_0::setExternalControl(bool) {
+template <typename I>
+HalResult<void> HidlHalWrapper<I>::setExternalControl(bool) {
ALOGV("Skipped setExternalControl because Vibrator HAL does not support it");
return HalResult<void>::unsupported();
}
-HalResult<void> HidlHalWrapperV1_0::alwaysOnEnable(int32_t, Effect, EffectStrength) {
+template <typename I>
+HalResult<void> HidlHalWrapper<I>::alwaysOnEnable(int32_t, Effect, EffectStrength) {
ALOGV("Skipped alwaysOnEnable because Vibrator HAL AIDL is not available");
return HalResult<void>::unsupported();
}
-HalResult<void> HidlHalWrapperV1_0::alwaysOnDisable(int32_t) {
+template <typename I>
+HalResult<void> HidlHalWrapper<I>::alwaysOnDisable(int32_t) {
ALOGV("Skipped alwaysOnDisable because Vibrator HAL AIDL is not available");
return HalResult<void>::unsupported();
}
-HalResult<Capabilities> HidlHalWrapperV1_0::getCapabilities() {
+template <typename I>
+HalResult<Capabilities> HidlHalWrapper<I>::getCapabilities() {
std::lock_guard<std::mutex> lock(mCapabilitiesMutex);
- return loadCached<Capabilities>(std::bind(&HidlHalWrapperV1_0::getCapabilitiesInternal, this),
+ return loadCached<Capabilities>(std::bind(&HidlHalWrapper<I>::getCapabilitiesInternal, this),
mCapabilities);
}
-HalResult<std::vector<Effect>> HidlHalWrapperV1_0::getSupportedEffects() {
+template <typename I>
+HalResult<std::vector<Effect>> HidlHalWrapper<I>::getSupportedEffects() {
ALOGV("Skipped getSupportedEffects because Vibrator HAL AIDL is not available");
return HalResult<std::vector<Effect>>::unsupported();
}
-HalResult<milliseconds> HidlHalWrapperV1_0::performEffect(
- Effect effect, EffectStrength strength, const std::function<void()>& completionCallback) {
- if (isStaticCastValid<V1_0::Effect>(effect)) {
- return performInternalV1_0(effect, strength, completionCallback);
- }
-
- ALOGV("Skipped performEffect because Vibrator HAL does not support effect %s",
- Aidl::toString(effect).c_str());
- return HalResult<milliseconds>::unsupported();
-}
-
-HalResult<void> HidlHalWrapperV1_0::performComposedEffect(const std::vector<CompositeEffect>&,
- const std::function<void()>&) {
+template <typename I>
+HalResult<void> HidlHalWrapper<I>::performComposedEffect(const std::vector<CompositeEffect>&,
+ const std::function<void()>&) {
ALOGV("Skipped composed effect because Vibrator HAL AIDL is not available");
return HalResult<void>::unsupported();
}
-HalResult<Capabilities> HidlHalWrapperV1_0::getCapabilitiesInternal() {
- hardware::Return<bool> result = mHandleV1_0->supportsAmplitudeControl();
+template <typename I>
+HalResult<Capabilities> HidlHalWrapper<I>::getCapabilitiesInternal() {
+ hardware::Return<bool> result = getHal()->supportsAmplitudeControl();
Capabilities capabilities =
result.withDefault(false) ? Capabilities::AMPLITUDE_CONTROL : Capabilities::NONE;
return HalResult<Capabilities>::fromReturn(result, capabilities);
}
-template <class I, class T>
-HalResult<milliseconds> HidlHalWrapperV1_0::performInternal(
- perform_fn<I, T> performFn, sp<I> handle, T effect, EffectStrength strength,
+template <typename I>
+template <typename T>
+HalResult<milliseconds> HidlHalWrapper<I>::performInternal(
+ perform_fn<T> performFn, sp<I> handle, T effect, EffectStrength strength,
const std::function<void()>& completionCallback) {
V1_0::Status status;
int32_t lengthMs;
@@ -341,10 +364,24 @@
return ret;
}
-HalResult<milliseconds> HidlHalWrapperV1_0::performInternalV1_0(
+template <typename I>
+sp<I> HidlHalWrapper<I>::getHal() {
+ std::lock_guard<std::mutex> lock(mHandleMutex);
+ return mHandle;
+}
+
+// -------------------------------------------------------------------------------------------------
+
+HalResult<milliseconds> HidlHalWrapperV1_0::performEffect(
Effect effect, EffectStrength strength, const std::function<void()>& completionCallback) {
- V1_0::Effect e = static_cast<V1_0::Effect>(effect);
- return performInternal(&V1_0::IVibrator::perform, mHandleV1_0, e, strength, completionCallback);
+ if (isStaticCastValid<V1_0::Effect>(effect)) {
+ return performInternal(&V1_0::IVibrator::perform, getHal(),
+ static_cast<V1_0::Effect>(effect), strength, completionCallback);
+ }
+
+ ALOGV("Skipped performEffect because Vibrator HAL does not support effect %s",
+ Aidl::toString(effect).c_str());
+ return HalResult<milliseconds>::unsupported();
}
// -------------------------------------------------------------------------------------------------
@@ -352,10 +389,12 @@
HalResult<milliseconds> HidlHalWrapperV1_1::performEffect(
Effect effect, EffectStrength strength, const std::function<void()>& completionCallback) {
if (isStaticCastValid<V1_0::Effect>(effect)) {
- return performInternalV1_0(effect, strength, completionCallback);
+ return performInternal(&V1_1::IVibrator::perform, getHal(),
+ static_cast<V1_0::Effect>(effect), strength, completionCallback);
}
if (isStaticCastValid<V1_1::Effect_1_1>(effect)) {
- return performInternalV1_1(effect, strength, completionCallback);
+ return performInternal(&V1_1::IVibrator::perform_1_1, getHal(),
+ static_cast<V1_1::Effect_1_1>(effect), strength, completionCallback);
}
ALOGV("Skipped performEffect because Vibrator HAL does not support effect %s",
@@ -363,25 +402,21 @@
return HalResult<milliseconds>::unsupported();
}
-HalResult<milliseconds> HidlHalWrapperV1_1::performInternalV1_1(
- Effect effect, EffectStrength strength, const std::function<void()>& completionCallback) {
- V1_1::Effect_1_1 e = static_cast<V1_1::Effect_1_1>(effect);
- return performInternal(&V1_1::IVibrator::perform_1_1, mHandleV1_1, e, strength,
- completionCallback);
-}
-
// -------------------------------------------------------------------------------------------------
HalResult<milliseconds> HidlHalWrapperV1_2::performEffect(
Effect effect, EffectStrength strength, const std::function<void()>& completionCallback) {
if (isStaticCastValid<V1_0::Effect>(effect)) {
- return performInternalV1_0(effect, strength, completionCallback);
+ return performInternal(&V1_2::IVibrator::perform, getHal(),
+ static_cast<V1_0::Effect>(effect), strength, completionCallback);
}
if (isStaticCastValid<V1_1::Effect_1_1>(effect)) {
- return performInternalV1_1(effect, strength, completionCallback);
+ return performInternal(&V1_2::IVibrator::perform_1_1, getHal(),
+ static_cast<V1_1::Effect_1_1>(effect), strength, completionCallback);
}
if (isStaticCastValid<V1_2::Effect>(effect)) {
- return performInternalV1_2(effect, strength, completionCallback);
+ return performInternal(&V1_2::IVibrator::perform_1_2, getHal(),
+ static_cast<V1_2::Effect>(effect), strength, completionCallback);
}
ALOGV("Skipped performEffect because Vibrator HAL does not support effect %s",
@@ -389,33 +424,30 @@
return HalResult<milliseconds>::unsupported();
}
-HalResult<milliseconds> HidlHalWrapperV1_2::performInternalV1_2(
- Effect effect, EffectStrength strength, const std::function<void()>& completionCallback) {
- V1_2::Effect e = static_cast<V1_2::Effect>(effect);
- return performInternal(&V1_2::IVibrator::perform_1_2, mHandleV1_2, e, strength,
- completionCallback);
-}
-
// -------------------------------------------------------------------------------------------------
HalResult<void> HidlHalWrapperV1_3::setExternalControl(bool enabled) {
- auto result = mHandleV1_3->setExternalControl(static_cast<uint32_t>(enabled));
+ auto result = getHal()->setExternalControl(static_cast<uint32_t>(enabled));
return HalResult<void>::fromStatus(result.withDefault(V1_0::Status::UNKNOWN_ERROR));
}
HalResult<milliseconds> HidlHalWrapperV1_3::performEffect(
Effect effect, EffectStrength strength, const std::function<void()>& completionCallback) {
if (isStaticCastValid<V1_0::Effect>(effect)) {
- return performInternalV1_0(effect, strength, completionCallback);
+ return performInternal(&V1_3::IVibrator::perform, getHal(),
+ static_cast<V1_0::Effect>(effect), strength, completionCallback);
}
if (isStaticCastValid<V1_1::Effect_1_1>(effect)) {
- return performInternalV1_1(effect, strength, completionCallback);
+ return performInternal(&V1_3::IVibrator::perform_1_1, getHal(),
+ static_cast<V1_1::Effect_1_1>(effect), strength, completionCallback);
}
if (isStaticCastValid<V1_2::Effect>(effect)) {
- return performInternalV1_2(effect, strength, completionCallback);
+ return performInternal(&V1_3::IVibrator::perform_1_2, getHal(),
+ static_cast<V1_2::Effect>(effect), strength, completionCallback);
}
if (isStaticCastValid<V1_3::Effect>(effect)) {
- return performInternalV1_3(effect, strength, completionCallback);
+ return performInternal(&V1_3::IVibrator::perform_1_3, getHal(),
+ static_cast<V1_3::Effect>(effect), strength, completionCallback);
}
ALOGV("Skipped performEffect because Vibrator HAL does not support effect %s",
@@ -424,23 +456,23 @@
}
HalResult<Capabilities> HidlHalWrapperV1_3::getCapabilitiesInternal() {
- HalResult<Capabilities> parentResult = HidlHalWrapperV1_2::getCapabilitiesInternal();
- if (!parentResult.isOk()) {
- // Loading for previous HAL versions already failed, so propagate failure.
- return parentResult;
+ sp<V1_3::IVibrator> hal = getHal();
+ auto amplitudeResult = hal->supportsAmplitudeControl();
+ if (!amplitudeResult.isOk()) {
+ return HalResult<Capabilities>::failed();
}
- Capabilities capabilities = parentResult.value();
- auto result = mHandleV1_3->supportsExternalControl();
- capabilities |= result.withDefault(false) ? Capabilities::EXTERNAL_CONTROL : Capabilities::NONE;
- return HalResult<Capabilities>::fromReturn(result, capabilities);
-}
+ auto externalControlResult = hal->supportsExternalControl();
+ Capabilities capabilities = Capabilities::NONE;
-HalResult<milliseconds> HidlHalWrapperV1_3::performInternalV1_3(
- Effect effect, EffectStrength strength, const std::function<void()>& completionCallback) {
- V1_3::Effect e = static_cast<V1_3::Effect>(effect);
- return performInternal(&V1_3::IVibrator::perform_1_3, mHandleV1_3, e, strength,
- completionCallback);
+ if (amplitudeResult.withDefault(false)) {
+ capabilities |= Capabilities::AMPLITUDE_CONTROL;
+ }
+ if (externalControlResult.withDefault(false)) {
+ capabilities |= Capabilities::EXTERNAL_CONTROL;
+ }
+
+ return HalResult<Capabilities>::fromReturn(externalControlResult, capabilities);
}
// -------------------------------------------------------------------------------------------------
diff --git a/services/vibratorservice/include/vibratorservice/VibratorHalController.h b/services/vibratorservice/include/vibratorservice/VibratorHalController.h
index 1fb7d05..daf2c8c 100644
--- a/services/vibratorservice/include/vibratorservice/VibratorHalController.h
+++ b/services/vibratorservice/include/vibratorservice/VibratorHalController.h
@@ -51,7 +51,10 @@
mConnectedHal(nullptr) {}
virtual ~HalController() = default;
+ void init();
+
HalResult<void> ping() final override;
+ void tryReconnect() final override;
HalResult<void> on(std::chrono::milliseconds timeout,
const std::function<void()>& completionCallback) final override;
@@ -81,8 +84,6 @@
// Shared pointer to allow local copies to be used by different threads.
std::shared_ptr<HalWrapper> mConnectedHal GUARDED_BY(mConnectedHalMutex);
- std::shared_ptr<HalWrapper> initHal();
-
template <typename T>
HalResult<T> processHalResult(HalResult<T> result, const char* functionName);
diff --git a/services/vibratorservice/include/vibratorservice/VibratorHalWrapper.h b/services/vibratorservice/include/vibratorservice/VibratorHalWrapper.h
index 5e3c275..a4fa869 100644
--- a/services/vibratorservice/include/vibratorservice/VibratorHalWrapper.h
+++ b/services/vibratorservice/include/vibratorservice/VibratorHalWrapper.h
@@ -20,6 +20,7 @@
#include <android-base/thread_annotations.h>
#include <android/hardware/vibrator/1.3/IVibrator.h>
#include <android/hardware/vibrator/IVibrator.h>
+#include <binder/IServiceManager.h>
#include <vibratorservice/VibratorCallbackScheduler.h>
@@ -131,6 +132,7 @@
virtual ~HalWrapper() = default;
virtual HalResult<void> ping() = 0;
+ virtual void tryReconnect() = 0;
virtual HalResult<void> on(std::chrono::milliseconds timeout,
const std::function<void()>& completionCallback) = 0;
@@ -167,34 +169,36 @@
: HalWrapper(std::move(scheduler)), mHandle(std::move(handle)) {}
virtual ~AidlHalWrapper() = default;
- virtual HalResult<void> ping() override;
+ HalResult<void> ping() override final;
+ void tryReconnect() override final;
- virtual HalResult<void> on(std::chrono::milliseconds timeout,
- const std::function<void()>& completionCallback) override;
- virtual HalResult<void> off() override;
+ HalResult<void> on(std::chrono::milliseconds timeout,
+ const std::function<void()>& completionCallback) override final;
+ HalResult<void> off() override final;
- virtual HalResult<void> setAmplitude(int32_t amplitude) override;
- virtual HalResult<void> setExternalControl(bool enabled) override;
+ HalResult<void> setAmplitude(int32_t amplitude) override final;
+ HalResult<void> setExternalControl(bool enabled) override final;
- virtual HalResult<void> alwaysOnEnable(int32_t id, hardware::vibrator::Effect effect,
- hardware::vibrator::EffectStrength strength) override;
- virtual HalResult<void> alwaysOnDisable(int32_t id) override;
+ HalResult<void> alwaysOnEnable(int32_t id, hardware::vibrator::Effect effect,
+ hardware::vibrator::EffectStrength strength) override final;
+ HalResult<void> alwaysOnDisable(int32_t id) override final;
- virtual HalResult<Capabilities> getCapabilities() override;
- virtual HalResult<std::vector<hardware::vibrator::Effect>> getSupportedEffects() override;
+ HalResult<Capabilities> getCapabilities() override final;
+ HalResult<std::vector<hardware::vibrator::Effect>> getSupportedEffects() override final;
- virtual HalResult<std::chrono::milliseconds> performEffect(
+ HalResult<std::chrono::milliseconds> performEffect(
hardware::vibrator::Effect effect, hardware::vibrator::EffectStrength strength,
- const std::function<void()>& completionCallback) override;
+ const std::function<void()>& completionCallback) override final;
- virtual HalResult<void> performComposedEffect(
+ HalResult<void> performComposedEffect(
const std::vector<hardware::vibrator::CompositeEffect>& primitiveEffects,
- const std::function<void()>& completionCallback) override;
+ const std::function<void()>& completionCallback) override final;
private:
- const sp<hardware::vibrator::IVibrator> mHandle;
+ std::mutex mHandleMutex;
std::mutex mCapabilitiesMutex;
std::mutex mSupportedEffectsMutex;
+ sp<hardware::vibrator::IVibrator> mHandle GUARDED_BY(mHandleMutex);
std::optional<Capabilities> mCapabilities GUARDED_BY(mCapabilitiesMutex);
std::optional<std::vector<hardware::vibrator::Effect>> mSupportedEffects
GUARDED_BY(mSupportedEffectsMutex);
@@ -202,125 +206,120 @@
// Loads directly from IVibrator handle, skipping caches.
HalResult<Capabilities> getCapabilitiesInternal();
HalResult<std::vector<hardware::vibrator::Effect>> getSupportedEffectsInternal();
+ sp<hardware::vibrator::IVibrator> getHal();
};
-// Wrapper for the HDIL Vibrator HAL v1.0.
-class HidlHalWrapperV1_0 : public HalWrapper {
+// Wrapper for the HDIL Vibrator HALs.
+template <typename I>
+class HidlHalWrapper : public HalWrapper {
public:
- HidlHalWrapperV1_0(std::shared_ptr<CallbackScheduler> scheduler,
- sp<hardware::vibrator::V1_0::IVibrator> handle)
- : HalWrapper(std::move(scheduler)), mHandleV1_0(std::move(handle)) {}
- virtual ~HidlHalWrapperV1_0() = default;
+ HidlHalWrapper(std::shared_ptr<CallbackScheduler> scheduler, sp<I> handle)
+ : HalWrapper(std::move(scheduler)), mHandle(std::move(handle)) {}
+ virtual ~HidlHalWrapper() = default;
- virtual HalResult<void> ping() override;
+ HalResult<void> ping() override final;
+ void tryReconnect() override final;
- virtual HalResult<void> on(std::chrono::milliseconds timeout,
- const std::function<void()>& completionCallback) override;
- virtual HalResult<void> off() override;
+ HalResult<void> on(std::chrono::milliseconds timeout,
+ const std::function<void()>& completionCallback) override final;
+ HalResult<void> off() override final;
- virtual HalResult<void> setAmplitude(int32_t amplitude) override;
+ HalResult<void> setAmplitude(int32_t amplitude) override final;
virtual HalResult<void> setExternalControl(bool enabled) override;
- virtual HalResult<void> alwaysOnEnable(int32_t id, hardware::vibrator::Effect effect,
- hardware::vibrator::EffectStrength strength) override;
- virtual HalResult<void> alwaysOnDisable(int32_t id) override;
+ HalResult<void> alwaysOnEnable(int32_t id, hardware::vibrator::Effect effect,
+ hardware::vibrator::EffectStrength strength) override final;
+ HalResult<void> alwaysOnDisable(int32_t id) override final;
- virtual HalResult<Capabilities> getCapabilities() override;
- virtual HalResult<std::vector<hardware::vibrator::Effect>> getSupportedEffects() override;
+ HalResult<Capabilities> getCapabilities() override final;
+ HalResult<std::vector<hardware::vibrator::Effect>> getSupportedEffects() override final;
- virtual HalResult<std::chrono::milliseconds> performEffect(
- hardware::vibrator::Effect effect, hardware::vibrator::EffectStrength strength,
- const std::function<void()>& completionCallback) override;
-
- virtual HalResult<void> performComposedEffect(
+ HalResult<void> performComposedEffect(
const std::vector<hardware::vibrator::CompositeEffect>& primitiveEffects,
- const std::function<void()>& completionCallback) override;
+ const std::function<void()>& completionCallback) override final;
protected:
- const sp<hardware::vibrator::V1_0::IVibrator> mHandleV1_0;
+ std::mutex mHandleMutex;
std::mutex mCapabilitiesMutex;
+ sp<I> mHandle GUARDED_BY(mHandleMutex);
std::optional<Capabilities> mCapabilities GUARDED_BY(mCapabilitiesMutex);
// Loads directly from IVibrator handle, skipping the mCapabilities cache.
virtual HalResult<Capabilities> getCapabilitiesInternal();
- template <class I, class T>
+ template <class T>
using perform_fn =
hardware::Return<void> (I::*)(T, hardware::vibrator::V1_0::EffectStrength,
hardware::vibrator::V1_0::IVibrator::perform_cb);
- template <class I, class T>
+ template <class T>
HalResult<std::chrono::milliseconds> performInternal(
- perform_fn<I, T> performFn, sp<I> handle, T effect,
+ perform_fn<T> performFn, sp<I> handle, T effect,
hardware::vibrator::EffectStrength strength,
const std::function<void()>& completionCallback);
- HalResult<std::chrono::milliseconds> performInternalV1_0(
+ sp<I> getHal();
+};
+
+// Wrapper for the HDIL Vibrator HAL v1.0.
+class HidlHalWrapperV1_0 : public HidlHalWrapper<hardware::vibrator::V1_0::IVibrator> {
+public:
+ HidlHalWrapperV1_0(std::shared_ptr<CallbackScheduler> scheduler,
+ sp<hardware::vibrator::V1_0::IVibrator> handle)
+ : HidlHalWrapper<hardware::vibrator::V1_0::IVibrator>(std::move(scheduler),
+ std::move(handle)) {}
+ virtual ~HidlHalWrapperV1_0() = default;
+
+ HalResult<std::chrono::milliseconds> performEffect(
hardware::vibrator::Effect effect, hardware::vibrator::EffectStrength strength,
- const std::function<void()>& completionCallback);
+ const std::function<void()>& completionCallback) override final;
};
// Wrapper for the HDIL Vibrator HAL v1.1.
-class HidlHalWrapperV1_1 : public HidlHalWrapperV1_0 {
+class HidlHalWrapperV1_1 : public HidlHalWrapper<hardware::vibrator::V1_1::IVibrator> {
public:
HidlHalWrapperV1_1(std::shared_ptr<CallbackScheduler> scheduler,
sp<hardware::vibrator::V1_1::IVibrator> handle)
- : HidlHalWrapperV1_0(std::move(scheduler), handle), mHandleV1_1(handle) {}
+ : HidlHalWrapper<hardware::vibrator::V1_1::IVibrator>(std::move(scheduler),
+ std::move(handle)) {}
virtual ~HidlHalWrapperV1_1() = default;
- virtual HalResult<std::chrono::milliseconds> performEffect(
+ HalResult<std::chrono::milliseconds> performEffect(
hardware::vibrator::Effect effect, hardware::vibrator::EffectStrength strength,
- const std::function<void()>& completionCallback) override;
-
-protected:
- const sp<hardware::vibrator::V1_1::IVibrator> mHandleV1_1;
-
- HalResult<std::chrono::milliseconds> performInternalV1_1(
- hardware::vibrator::Effect effect, hardware::vibrator::EffectStrength strength,
- const std::function<void()>& completionCallback);
+ const std::function<void()>& completionCallback) override final;
};
// Wrapper for the HDIL Vibrator HAL v1.2.
-class HidlHalWrapperV1_2 : public HidlHalWrapperV1_1 {
+class HidlHalWrapperV1_2 : public HidlHalWrapper<hardware::vibrator::V1_2::IVibrator> {
public:
HidlHalWrapperV1_2(std::shared_ptr<CallbackScheduler> scheduler,
sp<hardware::vibrator::V1_2::IVibrator> handle)
- : HidlHalWrapperV1_1(std::move(scheduler), handle), mHandleV1_2(handle) {}
+ : HidlHalWrapper<hardware::vibrator::V1_2::IVibrator>(std::move(scheduler),
+ std::move(handle)) {}
virtual ~HidlHalWrapperV1_2() = default;
- virtual HalResult<std::chrono::milliseconds> performEffect(
+ HalResult<std::chrono::milliseconds> performEffect(
hardware::vibrator::Effect effect, hardware::vibrator::EffectStrength strength,
- const std::function<void()>& completionCallback) override;
-
-protected:
- const sp<hardware::vibrator::V1_2::IVibrator> mHandleV1_2;
-
- HalResult<std::chrono::milliseconds> performInternalV1_2(
- hardware::vibrator::Effect effect, hardware::vibrator::EffectStrength strength,
- const std::function<void()>& completionCallback);
+ const std::function<void()>& completionCallback) override final;
};
// Wrapper for the HDIL Vibrator HAL v1.3.
-class HidlHalWrapperV1_3 : public HidlHalWrapperV1_2 {
+class HidlHalWrapperV1_3 : public HidlHalWrapper<hardware::vibrator::V1_3::IVibrator> {
public:
HidlHalWrapperV1_3(std::shared_ptr<CallbackScheduler> scheduler,
sp<hardware::vibrator::V1_3::IVibrator> handle)
- : HidlHalWrapperV1_2(std::move(scheduler), handle), mHandleV1_3(handle) {}
+ : HidlHalWrapper<hardware::vibrator::V1_3::IVibrator>(std::move(scheduler),
+ std::move(handle)) {}
virtual ~HidlHalWrapperV1_3() = default;
- virtual HalResult<void> setExternalControl(bool enabled) override;
+ HalResult<void> setExternalControl(bool enabled) override final;
- virtual HalResult<std::chrono::milliseconds> performEffect(
+ HalResult<std::chrono::milliseconds> performEffect(
hardware::vibrator::Effect effect, hardware::vibrator::EffectStrength strength,
- const std::function<void()>& completionCallback) override;
+ const std::function<void()>& completionCallback) override final;
protected:
- const sp<hardware::vibrator::V1_3::IVibrator> mHandleV1_3;
-
- virtual HalResult<Capabilities> getCapabilitiesInternal() override;
- HalResult<std::chrono::milliseconds> performInternalV1_3(
- hardware::vibrator::Effect effect, hardware::vibrator::EffectStrength strength,
- const std::function<void()>& completionCallback);
+ HalResult<Capabilities> getCapabilitiesInternal() override final;
};
// -------------------------------------------------------------------------------------------------
diff --git a/services/vibratorservice/test/VibratorHalControllerTest.cpp b/services/vibratorservice/test/VibratorHalControllerTest.cpp
index 24e6a1e..2d55549 100644
--- a/services/vibratorservice/test/VibratorHalControllerTest.cpp
+++ b/services/vibratorservice/test/VibratorHalControllerTest.cpp
@@ -53,6 +53,7 @@
virtual ~MockHalWrapper() = default;
MOCK_METHOD(vibrator::HalResult<void>, ping, (), (override));
+ MOCK_METHOD(void, tryReconnect, (), (override));
MOCK_METHOD(vibrator::HalResult<void>, on,
(milliseconds timeout, const std::function<void()>& completionCallback),
(override));
@@ -132,7 +133,6 @@
vibrator::HalResult<vibrator::Capabilities> capabilitiesResult,
vibrator::HalResult<std::vector<Effect>> effectsResult,
vibrator::HalResult<milliseconds> durationResult) {
- InSequence seq;
EXPECT_CALL(*mMockHal.get(), ping())
.Times(Exactly(cardinality))
.WillRepeatedly(Return(voidResult));
@@ -167,11 +167,25 @@
EXPECT_CALL(*mMockHal.get(), performComposedEffect(Eq(compositeEffects), _))
.Times(Exactly(cardinality))
.WillRepeatedly(Return(voidResult));
+
+ if (cardinality > 1) {
+ // One reconnection call after each failure.
+ EXPECT_CALL(*mMockHal.get(), tryReconnect()).Times(Exactly(11 * cardinality));
+ }
}
};
// -------------------------------------------------------------------------------------------------
+TEST_F(VibratorHalControllerTest, TestInit) {
+ mController->init();
+ ASSERT_EQ(1, mConnectCounter);
+
+ // Noop when wrapper was already initialized.
+ mController->init();
+ ASSERT_EQ(1, mConnectCounter);
+}
+
TEST_F(VibratorHalControllerTest, TestApiCallsAreForwardedToHal) {
std::vector<Effect> supportedEffects;
supportedEffects.push_back(Effect::CLICK);
@@ -211,7 +225,6 @@
ASSERT_TRUE(mController->performComposedEffect(compositeEffects, []() {}).isOk());
- // No reconnection attempt was made after the first one.
ASSERT_EQ(1, mConnectCounter);
}
@@ -239,7 +252,6 @@
ASSERT_TRUE(mController->performComposedEffect(std::vector<CompositeEffect>(), []() {})
.isUnsupported());
- // No reconnection attempt was made after the first one.
ASSERT_EQ(1, mConnectCounter);
}
@@ -266,23 +278,24 @@
ASSERT_TRUE(
mController->performComposedEffect(std::vector<CompositeEffect>(), []() {}).isFailed());
- // One reconnection attempt + retry attempts per api call.
- ASSERT_EQ(11 * MAX_ATTEMPTS, mConnectCounter);
+ ASSERT_EQ(1, mConnectCounter);
}
TEST_F(VibratorHalControllerTest, TestFailedApiResultReturnsSuccessAfterRetries) {
{
InSequence seq;
EXPECT_CALL(*mMockHal.get(), ping())
- .Times(Exactly(2))
- .WillOnce(Return(vibrator::HalResult<void>::failed()))
+ .Times(Exactly(1))
+ .WillRepeatedly(Return(vibrator::HalResult<void>::failed()));
+ EXPECT_CALL(*mMockHal.get(), tryReconnect()).Times(Exactly(1));
+ EXPECT_CALL(*mMockHal.get(), ping())
+ .Times(Exactly(1))
.WillRepeatedly(Return(vibrator::HalResult<void>::ok()));
}
ASSERT_EQ(0, mConnectCounter);
ASSERT_TRUE(mController->ping().isOk());
- // One connect + one retry.
- ASSERT_EQ(2, mConnectCounter);
+ ASSERT_EQ(1, mConnectCounter);
}
TEST_F(VibratorHalControllerTest, TestMultiThreadConnectsOnlyOnce) {
@@ -323,7 +336,7 @@
ASSERT_TRUE(mController->performComposedEffect(std::vector<CompositeEffect>(), []() {})
.isUnsupported());
- // One reconnection attempt per api call, no retry.
+ // One connection attempt per api call.
ASSERT_EQ(11, mConnectCounter);
}
@@ -337,19 +350,24 @@
return vibrator::HalResult<void>::ok();
});
EXPECT_CALL(*mMockHal.get(), ping())
- .Times(Exactly(MAX_ATTEMPTS))
+ .Times(Exactly(1))
.WillRepeatedly(Return(vibrator::HalResult<void>::failed()));
+ EXPECT_CALL(*mMockHal.get(), tryReconnect()).Times(Exactly(1));
+ EXPECT_CALL(*mMockHal.get(), ping())
+ .Times(Exactly(1))
+ .WillRepeatedly(Return(vibrator::HalResult<void>::failed()));
+ EXPECT_CALL(*mMockHal.get(), tryReconnect()).Times(Exactly(1));
}
std::unique_ptr<int32_t> callbackCounter = std::make_unique<int32_t>();
auto callback = vibrator::TestFactory::createCountingCallback(callbackCounter.get());
ASSERT_TRUE(mController->on(10ms, callback).isOk());
- ASSERT_TRUE(mController->ping().isFailed()); // Delete connected HAL pointer from controller.
- mMockHal.reset(); // Delete mock HAL pointer from test class.
+ ASSERT_TRUE(mController->ping().isFailed());
+ mMockHal.reset();
ASSERT_EQ(0, *callbackCounter.get());
- // Callback triggered even after HalWrapper was completely destroyed.
+ // Callback triggered even after HalWrapper was reconnected.
std::this_thread::sleep_for(15ms);
ASSERT_EQ(1, *callbackCounter.get());
}