source/core/bufferable.cpp

   1 #include <stdexcept>
   2 #include "buffer.h"
   3 #include "bufferable.h"
   4 #include "error.h"
   5
   6 using namespace std;
   7
   8 namespace Msp {
   9 namespace GL {
  10
  11 Bufferable::Bufferable(Bufferable &&other):
  12         buffer(other.buffer),
  13         offset(other.offset),
  14         next_in_buffer(other.next_in_buffer),
  15         prev_in_buffer(other.prev_in_buffer),
  16         location_dirty(other.location_dirty),
  17         dirty(other.dirty)
  18 {
  19         other.buffer = 0;
  20         other.next_in_buffer = 0;
  21         other.prev_in_buffer = 0;
  22         if(next_in_buffer)
  23                 next_in_buffer->prev_in_buffer = this;
  24         if(prev_in_buffer)
  25                 prev_in_buffer->next_in_buffer = this;
  26 }
  27
  28 Bufferable::~Bufferable()
  29 {
  30         unlink_from_buffer();
  31 }
  32
  33 void Bufferable::use_buffer(Buffer *buf, Bufferable *prev)
  34 {
  35         if(prev && buf!=prev->buffer)
  36                 throw invalid_argument("Bufferable::use_buffer");
  37
  38         if(buffer)
  39                 unlink_from_buffer();
  40
  41         buffer = buf;
  42         if(buffer)
  43         {
  44                 prev_in_buffer = prev;
  45                 if(prev_in_buffer)
  46                 {
  47                         next_in_buffer = prev_in_buffer->next_in_buffer;
  48                         prev_in_buffer->next_in_buffer = this;
  49                 }
  50         }
  51
  52         location_dirty = true;
  53         dirty = true;
  54         update_offset();
  55 }
  56
  57 void Bufferable::change_buffer(Buffer *buf)
  58 {
  59         for(Bufferable *b=this; b; b=b->next_in_buffer)
  60         {
  61                 b->buffer = buf;
  62                 b->location_dirty = true;
  63                 b->dirty = true;
  64         }
  65         for(Bufferable *b=prev_in_buffer; b; b=b->prev_in_buffer)
  66         {
  67                 b->buffer = buf;
  68                 b->location_dirty = true;
  69                 b->dirty = true;
  70         }
  71 }
  72
  73 size_t Bufferable::get_required_buffer_size() const
  74 {
  75         const Bufferable *last = this;
  76         for(; last->next_in_buffer; last=last->next_in_buffer) ;
  77         return last->offset+last->get_data_size();
  78 }
  79
  80 void Bufferable::unlink_from_buffer()
  81 {
  82         if(prev_in_buffer)
  83                 prev_in_buffer->next_in_buffer = next_in_buffer;
  84         if(next_in_buffer)
  85         {
  86                 next_in_buffer->prev_in_buffer = prev_in_buffer;
  87                 next_in_buffer->update_offset();
  88         }
  89         prev_in_buffer = 0;
  90         next_in_buffer = 0;
  91         buffer = 0;
  92         offset = 0;
  93 }
  94
  95 void Bufferable::update_offset()
  96 {
  97         size_t new_offset = 0;
  98         if(prev_in_buffer)
  99                 new_offset = prev_in_buffer->offset+prev_in_buffer->get_data_size();
 100
 101         size_t align = get_alignment();
 102         new_offset += align-1;
 103         new_offset -= new_offset%align;
 104         if(new_offset!=offset)
 105         {
 106                 offset = new_offset;
 107                 location_dirty = true;
 108                 dirty = true;
 109         }
 110
 111         if(next_in_buffer)
 112                 next_in_buffer->update_offset();
 113         else if(buffer && offset+get_data_size()>buffer->get_size())
 114         {
 115                 location_dirty = true;
 116                 dirty = true;
 117         }
 118 }
 119
 120 void Bufferable::upload_data(char *target) const
 121 {
 122         if(!buffer)
 123                 throw invalid_operation("Bufferable::upload_data");
 124
 125         size_t data_size = get_data_size();
 126         if(location_dirty)
 127         {
 128                 buffer->require_size(offset+data_size);
 129                 location_dirty = false;
 130         }
 131
 132         if(target)
 133         {
 134                 const char *source = reinterpret_cast<const char *>(get_data_pointer());
 135                 copy(source, source+data_size, target);
 136         }
 137         else
 138                 buffer->sub_data(offset, data_size, get_data_pointer());
 139         dirty = false;
 140 }
 141
 142
 143 Bufferable::AsyncUpdater::AsyncUpdater(const Bufferable &b):
 144         bufferable(b)
 145 {
 146         bufferable.buffer->require_size(bufferable.get_required_buffer_size());
 147         mapped_address = reinterpret_cast<char *>(bufferable.buffer->map());
 148 }
 149
 150 Bufferable::AsyncUpdater::~AsyncUpdater()
 151 {
 152         bufferable.buffer->unmap();
 153 }
 154
 155 void Bufferable::AsyncUpdater::upload_data()
 156 {
 157         bufferable.upload_data(mapped_address+bufferable.offset);
 158         // Update all bufferables in the same buffer at once
 159         for(const Bufferable *b=bufferable.prev_in_buffer; b; b=b->prev_in_buffer)
 160                 if(b->dirty)
 161                         b->upload_data(mapped_address+b->offset);
 162         for(const Bufferable *b=bufferable.next_in_buffer; b; b=b->next_in_buffer)
 163                 if(b->dirty)
 164                         b->upload_data(mapped_address+b->offset);
 165 }
 166
 167 } // namespace GL
 168 } // namespace Msp