Searched refs:fmqSynchronized (Results 1 – 2 of 2) sorted by relevance
252 if (mPm.fmqSynchronized != nullptr) { in streamEnergyData()258 mPm.fmqSynchronized.reset(new (std::nothrow) MessageQueueSync(MAX_QUEUE_SIZE, true)); in streamEnergyData()259 if (mPm.fmqSynchronized == nullptr || mPm.fmqSynchronized->isValid() == false) { in streamEnergyData()260 mPm.fmqSynchronized = nullptr; in streamEnergyData()270 mPm.fmqSynchronized->writeBlocking(&mPm.reading[0], mPm.reading.size(), in streamEnergyData()284 mPm.fmqSynchronized = nullptr; in streamEnergyData()289 _hidl_cb(*(mPm.fmqSynchronized)->getDesc(), numSamples, mPm.reading.size(), Status::SUCCESS); in streamEnergyData()
61 std::unique_ptr<MessageQueueSync> fmqSynchronized; member