bevy_render/render_resource/
uniform_buffer.rs1use core::{marker::PhantomData, num::NonZero};
2
3use crate::{
4 render_resource::Buffer,
5 renderer::{RenderDevice, RenderQueue},
6};
7use encase::{
8 internal::{AlignmentValue, BufferMut, WriteInto},
9 DynamicUniformBuffer as DynamicUniformBufferWrapper, ShaderType,
10 UniformBuffer as UniformBufferWrapper,
11};
12use wgpu::{
13 util::BufferInitDescriptor, BindingResource, BufferBinding, BufferDescriptor, BufferUsages,
14};
15
16use super::IntoBinding;
17
18pub struct UniformBuffer<T: ShaderType> {
40 value: T,
41 scratch: UniformBufferWrapper<Vec<u8>>,
42 buffer: Option<Buffer>,
43 label: Option<String>,
44 changed: bool,
45 buffer_usage: BufferUsages,
46}
47
48impl<T: ShaderType> From<T> for UniformBuffer<T> {
49 fn from(value: T) -> Self {
50 Self {
51 value,
52 scratch: UniformBufferWrapper::new(Vec::new()),
53 buffer: None,
54 label: None,
55 changed: false,
56 buffer_usage: BufferUsages::COPY_DST | BufferUsages::UNIFORM,
57 }
58 }
59}
60
61impl<T: ShaderType + Default> Default for UniformBuffer<T> {
62 fn default() -> Self {
63 Self {
64 value: T::default(),
65 scratch: UniformBufferWrapper::new(Vec::new()),
66 buffer: None,
67 label: None,
68 changed: false,
69 buffer_usage: BufferUsages::COPY_DST | BufferUsages::UNIFORM,
70 }
71 }
72}
73
74impl<T: ShaderType + WriteInto> UniformBuffer<T> {
75 #[inline]
76 pub fn buffer(&self) -> Option<&Buffer> {
77 self.buffer.as_ref()
78 }
79
80 #[inline]
81 pub fn binding(&self) -> Option<BindingResource> {
82 Some(BindingResource::Buffer(
83 self.buffer()?.as_entire_buffer_binding(),
84 ))
85 }
86
87 pub fn set(&mut self, value: T) {
89 self.value = value;
90 }
91
92 pub fn get(&self) -> &T {
93 &self.value
94 }
95
96 pub fn get_mut(&mut self) -> &mut T {
97 &mut self.value
98 }
99
100 pub fn set_label(&mut self, label: Option<&str>) {
101 let label = label.map(str::to_string);
102
103 if label != self.label {
104 self.changed = true;
105 }
106
107 self.label = label;
108 }
109
110 pub fn get_label(&self) -> Option<&str> {
111 self.label.as_deref()
112 }
113
114 pub fn add_usages(&mut self, usage: BufferUsages) {
120 self.buffer_usage |= usage;
121 self.changed = true;
122 }
123
124 pub fn write_buffer(&mut self, device: &RenderDevice, queue: &RenderQueue) {
130 self.scratch.write(&self.value).unwrap();
131
132 if self.changed || self.buffer.is_none() {
133 self.buffer = Some(device.create_buffer_with_data(&BufferInitDescriptor {
134 label: self.label.as_deref(),
135 usage: self.buffer_usage,
136 contents: self.scratch.as_ref(),
137 }));
138 self.changed = false;
139 } else if let Some(buffer) = &self.buffer {
140 queue.write_buffer(buffer, 0, self.scratch.as_ref());
141 }
142 }
143}
144
145impl<'a, T: ShaderType + WriteInto> IntoBinding<'a> for &'a UniformBuffer<T> {
146 #[inline]
147 fn into_binding(self) -> BindingResource<'a> {
148 self.buffer()
149 .expect("Failed to get buffer")
150 .as_entire_buffer_binding()
151 .into_binding()
152 }
153}
154
155pub struct DynamicUniformBuffer<T: ShaderType> {
178 scratch: DynamicUniformBufferWrapper<Vec<u8>>,
179 buffer: Option<Buffer>,
180 label: Option<String>,
181 changed: bool,
182 buffer_usage: BufferUsages,
183 _marker: PhantomData<fn() -> T>,
184}
185
186impl<T: ShaderType> Default for DynamicUniformBuffer<T> {
187 fn default() -> Self {
188 Self {
189 scratch: DynamicUniformBufferWrapper::new(Vec::new()),
190 buffer: None,
191 label: None,
192 changed: false,
193 buffer_usage: BufferUsages::COPY_DST | BufferUsages::UNIFORM,
194 _marker: PhantomData,
195 }
196 }
197}
198
199impl<T: ShaderType + WriteInto> DynamicUniformBuffer<T> {
200 pub fn new_with_alignment(alignment: u64) -> Self {
201 Self {
202 scratch: DynamicUniformBufferWrapper::new_with_alignment(Vec::new(), alignment),
203 buffer: None,
204 label: None,
205 changed: false,
206 buffer_usage: BufferUsages::COPY_DST | BufferUsages::UNIFORM,
207 _marker: PhantomData,
208 }
209 }
210
211 #[inline]
212 pub fn buffer(&self) -> Option<&Buffer> {
213 self.buffer.as_ref()
214 }
215
216 #[inline]
217 pub fn binding(&self) -> Option<BindingResource> {
218 Some(BindingResource::Buffer(BufferBinding {
219 buffer: self.buffer()?,
220 offset: 0,
221 size: Some(T::min_size()),
222 }))
223 }
224
225 #[inline]
226 pub fn is_empty(&self) -> bool {
227 self.scratch.as_ref().is_empty()
228 }
229
230 #[inline]
232 pub fn push(&mut self, value: &T) -> u32 {
233 self.scratch.write(value).unwrap() as u32
234 }
235
236 pub fn set_label(&mut self, label: Option<&str>) {
237 let label = label.map(str::to_string);
238
239 if label != self.label {
240 self.changed = true;
241 }
242
243 self.label = label;
244 }
245
246 pub fn get_label(&self) -> Option<&str> {
247 self.label.as_deref()
248 }
249
250 pub fn add_usages(&mut self, usage: BufferUsages) {
256 self.buffer_usage |= usage;
257 self.changed = true;
258 }
259
260 #[inline]
276 pub fn get_writer<'a>(
277 &'a mut self,
278 max_count: usize,
279 device: &RenderDevice,
280 queue: &'a RenderQueue,
281 ) -> Option<DynamicUniformBufferWriter<'a, T>> {
282 let alignment = if cfg!(feature = "ios_simulator") {
283 AlignmentValue::new(256)
288 } else {
289 AlignmentValue::new(device.limits().min_uniform_buffer_offset_alignment as u64)
290 };
291
292 let mut capacity = self.buffer.as_deref().map(wgpu::Buffer::size).unwrap_or(0);
293 let size = alignment
294 .round_up(T::min_size().get())
295 .checked_mul(max_count as u64)
296 .unwrap();
297
298 if capacity < size || (self.changed && size > 0) {
299 let buffer = device.create_buffer(&BufferDescriptor {
300 label: self.label.as_deref(),
301 usage: self.buffer_usage,
302 size,
303 mapped_at_creation: false,
304 });
305 capacity = buffer.size();
306 self.buffer = Some(buffer);
307 self.changed = false;
308 }
309
310 if let Some(buffer) = self.buffer.as_deref() {
311 let buffer_view = queue
312 .write_buffer_with(buffer, 0, NonZero::<u64>::new(buffer.size())?)
313 .unwrap();
314 Some(DynamicUniformBufferWriter {
315 buffer: encase::DynamicUniformBuffer::new_with_alignment(
316 QueueWriteBufferViewWrapper {
317 capacity: capacity as usize,
318 buffer_view,
319 },
320 alignment.get(),
321 ),
322 _marker: PhantomData,
323 })
324 } else {
325 None
326 }
327 }
328
329 #[inline]
335 pub fn write_buffer(&mut self, device: &RenderDevice, queue: &RenderQueue) {
336 let capacity = self.buffer.as_deref().map(wgpu::Buffer::size).unwrap_or(0);
337 let size = self.scratch.as_ref().len() as u64;
338
339 if capacity < size || (self.changed && size > 0) {
340 self.buffer = Some(device.create_buffer_with_data(&BufferInitDescriptor {
341 label: self.label.as_deref(),
342 usage: self.buffer_usage,
343 contents: self.scratch.as_ref(),
344 }));
345 self.changed = false;
346 } else if let Some(buffer) = &self.buffer {
347 queue.write_buffer(buffer, 0, self.scratch.as_ref());
348 }
349 }
350
351 #[inline]
352 pub fn clear(&mut self) {
353 self.scratch.as_mut().clear();
354 self.scratch.set_offset(0);
355 }
356}
357
358pub struct DynamicUniformBufferWriter<'a, T> {
362 buffer: encase::DynamicUniformBuffer<QueueWriteBufferViewWrapper<'a>>,
363 _marker: PhantomData<fn() -> T>,
364}
365
366impl<'a, T: ShaderType + WriteInto> DynamicUniformBufferWriter<'a, T> {
367 pub fn write(&mut self, value: &T) -> u32 {
368 self.buffer.write(value).unwrap() as u32
369 }
370}
371
372struct QueueWriteBufferViewWrapper<'a> {
375 buffer_view: wgpu::QueueWriteBufferView<'a>,
376 capacity: usize,
379}
380
381impl<'a> BufferMut for QueueWriteBufferViewWrapper<'a> {
382 #[inline]
383 fn capacity(&self) -> usize {
384 self.capacity
385 }
386
387 #[inline]
388 fn write<const N: usize>(&mut self, offset: usize, val: &[u8; N]) {
389 self.buffer_view.write(offset, val);
390 }
391
392 #[inline]
393 fn write_slice(&mut self, offset: usize, val: &[u8]) {
394 self.buffer_view.write_slice(offset, val);
395 }
396}
397
398impl<'a, T: ShaderType + WriteInto> IntoBinding<'a> for &'a DynamicUniformBuffer<T> {
399 #[inline]
400 fn into_binding(self) -> BindingResource<'a> {
401 self.binding().unwrap()
402 }
403}