diff --git a/Source/Plugins/Plugin_VideoOGL/Src/StreamBuffer.cpp b/Source/Plugins/Plugin_VideoOGL/Src/StreamBuffer.cpp index 6b6eb57238..22fb044718 100644 --- a/Source/Plugins/Plugin_VideoOGL/Src/StreamBuffer.cpp +++ b/Source/Plugins/Plugin_VideoOGL/Src/StreamBuffer.cpp @@ -23,12 +23,15 @@ namespace OGL { -StreamBuffer::StreamBuffer(u32 type, size_t size) -: m_buffertype(type), m_size(size), m_iterator(0) +static const u32 SYNC_POINTS = 16; + +StreamBuffer::StreamBuffer(u32 type, size_t size, StreamType uploadType) +: m_uploadtype(uploadType), m_buffertype(type), m_size(size), m_iterator(0), m_last_iterator(0) { glGenBuffers(1, &m_buffer); - m_uploadtype = MAP_AND_ORPHAN; + if(m_uploadtype == STREAM_DETECT) + m_uploadtype = MAP_AND_ORPHAN; Init(); } @@ -39,32 +42,51 @@ StreamBuffer::~StreamBuffer() glDeleteBuffers(1, &m_buffer); } -void StreamBuffer::Align ( u32 stride ) +void StreamBuffer::Alloc ( size_t size, u32 stride ) { - if(m_iterator) { - m_iterator--; - m_iterator = m_iterator - (m_iterator % stride) + stride; + size_t m_iterator_aligned = m_iterator; + if(m_iterator_aligned && stride) { + m_iterator_aligned--; + m_iterator_aligned = m_iterator_aligned - (m_iterator_aligned % stride) + stride; } -} - -void StreamBuffer::Alloc ( size_t size ) -{ + switch(m_uploadtype) { case MAP_AND_ORPHAN: - if(m_iterator+size >= m_size) { + if(m_iterator_aligned+size >= m_size) { glBufferData(m_buffertype, m_size, NULL, GL_STREAM_DRAW); - m_iterator = 0; + m_iterator_aligned = 0; + } + break; + case MAP_AND_SYNC: + for(u32 i=m_iterator*SYNC_POINTS/m_size+1; i<(m_iterator_aligned+size)*SYNC_POINTS/m_size+1 && i < SYNC_POINTS; i++) + { + glClientWaitSync(fences[i], GL_SYNC_FLUSH_COMMANDS_BIT, GL_TIMEOUT_IGNORED); + glDeleteSync(fences[i]); + } + + if(m_iterator_aligned+size >= m_size) { + for(u32 i=m_last_iterator*SYNC_POINTS/m_size; i < SYNC_POINTS; i++) + fences[i] = glFenceSync(GL_SYNC_GPU_COMMANDS_COMPLETE, 0); + m_iterator_aligned = 0; + m_last_iterator = 0; + glClientWaitSync(fences[0], GL_SYNC_FLUSH_COMMANDS_BIT, GL_TIMEOUT_IGNORED); + glDeleteSync(fences[0]); } break; case BUFFERSUBDATA: - m_iterator = 0; + m_iterator_aligned = 0; break; } + + m_iterator = m_iterator_aligned; } size_t StreamBuffer::Upload ( u8* data, size_t size ) { switch(m_uploadtype) { + case MAP_AND_SYNC: + for(u32 i=m_last_iterator*SYNC_POINTS/m_size; iAlign(stride); - s_vertexBuffer->Alloc(vertex_data_size); + s_vertexBuffer->Alloc(vertex_data_size, stride); u32 offset = s_vertexBuffer->Upload(LocalVBuffer, vertex_data_size); s_baseVertex = offset / stride;