Donate to e Foundation | Murena handsets with /e/OS | Own a part of Murena! Learn more

Commit 3250a8d8 authored by Hans Chen's avatar Hans Chen Committed by android-build-merger
Browse files

Modified ITestMsgQ hal service interface am: 58d52f70 am: 2fd89193 

am: 662e5d33

Change-Id: Id7c8431920c42e33f26e4d66e7ace90b3568733f
parents 378a218e 662e5d33

tests/msgq/1.0/ITestMsgQ.hal

+5 −5
Original line number Diff line number Diff line
@@ -24,14 +24,14 @@ interface ITestMsgQ { 


    /**

     * This method requests the service to set up a synchronous read/write

     * wait-free FMQ with the client as reader.

     * wait-free FMQ using the input descriptor with the client as reader.

     *

     * @param mqDesc This structure describes the FMQ that was set up by the

     * client. Server uses this descriptor to set up a FMQ object at its end.

     *

     * @return ret True if the setup is successful.

     * @return mqDesc This structure describes the FMQ that was

     * set up by the service. Client can use it to set up the FMQ at its end.

     */

    configureFmqSyncReadWrite()

        generates(bool ret, fmq_sync<uint16_t> mqDesc);

    configureFmqSyncReadWrite(fmq_sync<uint16_t> mqDesc) generates(bool ret);



    /**

     * This method requests the service to return an MQDescriptor to

tests/msgq/1.0/default/TestMsgQ.cpp

+13 −16
Original line number Diff line number Diff line
@@ -24,13 +24,12 @@ namespace V1_0 { 
namespace implementation {



// Methods from ::android::hardware::tests::msgq::V1_0::ITestMsgQ follow.

Return<void> TestMsgQ::configureFmqSyncReadWrite(configureFmqSyncReadWrite_cb _hidl_cb) {

    static constexpr size_t kNumElementsInQueue = 1024;

    mFmqSynchronized.reset(new (std::nothrow) MessageQueueSync(

            kNumElementsInQueue, true /* configureEventFlagWord */));

Return<bool> TestMsgQ::configureFmqSyncReadWrite(

    const android::hardware::MQDescriptorSync<uint16_t>& mqDesc) {

    mFmqSynchronized.reset(new (std::nothrow) MessageQueueSync(mqDesc));

    if ((mFmqSynchronized == nullptr) || (mFmqSynchronized->isValid() == false)) {

        _hidl_cb(false /* ret */, MessageQueueSync::Descriptor());

    } else {

        return false;

    }

    /*

     * Initialize the EventFlag word with bit FMQ_NOT_FULL.

     */
@@ -39,9 +38,7 @@ Return<void> TestMsgQ::configureFmqSyncReadWrite(configureFmqSyncReadWrite_cb _h 
        std::atomic_init(evFlagWordPtr,

                         static_cast<uint32_t>(ITestMsgQ::EventFlagBits::FMQ_NOT_FULL));

    }

        _hidl_cb(true /* ret */, *mFmqSynchronized->getDesc());

    }

    return Void();

    return true;

}



Return<void> TestMsgQ::getFmqUnsyncWrite(bool configureFmq, getFmqUnsyncWrite_cb _hidl_cb) {

tests/msgq/1.0/default/TestMsgQ.h

+1 −1
Original line number Diff line number Diff line
@@ -55,7 +55,7 @@ struct TestMsgQ : public ITestMsgQ { 
    TestMsgQ() : mFmqSynchronized(nullptr), mFmqUnsynchronized(nullptr) {}



    // Methods from ::android::hardware::tests::msgq::V1_0::ITestMsgQ follow.

    Return<void> configureFmqSyncReadWrite(configureFmqSyncReadWrite_cb _hidl_cb) override;

    Return<bool> configureFmqSyncReadWrite(const MQDescriptorSync<uint16_t>& mqDesc) override;

    Return<void> getFmqUnsyncWrite(bool configureFmq, getFmqUnsyncWrite_cb _hidl_cb) override;

    Return<bool> requestWriteFmqSync(int32_t count) override;

    Return<bool> requestReadFmqSync(int32_t count) override;