use smallvec::SmallVec;
use command_buffer::submit::SubmitCommandBufferBuilder;
use command_buffer::submit::SubmitPresentBuilder;
use sync::PipelineStages;
use sync::Semaphore;
#[derive(Debug)]
pub struct SubmitSemaphoresWaitBuilder<'a> {
semaphores: SmallVec<[&'a Semaphore; 8]>,
}
impl<'a> SubmitSemaphoresWaitBuilder<'a> {
#[inline]
pub fn new() -> SubmitSemaphoresWaitBuilder<'a> {
SubmitSemaphoresWaitBuilder { semaphores: SmallVec::new() }
}
#[inline]
pub unsafe fn add_wait_semaphore(&mut self, semaphore: &'a Semaphore) {
self.semaphores.push(semaphore);
}
#[inline]
pub fn merge(&mut self, mut other: SubmitSemaphoresWaitBuilder<'a>) {
self.semaphores.extend(other.semaphores.drain());
}
}
impl<'a> Into<SubmitCommandBufferBuilder<'a>> for SubmitSemaphoresWaitBuilder<'a> {
#[inline]
fn into(mut self) -> SubmitCommandBufferBuilder<'a> {
unsafe {
let mut builder = SubmitCommandBufferBuilder::new();
for sem in self.semaphores.drain() {
builder.add_wait_semaphore(sem,
PipelineStages {
all_commands: true,
..PipelineStages::none()
});
}
builder
}
}
}
impl<'a> Into<SubmitPresentBuilder<'a>> for SubmitSemaphoresWaitBuilder<'a> {
#[inline]
fn into(mut self) -> SubmitPresentBuilder<'a> {
unsafe {
let mut builder = SubmitPresentBuilder::new();
for sem in self.semaphores.drain() {
builder.add_wait_semaphore(sem);
}
builder
}
}
}