/* * Copyright 2020 Google LLC. * * Use of this source code is governed by a BSD-style license that can be * found in the LICENSE file. */ #include "src/gpu/ganesh/gl/GrGLFinishCallbacks.h" #include "include/gpu/GpuTypes.h" #include "include/private/base/SkAssert.h" #include "src/gpu/ganesh/gl/GrGLGpu.h" #include GrGLFinishCallbacks::GrGLFinishCallbacks(GrGLGpu* gpu) : fGpu(gpu) {} GrGLFinishCallbacks::~GrGLFinishCallbacks() { this->callAll(true); } void GrGLFinishCallbacks::add(skgpu::AutoCallback callback, GrGLint timerQuery) { SkASSERT(callback); FinishCallback finishCallback; finishCallback.fCallback = std::move(callback); finishCallback.fSync = fGpu->insertSync(); finishCallback.fTimerQuery = timerQuery; fCallbacks.push_back(std::move(finishCallback)); } void GrGLFinishCallbacks::check() { // Bail after the first unfinished sync since we expect they signal in the order inserted. while (!fCallbacks.empty() && fGpu->testSync(fCallbacks.front().fSync)) { // While we are processing a proc we need to make sure to remove it from the callback list // before calling it. This is because the client could trigger a call (e.g. calling // flushAndSubmit(/*sync=*/true)) that has us process the finished callbacks. We also must // process deleting the sync before a client may abandon the context. auto& finishCallback = fCallbacks.front(); if (finishCallback.fSync) { fGpu->deleteSync(finishCallback.fSync); } skgpu::GpuStats stats; if (auto timerQuery = finishCallback.fTimerQuery) { stats.elapsedTime = fGpu->getTimerQueryResult(timerQuery); if (finishCallback.fCallback.receivesGpuStats()) { finishCallback.fCallback.setStats(stats); } } fCallbacks.pop_front(); } } void GrGLFinishCallbacks::callAll(bool doDelete) { while (!fCallbacks.empty()) { // While we are processing a proc we need to make sure to remove it from the callback list // before calling it. This is because the client could trigger a call (e.g. calling // flushAndSubmit(/*sync=*/true)) that has us process the finished callbacks. We also must // process deleting the sync before a client may abandon the context. auto& finishCallback = fCallbacks.front(); skgpu::GpuStats stats; if (doDelete && finishCallback.fSync) { fGpu->deleteSync(finishCallback.fSync); if (finishCallback.fTimerQuery) { stats.elapsedTime = fGpu->getTimerQueryResult(finishCallback.fTimerQuery); if (finishCallback.fCallback.receivesGpuStats()) { finishCallback.fCallback.setStats(stats); } } } fCallbacks.pop_front(); } }