commit a9ffd59dfc4527733fe22262ef4c44608c95fba8
author hkuang <hkuang@google.com> Fri Jun 05 10:38:02 2020 -0700
committer hkuang <hkuang@google.com> Tue Jun 09 17:52:31 2020 -0700
tree fd8c081c7aa24719d2fcca9449581923969a3237
parent dc24554a64946147d683a21f111f53413879e2c6

transcoding: Add more test configs for SimulatedTranscoder

Bug: 154734285
Bug: 145628554
Test: Unit test.
Change-Id: Id9d77e2d53c2dc582cc7034f158b5ab9eedcf586

services/mediatranscoding/SimulatedTranscoder.cpp

diff --git a/services/mediatranscoding/SimulatedTranscoder.cpp b/services/mediatranscoding/SimulatedTranscoder.cpp
index 1b68d5c..0a77fbe 100644
--- a/services/mediatranscoding/SimulatedTranscoder.cpp
+++ b/services/mediatranscoding/SimulatedTranscoder.cpp
@@ -48,7 +48,12 @@
 }
 
 void SimulatedTranscoder::start(ClientIdType clientId, JobIdType jobId,
-                                const TranscodingRequestParcel& /*request*/) {
+                                const TranscodingRequestParcel& request) {
+    if (request.testConfig.processingTotalTimeMs > 0) {
+        mJobProcessingTimeMs = request.testConfig.processingTotalTimeMs;
+    }
+    ALOGV("%s: job {%d}: processingTime: %lld", __FUNCTION__, jobId,
+          (long long)mJobProcessingTimeMs);
     queueEvent(Event::Start, clientId, jobId);
 }
 
@@ -123,7 +128,7 @@
                 lastRunningTime = std::chrono::system_clock::now();
                 lastRunningEvent = event;
                 if (event.type == Event::Start) {
-                    remainingUs = std::chrono::microseconds(kJobDurationUs);
+                    remainingUs = std::chrono::milliseconds(mJobProcessingTimeMs);
                 }
             } else if (running && (event.type == Event::Pause || event.type == Event::Stop)) {
                 running = false;

services/mediatranscoding/SimulatedTranscoder.h

diff --git a/services/mediatranscoding/SimulatedTranscoder.h b/services/mediatranscoding/SimulatedTranscoder.h
index 646ba4e..9054b4c 100644
--- a/services/mediatranscoding/SimulatedTranscoder.h
+++ b/services/mediatranscoding/SimulatedTranscoder.h
@@ -29,6 +29,8 @@
  * SimulatedTranscoder is currently used to instantiate MediaTranscodingService
  * on service side for testing, so that we could actually test the IPC calls of
  * MediaTranscodingService to expose issues that's observable only over IPC.
+ * SimulatedTranscoder is used when useSimulatedTranscoder in TranscodingTestConfig
+ * is set to true.
  *
  * SimulatedTranscoder simulates job execution by reporting finish after kJobDurationUs.
  * Job lifecycle events are reported via progress updates with special progress
@@ -61,6 +63,9 @@
     std::condition_variable mCondition;
     std::list<Event> mQueue GUARDED_BY(mLock);
 
+    // Minimum time spent on transcode the video. This is used just for testing.
+    int64_t mJobProcessingTimeMs = kJobDurationUs / 1000;
+
     static const char* toString(Event::Type type);
     void queueEvent(Event::Type type, ClientIdType clientId, JobIdType jobId);
     void threadLoop();