X-Git-Url: http://git.tdb.fi/?p=libs%2Fgl.git;a=blobdiff_plain;f=source%2Fcore%2Fbufferable.cpp;h=d8f3c9c43f9622602851e03f38dd72221031d0b3;hp=374c4eeb3b83ee5d1617b9249383696a9f7aa15f;hb=HEAD;hpb=e70662d7812464159f2e47f4bebb69d88f89ae93 diff --git a/source/core/bufferable.cpp b/source/core/bufferable.cpp index 374c4eeb..d8f3c9c4 100644 --- a/source/core/bufferable.cpp +++ b/source/core/bufferable.cpp @@ -1,5 +1,4 @@ #include -#include "buffer.h" #include "bufferable.h" #include "error.h" @@ -50,7 +49,7 @@ void Bufferable::use_buffer(Buffer *buf, Bufferable *prev) } location_dirty = true; - dirty = true; + mark_dirty(); update_offset(); } @@ -60,21 +59,30 @@ void Bufferable::change_buffer(Buffer *buf) { b->buffer = buf; b->location_dirty = true; - b->dirty = true; + b->mark_dirty(); } for(Bufferable *b=prev_in_buffer; b; b=b->prev_in_buffer) { b->buffer = buf; b->location_dirty = true; - b->dirty = true; + b->mark_dirty(); } } -size_t Bufferable::get_required_buffer_size() const +size_t Bufferable::get_required_buffer_size(bool align) const { const Bufferable *last = this; for(; last->next_in_buffer; last=last->next_in_buffer) ; - return last->offset+last->get_data_size(); + size_t size = last->offset+last->get_data_size(); + if(align) + { + const Bufferable *first = this; + for(; first->prev_in_buffer; first=first->prev_in_buffer) ; + size_t alignment = first->get_alignment(); + size += alignment-1; + size -= size%alignment; + } + return size; } void Bufferable::unlink_from_buffer() @@ -105,7 +113,7 @@ void Bufferable::update_offset() { offset = new_offset; location_dirty = true; - dirty = true; + mark_dirty(); } if(next_in_buffer) @@ -113,15 +121,26 @@ void Bufferable::update_offset() else if(buffer && offset+get_data_size()>buffer->get_size()) { location_dirty = true; - dirty = true; + mark_dirty(); } } -void Bufferable::upload_data(char *target) const +void Bufferable::mark_dirty() +{ + dirty = 0xFF; +} + +void Bufferable::upload_data(unsigned frame, char *target) const { if(!buffer) throw invalid_operation("Bufferable::upload_data"); + unsigned multi_buf = buffer->get_multiplicity(); + frame %= multi_buf; + uint8_t mask = 1<sub_data(offset, data_size, get_data_pointer()); - dirty = false; + buffer->sub_data(frame*buffer->get_size()+offset, data_size, get_data_pointer()); + dirty &= ~mask; + if(!(dirty&((1<require_size(bufferable.get_required_buffer_size()); - mapped_address = reinterpret_cast(bufferable.buffer->map()); + if(!buffer || buffer->get_multiplicity()>1) + throw invalid_operation("Bufferable::create_async_updater"); + return new AsyncUpdater(*this); } -Bufferable::AsyncUpdater::~AsyncUpdater() -{ - bufferable.buffer->unmap(); -} + +Bufferable::AsyncUpdater::AsyncUpdater(const Bufferable &b): + bufferable(b), + transfer(b.buffer->sub_data_async(0, bufferable.get_required_buffer_size())) +{ } void Bufferable::AsyncUpdater::upload_data() { - bufferable.upload_data(mapped_address+bufferable.offset); + char *mapped_address = static_cast(transfer.get_address()); + bufferable.upload_data(0, mapped_address+bufferable.offset); // Update all bufferables in the same buffer at once for(const Bufferable *b=bufferable.prev_in_buffer; b; b=b->prev_in_buffer) if(b->dirty) - b->upload_data(mapped_address+b->offset); + b->upload_data(0, mapped_address+b->offset); for(const Bufferable *b=bufferable.next_in_buffer; b; b=b->next_in_buffer) if(b->dirty) - b->upload_data(mapped_address+b->offset); + b->upload_data(0, mapped_address+b->offset); } } // namespace GL