dacho 0.2.0

ECS Game Engine
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85

// dacho/src/renderer/commands/pool.rs

// crates
use {
    anyhow::Result,
    ash::vk
};

// crate
use crate::{
    renderer::{
        devices::Device,
        VulkanDrop
    },
    create_log, destroy_log
};

pub struct CommandPool {
    pub raw: vk::CommandPool
}

impl CommandPool {
    pub fn new(device: &Device) -> Result<Self> {
        create_log!(debug);

        let raw = {
            let create_info = vk::CommandPoolCreateInfo::builder()
                .queue_family_index(0)
                .flags(vk::CommandPoolCreateFlags::RESET_COMMAND_BUFFER);

            unsafe { device.raw.create_command_pool(&create_info, None) }?
        };

        Ok(Self { raw })
    }

    pub fn begin_single_time_commands(&self, device: &Device) -> Result<vk::CommandBuffer> {
        let command_buffer = {
            let allocate_info = vk::CommandBufferAllocateInfo::builder()
                .level(vk::CommandBufferLevel::PRIMARY)
                .command_pool(self.raw)
                .command_buffer_count(1);

            unsafe { device.raw.allocate_command_buffers(&allocate_info) }?[0]
        };

        {
            let begin_info = vk::CommandBufferBeginInfo::builder()
                .flags(vk::CommandBufferUsageFlags::ONE_TIME_SUBMIT);

            unsafe { device.raw.begin_command_buffer(command_buffer, &begin_info) }?;
        }

        Ok(command_buffer)
    }

    pub fn end_single_time_commands(
        &self,
        device:         &Device,
        command_buffer:  vk::CommandBuffer
    ) -> Result<()> {
        unsafe { device.raw.end_command_buffer(command_buffer) }?;

        let command_buffers = [command_buffer];

        let submit_info = vk::SubmitInfo::builder()
            .command_buffers(&command_buffers);

        unsafe { device.raw.queue_submit(device.queue, &[*submit_info], vk::Fence::null()) }?;

        unsafe { device.raw.queue_wait_idle(device.queue) }?;
        unsafe { device.raw.free_command_buffers(self.raw, &command_buffers); }

        Ok(())
    }
}

impl VulkanDrop for CommandPool {
    fn drop(&self, device: &Device) {
        destroy_log!(debug);

        unsafe { device.raw.destroy_command_pool(self.raw, None); }
    }
}