Iterative cleanup for GL programs in GPU process

gpu/ipc/service/gpu_channel.cc

 // Copyright (c) 2012 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "gpu/ipc/service/gpu_channel.h"
 
 #include <utility>
 
 #if defined(OS_WIN)
 #include <windows.h>
@@ skipping 16 matching lines @@
 #include "base/threading/thread_task_runner_handle.h"
 #include "base/timer/timer.h"
 #include "base/trace_event/memory_dump_manager.h"
 #include "base/trace_event/process_memory_dump.h"
 #include "base/trace_event/trace_event.h"
 #include "build/build_config.h"
 #include "gpu/command_buffer/common/mailbox.h"
 #include "gpu/command_buffer/service/command_executor.h"
 #include "gpu/command_buffer/service/image_factory.h"
 #include "gpu/command_buffer/service/mailbox_manager.h"
+#include "gpu/command_buffer/service/program_manager.h"
 #include "gpu/command_buffer/service/sync_point_manager.h"
 #include "gpu/ipc/common/gpu_messages.h"
 #include "gpu/ipc/service/gpu_channel_manager.h"
 #include "gpu/ipc/service/gpu_channel_manager_delegate.h"
 #include "gpu/ipc/service/gpu_memory_buffer_factory.h"
 #include "ipc/ipc_channel.h"
 #include "ipc/message_filter.h"
 #include "ui/gl/gl_context.h"
 #include "ui/gl/gl_image_shared_memory.h"
 #include "ui/gl/gl_surface.h"
@@ skipping 1014 matching lines @@
         return nullptr;
 
       return manager->gpu_memory_buffer_factory()
           ->AsImageFactory()
           ->CreateImageForGpuMemoryBuffer(handle, size, format, internalformat,
                                           client_id_, surface_handle);
     }
   }
 }
 
+GpuChannelDeleter::GpuChannelDeleter(std::unique_ptr<GpuChannel> channel)
+    : channel_(std::move(channel)) {
+  for (const auto& stub : channel_->stubs_) {
+    pending_stubs_.push(stub.second);
+  }
+}
+
+GpuChannelDeleter::~GpuChannelDeleter() = default;
+
+bool GpuChannelDeleter::DeleteWithTimeout(const base::TimeTicks& timeout) {
+  for (; pending_stubs_.size() > 0; pending_stubs_.pop()) {
+    auto* decoder = pending_stubs_.front()->decoder();
+    auto* surface = pending_stubs_.front()->surface();
+
+    if (!decoder) {
+      continue;
+    }
+
+    bool have_context = false;
+    if (decoder->GetGLContext()) {
+      // Try to make the context current regardless of whether it was lost, so
+      // we don't leak resources.
+      have_context = decoder->GetGLContext()->MakeCurrent(surface);
+    }
+
+    auto* program_manager = decoder->GetContextGroup()->program_manager();
+    if (!program_manager->PreDestroyWithTimeout(have_context, timeout)) {
+      // If PreDestroyWithTimeout returns false, the timeout was reached
+      // before deletion completed. We should also return false.
+      return false;
+    }
+  }
+
+  return true;
+}
+
 }  // namespace gpu