commit 0dc2bc658f5707b9482a10b19adb2c0e77fb3a81
author David Zhao <qingxun@google.com> Tue Oct 17 11:56:52 2023 -0700
committer David Zhao <qingxun@google.com> Tue Oct 17 19:49:54 2023 +0000
tree 595af361c6264a6bd4ded261469fe54ece72fce4
parent 8cee65d03f3803004e20372527b732a2e8dc7eff

Update TVInput impl and vts to create and validate queue

Test: m vts && vts-tradefed run vts --module VtsHalTvInputTargetTest
Bug: 305993654
Change-Id: I9e7a87b200c08a9807d99d66bd881226c4cc47aa

tv/input/aidl/vts/functional/VtsHalTvInputTargetTest.cpp

diff --git a/tv/input/aidl/vts/functional/VtsHalTvInputTargetTest.cpp b/tv/input/aidl/vts/functional/VtsHalTvInputTargetTest.cpp
index 8d3395b..746ae1e 100644
--- a/tv/input/aidl/vts/functional/VtsHalTvInputTargetTest.cpp
+++ b/tv/input/aidl/vts/functional/VtsHalTvInputTargetTest.cpp
@@ -355,8 +355,12 @@
     }
     int32_t stream_id = streamConfigs[0].streamId;
     ALOGD("GetTvMessageQueueTest: device_id=%d, stream_id=%d", device_id, stream_id);
-    MQDescriptor<int8_t, SynchronizedReadWrite> queue;
-    tv_input_->getTvMessageQueueDesc(&queue, device_id, stream_id);
+    MQDescriptor<int8_t, SynchronizedReadWrite> queueDescriptor;
+    AidlMessageQueue<int8_t, SynchronizedReadWrite>* queue;
+    tv_input_->getTvMessageQueueDesc(&queueDescriptor, device_id, stream_id);
+    queue = new (std::nothrow) AidlMessageQueue<int8_t, SynchronizedReadWrite>(queueDescriptor);
+    ASSERT_TRUE(queue->isValid());
+    delete queue;
 }
 
 INSTANTIATE_TEST_SUITE_P(PerInstance, TvInputAidlTest,