Yifan Hong | 11992a6 | 2016-11-09 18:07:40 -0800 | [diff] [blame] | 1 | |
| 2 | #define LOG_TAG "hidl_test" |
| 3 | |
| 4 | #include "FooCallback.h" |
Yifan Hong | 11992a6 | 2016-11-09 18:07:40 -0800 | [diff] [blame] | 5 | #include <hidl-test/FooHelper.h> |
| 6 | #include <inttypes.h> |
Dan Willemsen | 623ad8e | 2017-04-03 22:53:02 -0700 | [diff] [blame] | 7 | #include <log/log.h> |
Yifan Hong | 11992a6 | 2016-11-09 18:07:40 -0800 | [diff] [blame] | 8 | #include <utils/Timers.h> |
| 9 | |
| 10 | namespace android { |
| 11 | namespace hardware { |
| 12 | namespace tests { |
| 13 | namespace foo { |
| 14 | namespace V1_0 { |
| 15 | namespace implementation { |
| 16 | |
| 17 | enum { |
| 18 | NOT_REPORTED = -1LL |
| 19 | }; |
| 20 | |
| 21 | FooCallback::FooCallback() |
| 22 | : mLock{}, mCond{} { |
| 23 | for (size_t i = 0; i < invokeInfo.size(); i++) { |
| 24 | invokeInfo[i].invoked = false; |
| 25 | invokeInfo[i].timeNs = NOT_REPORTED; |
| 26 | invokeInfo[i].callerBlockedNs = NOT_REPORTED; |
| 27 | } |
| 28 | } |
| 29 | |
| 30 | Return<void> FooCallback::heyItsYou( |
| 31 | const sp<IFooCallback> &_cb) { |
| 32 | nsecs_t start = systemTime(); |
| 33 | ALOGI("SERVER(FooCallback) 1: heyItsYou cb = %p", _cb.get()); |
| 34 | nsecs_t end = systemTime(); |
| 35 | { |
| 36 | Mutex::Autolock lock(mLock); |
| 37 | invokeInfo[0].invoked = true; |
| 38 | invokeInfo[0].timeNs = end - start; |
| 39 | mCond.signal(); |
| 40 | } |
| 41 | ALOGI("SERVER(FooCallback) 2: heyItsYou returned"); |
| 42 | return Void(); |
| 43 | } |
| 44 | |
| 45 | Return<bool> FooCallback::heyItsYouIsntIt(const sp<IFooCallback> &_cb) { |
| 46 | nsecs_t start = systemTime(); |
| 47 | ALOGI("SERVER(FooCallback) 3: heyItsYouIsntIt cb = %p sleeping for %" PRId64 " seconds", _cb.get(), DELAY_S); |
| 48 | sleep(DELAY_S); |
| 49 | ALOGI("SERVER(FooCallback) 4: heyItsYouIsntIt cb = %p responding", _cb.get()); |
| 50 | nsecs_t end = systemTime(); |
| 51 | { |
| 52 | Mutex::Autolock lock(mLock); |
| 53 | invokeInfo[1].invoked = true; |
| 54 | invokeInfo[1].timeNs = end - start; |
| 55 | mCond.signal(); |
| 56 | } |
| 57 | ALOGI("SERVER(FooCallback) 5: heyItsYouIsntIt cb = %p responding", _cb.get()); |
| 58 | return true; |
| 59 | } |
| 60 | |
| 61 | Return<void> FooCallback::heyItsTheMeaningOfLife(uint8_t tmol) { |
| 62 | nsecs_t start = systemTime(); |
| 63 | ALOGI("SERVER(FooCallback) 6.1: heyItsTheMeaningOfLife = %d sleeping for %" PRId64 " seconds", tmol, DELAY_S); |
| 64 | sleep(DELAY_S); |
| 65 | ALOGI("SERVER(FooCallback) 6.2: heyItsTheMeaningOfLife = %d done sleeping", tmol); |
| 66 | nsecs_t end = systemTime(); |
| 67 | { |
| 68 | Mutex::Autolock lock(mLock); |
| 69 | invokeInfo[2].invoked = true; |
| 70 | invokeInfo[2].timeNs = end - start; |
| 71 | mCond.signal(); |
| 72 | } |
| 73 | ALOGI("SERVER(FooCallback) 6.3: heyItsTheMeaningOfLife returned"); |
| 74 | return Void(); |
| 75 | } |
| 76 | |
| 77 | Return<void> FooCallback::reportResults(int64_t ns, reportResults_cb cb) { |
| 78 | ALOGI("SERVER(FooCallback) 8.1: reportResults(%" PRId64 " seconds)", nanoseconds_to_seconds(ns)); |
| 79 | nsecs_t leftToWaitNs = ns; |
| 80 | bool cond; |
| 81 | { |
| 82 | Mutex::Autolock lock(mLock); |
| 83 | while ((cond = ((!invokeInfo[0].invoked || |
| 84 | !invokeInfo[1].invoked || |
| 85 | !invokeInfo[2].invoked || |
| 86 | invokeInfo[0].callerBlockedNs == NOT_REPORTED || |
| 87 | invokeInfo[1].callerBlockedNs == NOT_REPORTED || |
| 88 | invokeInfo[2].callerBlockedNs == NOT_REPORTED) && |
| 89 | leftToWaitNs > 0))) { |
| 90 | nsecs_t start = systemTime(); |
| 91 | ::android::status_t rc = mCond.waitRelative(mLock, leftToWaitNs); |
| 92 | if (rc != ::android::OK) { |
| 93 | ALOGW("SERVER(FooCallback)::reportResults(%" PRId64 " ns) Condition::waitRelative(%" PRId64 ") returned error (%d)", ns, leftToWaitNs, rc); |
| 94 | if (rc == -ETIMEDOUT) { |
| 95 | // time's up |
Yifan Hong | fcf94e4 | 2016-12-07 15:49:51 -0800 | [diff] [blame] | 96 | leftToWaitNs = -INT32_MAX; |
Yifan Hong | 11992a6 | 2016-11-09 18:07:40 -0800 | [diff] [blame] | 97 | } |
| 98 | break; |
| 99 | } |
| 100 | ALOGI("SERVER(FooCallback)::reportResults(%" PRId64 " ns) Condition::waitRelative was signalled", ns); |
| 101 | leftToWaitNs -= systemTime() - start; |
| 102 | } |
| 103 | } |
| 104 | ALOGI("SERVER(FooCallback) 8.2: reportResults returned;" |
| 105 | "invoked? %d, %d, %d; leftToWaitNs = %" PRId64 "; cond = %d", |
| 106 | invokeInfo[0].invoked, invokeInfo[1].invoked, invokeInfo[2].invoked, |
| 107 | leftToWaitNs, cond); |
| 108 | cb(leftToWaitNs, invokeInfo); |
| 109 | return Void(); |
| 110 | } |
| 111 | |
| 112 | Return<void> FooCallback::youBlockedMeFor(const hidl_array<int64_t, 3> &ns) { |
| 113 | ALOGI("SERVER(FooCallback) 7.1: youBlockedMeFor"); |
| 114 | { |
| 115 | Mutex::Autolock lock(mLock); |
| 116 | for (size_t i = 0; i < 3; i++) { |
| 117 | invokeInfo[i].callerBlockedNs = ns[i]; |
| 118 | } |
| 119 | mCond.signal(); |
| 120 | } |
| 121 | ALOGI("SERVER(FooCallback) 7.2: returned"); |
| 122 | return Void(); |
| 123 | } |
| 124 | |
| 125 | IFooCallback* HIDL_FETCH_IFooCallback(const char* /* name */) { |
| 126 | return new FooCallback(); |
| 127 | } |
| 128 | |
| 129 | } // namespace implementation |
| 130 | } // namespace V1_0 |
| 131 | } // namespace foo |
| 132 | } // namespace tests |
| 133 | } // namespace hardware |
| 134 | } // namespace android |