rafx-api 0.0.16

Rendering framework built on an extensible asset pipeline
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
86
87
88
89
90
91
92
93
94
95
96

use crate::gles2::RafxDeviceContextGles2;
use crate::{RafxFenceStatus, RafxResult};
use rafx_base::trust_cell::TrustCell;
use std::sync::atomic::{AtomicBool, Ordering};

//TODO: GL ES 3.0 has some sync primitives

pub struct RafxFenceGles2 {
    device_context: RafxDeviceContextGles2,
    // Set to true when an operation is scheduled to signal this fence
    // Cleared when an operation is scheduled to consume this fence
    submitted: AtomicBool,
    gl_finish_call_count: TrustCell<u64>,
}

impl RafxFenceGles2 {
    pub fn new(device_context: &RafxDeviceContextGles2) -> RafxResult<RafxFenceGles2> {
        // Fences are not available on OpenGL ES 2.0
        // use glFlush for Gpu->Cpu sync
        Ok(RafxFenceGles2 {
            device_context: device_context.clone(),
            submitted: AtomicBool::new(false),
            gl_finish_call_count: Default::default(),
        })
    }

    pub(crate) fn submitted(&self) -> bool {
        self.submitted.load(Ordering::Relaxed)
    }

    pub fn wait(&self) -> RafxResult<()> {
        if self.submitted() {
            self.device_context.gl_finish()?;
        }

        self.set_submitted(false);
        Ok(())
    }

    pub fn wait_for_fences(
        _device_context: &RafxDeviceContextGles2,
        fences: &[&RafxFenceGles2],
    ) -> RafxResult<()> {
        let mut finish_called = false;
        for fence in fences {
            if fence.submitted() {
                fence.device_context.gl_finish()?;
                finish_called = true;
                break;
            }
        }

        if finish_called {
            for fence in fences {
                fence.set_submitted(false);
            }
        }

        Ok(())
    }

    pub(crate) fn set_submitted(
        &self,
        available: bool,
    ) {
        if available {
            // Set the call count to the global device count. If it increments past the cached count,
            // we will know that finish was called since this fence was submitted
            *self.gl_finish_call_count.borrow_mut() = self
                .device_context
                .inner
                .gl_finish_call_count
                .load(Ordering::Relaxed);
        }
        self.submitted.store(available, Ordering::Relaxed);
    }

    pub fn get_fence_status(&self) -> RafxResult<RafxFenceStatus> {
        if !self.submitted() {
            Ok(RafxFenceStatus::Unsubmitted)
        } else {
            if *self.gl_finish_call_count.borrow()
                >= self
                    .device_context
                    .inner
                    .gl_finish_call_count
                    .load(Ordering::Relaxed)
            {
                self.set_submitted(false);
                Ok(RafxFenceStatus::Complete)
            } else {
                Ok(RafxFenceStatus::Incomplete)
            }
        }
    }
}