[MVE 1.5.1] [Push AV] Increase blind duration and transport expiry time (#43136)

* Increase blind duration and transport expiry time

Co-Author: Dhruvkumar <kakadiya.b@samsung.com>

Signed-off-by: Raveendra Karu <r.karu@samsung.com>

* Update asyncio timeout and address review comments.

Signed-off-by: Raveendra Karu <r.karu@samsung.com>

* Add comments to explain the reason for choosing time control fields values.

Signed-off-by: Raveendra Karu <r.karu@samsung.com>

---------

Signed-off-by: Raveendra Karu <r.karu@samsung.com>

Author: raveendra-karu

src/python_testing/TC_PAVSTTestBase.py

@@ -29,7 +29,7 @@
 
 
 class PAVSTTestBase:
-    DEFAULT_AV_TRANSPORT_EXPIRY_TIME_SEC = 100  # 100 seconds
+    DEFAULT_AV_TRANSPORT_EXPIRY_TIME_SEC = 150  # 150 seconds
 
     async def read_pavst_attribute_expect_success(self, endpoint, attribute):
         cluster = Clusters.Objects.PushAvStreamTransport

src/python_testing/TC_PAVST_2_13.py

@@ -34,6 +34,7 @@
 #       --trace-to perfetto:${TRACE_TEST_PERFETTO}.perfetto
 #       --endpoint 1
 #       --app-pipe /tmp/pavst_2_13_fifo
+#       --timeout 300
 #     factory-reset: true
 #     quiet: true
 # === END CI TEST ARGUMENTS ===
@@ -278,17 +279,19 @@ async def test_TC_PAVST_2_13(self):
             zoneID1 = cmdResponse.zoneID
 
         self.step(6)
+        # Initialze the time control fields
         initDuration = 5
         augDuration = 2
         maxDuration = 15
-        blindDuration = 3
+        # blindDuration time set as 10 sec to ensure it is sufficient enough to receive the motion event at DUT post the clip recording is completed
+        blindDuration = 10
         maxPreRollLen = 4
         try:
             zoneList = [{"zone": zoneID1, "sensitivity": 4}]
             triggerOptions = {"triggerType": pvcluster.Enums.TransportTriggerTypeEnum.kMotion,
                               "maxPreRollLen": 4000,
                               "motionZones": zoneList,
-                              "motionTimeControl": {"initialDuration": 5, "augmentationDuration": 2, "maxDuration": 15, "blindDuration": 3}}
+                              "motionTimeControl": {"initialDuration": initDuration, "augmentationDuration": augDuration, "maxDuration": maxDuration, "blindDuration": blindDuration}}
             status = await self.allocate_one_pushav_transport(endpoint, trigger_Options=triggerOptions,
                                                               tlsEndPoint=tlsEndpointId, url=f"https://{host_ip}:1234/streams/{uploadStreamId}/")
             asserts.assert_equal(status, Status.Success,
@@ -323,7 +326,8 @@ async def test_TC_PAVST_2_13(self):
                                    self.dut_node_id,
                                    self.get_endpoint())
 
-        timeControl = {"initialDuration": 5, "augmentationDuration": 2, "maxDuration": 15, "blindDuration": 3}
+        timeControl = {"initialDuration": initDuration, "augmentationDuration": augDuration,
+                       "maxDuration": maxDuration, "blindDuration": blindDuration}
         cmd = pvcluster.Commands.ManuallyTriggerTransport(
             connectionID=aConnectionID,
             activationReason=pvcluster.Enums.TriggerActivationReasonEnum.kEmergency,
@@ -444,13 +448,15 @@ async def test_TC_PAVST_2_13(self):
         )
 
         self.step(17)
+        # update maxDuration and  augDuration fields to ensure initDuration + augDuration > maxDuration
         maxDuration = 10
+        augDuration = 15
         try:
             zoneList = [{"zone": zoneID1, "sensitivity": 4}]
             triggerOptions = {"triggerType": pvcluster.Enums.TransportTriggerTypeEnum.kMotion,
                               "maxPreRollLen": 4000,
                               "motionZones": zoneList,
-                              "motionTimeControl": {"initialDuration": 5, "augmentationDuration": 15, "maxDuration": 10, "blindDuration": 3}}
+                              "motionTimeControl": {"initialDuration": initDuration, "augmentationDuration": augDuration, "maxDuration": maxDuration, "blindDuration": blindDuration}}
             status = await self.allocate_one_pushav_transport(endpoint, trigger_Options=triggerOptions,
                                                               tlsEndPoint=tlsEndpointId, url=f"https://{host_ip}:1234/streams/{uploadStreamId}/")
             asserts.assert_equal(status, Status.Success,