[VideoCapture] Handle GPU context lost for the zero-copy path

When the render thread encounters GPU context lost, we need to re-create
the SharedImage resources to recover the video capture stream.

This is a reland of crrev.com/c/2455328 with a fix to address the MSAN
test failure

Bug: 1131998, b:169429427
Test: Manually with chrome://gpuclean on soraka

TBR=jcliang@chromium.org,ccameron@chromium.org,kbr@chromium.org,dcastagna@chromium.org,guidou@chromium.org,ccameron@google.com

Change-Id: I3d00abaea04ccf95a795e116f5fc7ff5c7d7f43a
Reviewed-on: https://chromium-review.googlesource.com/c/chromium/src/+/2494406Reviewed-by: Ricky Liang <jcliang@chromium.org>
Commit-Queue: Ricky Liang <jcliang@chromium.org>
Cr-Commit-Position: refs/heads/master@{#820175}

third_party/blink/renderer/platform/exported/video_capture/web_video_capture_impl_manager.cc

@@ -101,8 +101,10 @@ base::OnceClosure WebVideoCaptureImplManager::UseDevice(
     it = devices_.end() - 1;
     it->session_id = id;
     it->impl = CreateVideoCaptureImplForTesting(id);
-    if (!it->impl)
-      it->impl.reset(new VideoCaptureImpl(id));
+    if (!it->impl) {
+      it->impl =
+          std::make_unique<VideoCaptureImpl>(id, render_main_task_runner_);
+    }
   }
   ++it->client_count;
 

third_party/blink/renderer/platform/exported/video_capture/web_video_capture_impl_manager_test.cc

@@ -51,7 +51,7 @@ class MockVideoCaptureImpl : public VideoCaptureImpl,
   MockVideoCaptureImpl(const media::VideoCaptureSessionId& session_id,
                        PauseResumeCallback* pause_callback,
                        base::OnceClosure destruct_callback)
-      : VideoCaptureImpl(session_id),
+      : VideoCaptureImpl(session_id, base::ThreadTaskRunnerHandle::Get()),
         pause_callback_(pause_callback),
         destruct_callback_(std::move(destruct_callback)) {}
 

third_party/blink/renderer/platform/video_capture/video_capture_impl.cc

@@ -66,11 +66,9 @@ struct VideoCaptureImpl::BufferContext
     : public base::RefCountedThreadSafe<BufferContext> {
  public:
   BufferContext(media::mojom::blink::VideoBufferHandlePtr buffer_handle,
-                media::GpuVideoAcceleratorFactories* gpu_factories,
                 scoped_refptr<base::SingleThreadTaskRunner> media_task_runner)
       : buffer_type_(buffer_handle->which()),
-        gpu_factories_(gpu_factories),
-        media_task_runner_(std::move(media_task_runner)) {
+        media_task_runner_(media_task_runner) {
     switch (buffer_type_) {
       case VideoFrameBufferHandleType::SHARED_BUFFER_HANDLE:
         InitializeFromSharedMemory(
@@ -91,7 +89,6 @@ struct VideoCaptureImpl::BufferContext
         // On macOS, an IOSurfaces passed as a GpuMemoryBufferHandle can be
         // used by both hardware and software paths.
         // https://crbug.com/1125879
-        CHECK(gpu_factories_);
         CHECK(media_task_runner_);
 #endif
         InitializeFromGpuMemoryBufferHandle(
@@ -123,20 +120,31 @@ struct VideoCaptureImpl::BufferContext
   // the VideoFrame can access the data either through mailboxes (e.g. display)
   // or through the DMA-buf FDs (e.g. video encoder).
   static void BindBufferToTextureOnMediaThread(
+      media::GpuVideoAcceleratorFactories* gpu_factories,
       scoped_refptr<BufferContext> buffer_context,
       media::mojom::blink::VideoFrameInfoPtr info,
       std::unique_ptr<gfx::GpuMemoryBuffer> gpu_memory_buffer,
       scoped_refptr<media::VideoFrame> frame,
       base::OnceCallback<void(media::mojom::blink::VideoFrameInfoPtr,
                               scoped_refptr<media::VideoFrame>,
-                              scoped_refptr<BufferContext>)> on_texture_bound) {
+                              scoped_refptr<BufferContext>)> on_texture_bound,
+      base::OnceCallback<void()> on_gpu_context_lost) {
+    DCHECK(gpu_factories);
     DCHECK(buffer_context->media_task_runner_->BelongsToCurrentThread());
-    DCHECK(buffer_context->gpu_factories_);
     DCHECK_EQ(info->pixel_format, media::PIXEL_FORMAT_NV12);
 
+    bool should_recreate_shared_image = false;
+    if (gpu_factories != buffer_context->gpu_factories_) {
+      DVLOG(1) << "GPU context changed; re-creating SharedImage objects";
+      buffer_context->gpu_factories_ = gpu_factories;
+      should_recreate_shared_image = true;
+    }
+
     // Create GPU texture and bind GpuMemoryBuffer to the texture.
     auto* sii = buffer_context->gpu_factories_->SharedImageInterface();
     if (!sii) {
+      DVLOG(1) << "GPU context lost";
+      std::move(on_gpu_context_lost).Run();
       std::move(on_texture_bound)
           .Run(std::move(info), std::move(frame), std::move(buffer_context));
       return;
@@ -150,7 +158,8 @@ struct VideoCaptureImpl::BufferContext
     unsigned texture_target =
         buffer_context->gpu_factories_->ImageTextureTarget(
             gpu_memory_buffer->GetFormat());
-    if (buffer_context->gmb_resources_->mailbox.IsZero()) {
+    if (should_recreate_shared_image ||
+        buffer_context->gmb_resources_->mailbox.IsZero()) {
       uint32_t usage =
           gpu::SHARED_IMAGE_USAGE_GLES2 | gpu::SHARED_IMAGE_USAGE_RASTER |
           gpu::SHARED_IMAGE_USAGE_DISPLAY | gpu::SHARED_IMAGE_USAGE_SCANOUT |
@@ -300,13 +309,17 @@ struct VideoCaptureImpl::ClientInfo {
   VideoCaptureDeliverFrameCB deliver_frame_cb;
 };
 
-VideoCaptureImpl::VideoCaptureImpl(media::VideoCaptureSessionId session_id)
+VideoCaptureImpl::VideoCaptureImpl(
+    media::VideoCaptureSessionId session_id,
+    scoped_refptr<base::SingleThreadTaskRunner> main_task_runner)
     : device_id_(session_id),
       session_id_(session_id),
       video_capture_host_for_testing_(nullptr),
       state_(blink::VIDEO_CAPTURE_STATE_STOPPED),
+      main_task_runner_(std::move(main_task_runner)),
       gpu_memory_buffer_support_(new gpu::GpuMemoryBufferSupport()) {
   CHECK(!session_id.is_empty());
+  DCHECK(main_task_runner_->BelongsToCurrentThread());
   DETACH_FROM_THREAD(io_thread_checker_);
 
   Platform::Current()->GetBrowserInterfaceBroker()->GetInterface(
@@ -318,6 +331,25 @@ VideoCaptureImpl::VideoCaptureImpl(media::VideoCaptureSessionId session_id)
   }
 }
 
+void VideoCaptureImpl::OnGpuContextLost(
+    base::WeakPtr<VideoCaptureImpl> video_capture_impl) {
+  // Called on the main task runner.
+  auto* gpu_factories = Platform::Current()->GetGpuFactories();
+  Platform::Current()->GetIOTaskRunner()->PostTask(
+      FROM_HERE,
+      base::BindOnce(&VideoCaptureImpl::SetGpuFactoriesHandleOnIOTaskRunner,
+                     video_capture_impl, gpu_factories));
+}
+
+void VideoCaptureImpl::SetGpuFactoriesHandleOnIOTaskRunner(
+    media::GpuVideoAcceleratorFactories* gpu_factories) {
+  DCHECK_CALLED_ON_VALID_THREAD(io_thread_checker_);
+  if (gpu_factories != gpu_factories_) {
+    LOG(ERROR) << "GPU factories handle changed; assuming GPU context lost";
+    gpu_factories_ = gpu_factories;
+  }
+}
+
 VideoCaptureImpl::~VideoCaptureImpl() {
   DCHECK_CALLED_ON_VALID_THREAD(io_thread_checker_);
   if ((state_ == VIDEO_CAPTURE_STATE_STARTING ||
@@ -505,9 +537,8 @@ void VideoCaptureImpl::OnNewBuffer(
 
   const bool inserted =
       client_buffers_
-          .emplace(buffer_id,
-                   new BufferContext(std::move(buffer_handle), gpu_factories_,
-                                     media_task_runner_))
+          .emplace(buffer_id, new BufferContext(std::move(buffer_handle),
+                                                media_task_runner_))
           .second;
   DCHECK(inserted);
 }
@@ -672,11 +703,15 @@ void VideoCaptureImpl::OnBufferReady(
       media_task_runner_->PostTask(
           FROM_HERE,
           base::BindOnce(
-              &BufferContext::BindBufferToTextureOnMediaThread,
+              &BufferContext::BindBufferToTextureOnMediaThread, gpu_factories_,
               std::move(buffer_context), std::move(info), std::move(gmb), frame,
               media::BindToCurrentLoop(base::BindOnce(
                   &VideoCaptureImpl::OnVideoFrameReady,
-                  weak_factory_.GetWeakPtr(), buffer_id, reference_time))));
+                  weak_factory_.GetWeakPtr(), buffer_id, reference_time)),
+              media::BindToLoop(
+                  main_task_runner_,
+                  base::BindOnce(&VideoCaptureImpl::OnGpuContextLost,
+                                 weak_factory_.GetWeakPtr()))));
       return;
     }
   }

third_party/blink/renderer/platform/video_capture/video_capture_impl.h

@@ -40,7 +40,9 @@ extern const PLATFORM_EXPORT base::Feature kTimeoutHangingVideoCaptureStarts;
 class PLATFORM_EXPORT VideoCaptureImpl
     : public media::mojom::blink::VideoCaptureObserver {
  public:
-  explicit VideoCaptureImpl(media::VideoCaptureSessionId session_id);
+  VideoCaptureImpl(
+      media::VideoCaptureSessionId session_id,
+      scoped_refptr<base::SingleThreadTaskRunner> main_task_runner);
   ~VideoCaptureImpl() override;
 
   // Stop/resume delivering video frames to clients, based on flag |suspend|.
@@ -150,6 +152,15 @@ class PLATFORM_EXPORT VideoCaptureImpl
 
   void OnStartTimedout();
 
+  // Callback for when GPU context lost is detected. The method fetches the new
+  // GPU factories handle on |main_task_runner_| and sets |gpu_factories_| to
+  // the new handle.
+  static void OnGpuContextLost(
+      base::WeakPtr<VideoCaptureImpl> video_capture_impl);
+
+  void SetGpuFactoriesHandleOnIOTaskRunner(
+      media::GpuVideoAcceleratorFactories* gpu_factories);
+
   // |device_id_| and |session_id_| are different concepts, but we reuse the
   // same numerical value, passed on construction.
   const base::UnguessableToken device_id_;
@@ -184,8 +195,9 @@ class PLATFORM_EXPORT VideoCaptureImpl
   int num_first_frame_logs_ = 0;
 
   // Methods of |gpu_factories_| need to run on |media_task_runner_|.
-  media::GpuVideoAcceleratorFactories* gpu_factories_;
+  media::GpuVideoAcceleratorFactories* gpu_factories_ = nullptr;
   scoped_refptr<base::SingleThreadTaskRunner> media_task_runner_;
+  scoped_refptr<base::SingleThreadTaskRunner> main_task_runner_;
 
   std::unique_ptr<gpu::GpuMemoryBufferSupport> gpu_memory_buffer_support_;
 

third_party/blink/renderer/platform/video_capture/video_capture_impl_test.cc

@@ -121,7 +121,9 @@ class MockMojoVideoCaptureHost : public media::mojom::blink::VideoCaptureHost {
 class VideoCaptureImplTest : public ::testing::Test {
  public:
   VideoCaptureImplTest()
-      : video_capture_impl_(new VideoCaptureImpl(session_id_)) {
+      : video_capture_impl_(
+            new VideoCaptureImpl(session_id_,
+                                 base::ThreadTaskRunnerHandle::Get())) {
     params_small_.requested_format = media::VideoCaptureFormat(
         gfx::Size(176, 144), 30, media::PIXEL_FORMAT_I420);
     params_large_.requested_format = media::VideoCaptureFormat(