| Flutter Impeller |

command_queue_vk.cc
Go to the documentation of this file.
1 // Copyright 2013 The Flutter Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file.
4
5 #include "fml/status.h"
6
7 #include "impeller/renderer/backend/vulkan/command_queue_vk.h"
8
9 #include "impeller/base/validation.h"
10 #include "impeller/renderer/backend/vulkan/command_buffer_vk.h"
11 #include "impeller/renderer/backend/vulkan/context_vk.h"
12 #include "impeller/renderer/backend/vulkan/fence_waiter_vk.h"
13 #include "impeller/renderer/backend/vulkan/tracked_objects_vk.h"
14 #include "impeller/renderer/command_buffer.h"
15
16 namespace impeller {
17
18 CommandQueueVK::CommandQueueVK(const std::weak_ptr<ContextVK>& context)
19 : context_(context) {}
20
21 CommandQueueVK::~CommandQueueVK() = default;
22
23 fml::Status CommandQueueVK::Submit(
24 const std::vector<std::shared_ptr<CommandBuffer>>& buffers,
25 const CompletionCallback& completion_callback,
26 bool block_on_schedule) {
27 if (buffers.empty()) {
28 return fml::Status(fml::StatusCode::kInvalidArgument,
29 "No command buffers provided.");
30 }
31 // Success or failure, you only get to submit once.
32 fml::ScopedCleanupClosure reset([&]() {
33 if (completion_callback) {
34 completion_callback(CommandBuffer::Status::kError);
35 }
36 });
37
38 std::vector<vk::CommandBuffer> vk_buffers;
39 std::vector<std::shared_ptr<TrackedObjectsVK>> tracked_objects;
40 vk_buffers.reserve(buffers.size());
41 tracked_objects.reserve(buffers.size());
42 for (const std::shared_ptr<CommandBuffer>& buffer : buffers) {
43 CommandBufferVK& command_buffer = CommandBufferVK::Cast(*buffer);
44 if (!command_buffer.EndCommandBuffer()) {
45 return fml::Status(fml::StatusCode::kCancelled,
46 "Failed to end command buffer.");
47 }
48 vk_buffers.push_back(command_buffer.GetCommandBuffer());
49 tracked_objects.push_back(std::move(command_buffer.tracked_objects_));
50 }
51
52 auto context = context_.lock();
53 if (!context) {
54 VALIDATION_LOG << "Device lost.";
55 return fml::Status(fml::StatusCode::kCancelled, "Device lost.");
56 }
57 auto [fence_result, fence] = context->GetDevice().createFenceUnique({});
58 if (fence_result != vk::Result::eSuccess) {
59 VALIDATION_LOG << "Failed to create fence: " << vk::to_string(fence_result);
60 return fml::Status(fml::StatusCode::kCancelled, "Failed to create fence.");
61 }
62
63 vk::SubmitInfo submit_info;
64 submit_info.setCommandBuffers(vk_buffers);
65 auto status = context->GetGraphicsQueue()->Submit(submit_info, *fence);
66 if (status != vk::Result::eSuccess) {
67 VALIDATION_LOG << "Failed to submit queue: " << vk::to_string(status);
68 return fml::Status(fml::StatusCode::kCancelled, "Failed to submit queue: ");
69 }
70
71 // Submit will proceed, call callback with true when it is done and do not
72 // call when `reset` is collected.
73 auto added_fence = context->GetFenceWaiter()->AddFence(
74 std::move(fence), [completion_callback, tracked_objects = std::move(
75 tracked_objects)]() mutable {
76 // Ensure tracked objects are destructed before calling any final
77 // callbacks.
78 tracked_objects.clear();
79 if (completion_callback) {
80 completion_callback(CommandBuffer::Status::kCompleted);
81 }
82 });
83 if (!added_fence) {
84 return fml::Status(fml::StatusCode::kCancelled, "Failed to add fence.");
85 }
86 reset.Release();
87 return fml::Status();
88 }
89
90 } // namespace impeller
impeller::BackendCast< CommandBufferVK, CommandBuffer >::Cast
static CommandBufferVK & Cast(CommandBuffer &base)
Definition: backend_cast.h:13
impeller::CommandBuffer::Status::kCompleted
@ kCompleted
impeller::CommandBuffer::Status::kError
@ kError
impeller::CommandBufferVK
Definition: command_buffer_vk.h:27
impeller::CommandBufferVK::EndCommandBuffer
bool EndCommandBuffer() const
End recording of the current command buffer.
Definition: command_buffer_vk.cc:106
impeller::CommandBufferVK::GetCommandBuffer
vk::CommandBuffer GetCommandBuffer() const
Retrieve the native command buffer from this object.
Definition: command_buffer_vk.cc:120
impeller::CommandQueue::CompletionCallback
std::function< void(CommandBuffer::Status)> CompletionCallback
Definition: command_queue.h:19
impeller::CommandQueueVK::~CommandQueueVK
~CommandQueueVK() override
impeller::CommandQueueVK::CommandQueueVK
CommandQueueVK(const std::weak_ptr< ContextVK > &context)
Definition: command_queue_vk.cc:18
impeller::CommandQueueVK::Submit
fml::Status Submit(const std::vector< std::shared_ptr< CommandBuffer >> &buffers, const CompletionCallback &completion_callback={}, bool block_on_schedule=false) override
Submit one or more command buffer objects to be encoded and executed on the GPU.
Definition: command_queue_vk.cc:23
command_buffer.h
command_buffer_vk.h
command_queue_vk.h
fence_waiter_vk.h
impeller
Definition: allocation.cc:12
context_vk.h
tracked_objects_vk.h
validation.h
VALIDATION_LOG
#define VALIDATION_LOG
Definition: validation.h:91