6502/CLK
1
0
Fork 0
mirror of https://github.com/TomHarte/CLK.git synced 2024-07-06 01:28:57 +00:00
Code Issues Projects Releases Wiki Activity

Added a testing hook, but as of yet no tests.

Browse Source
This commit is contained in:
Thomas Harte 2016-11-17 14:06:16 +08:00
parent aca1fa0577
commit f59537bce9
2 changed files with 39 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

48
Outputs/CRT/Internals/ArrayBuilder.cpp
View File

@ -11,8 +11,13 @@
using namespace Outputs::CRT;
ArrayBuilder::ArrayBuilder(size_t input_size, size_t output_size) :
output_(output_size),
input_(input_size)
output_(output_size, nullptr),
input_(input_size, nullptr)
{}
ArrayBuilder::ArrayBuilder(size_t input_size, size_t output_size, std::function<void(bool is_input, uint8_t *, size_t)> submission_function) :
output_(output_size, submission_function),
input_(input_size, submission_function)
{}
bool ArrayBuilder::is_full()
@ -70,8 +75,8 @@ ArrayBuilder::Submission ArrayBuilder::submit()
ArrayBuilder::Submission submission;
buffer_mutex_.lock();
submission.input_size = input_.submit();
submission.output_size = output_.submit();
submission.input_size = input_.submit(true);
submission.output_size = output_.submit(false);
if(is_full_)
{
is_full_ = false;
@ -83,18 +88,22 @@ ArrayBuilder::Submission ArrayBuilder::submit()
return submission;
}
ArrayBuilder::Buffer::Buffer(size_t size) :
allocated_data(0), flushed_data(0), submitted_data(0), is_full(false)
ArrayBuilder::Buffer::Buffer(size_t size, std::function<void(bool is_input, uint8_t *, size_t)> submission_function) :
allocated_data(0), flushed_data(0), submitted_data(0), is_full(false), submission_function_(submission_function)
{
glGenBuffers(1, &buffer);
glBindBuffer(GL_ARRAY_BUFFER, buffer);
glBufferData(GL_ARRAY_BUFFER, (GLsizeiptr)size, NULL, GL_STREAM_DRAW);
if(!submission_function_)
{
glGenBuffers(1, &buffer);
glBindBuffer(GL_ARRAY_BUFFER, buffer);
glBufferData(GL_ARRAY_BUFFER, (GLsizeiptr)size, NULL, GL_STREAM_DRAW);
}
data.resize(size);
}
ArrayBuilder::Buffer::~Buffer()
{
glDeleteBuffers(1, &buffer);
if(!submission_function_)
glDeleteBuffers(1, &buffer);
}
uint8_t *ArrayBuilder::get_storage(size_t size, Buffer &buffer)
@ -151,16 +160,19 @@ void ArrayBuilder::Buffer::flush()
}
}
size_t ArrayBuilder::Buffer::submit()
size_t ArrayBuilder::Buffer::submit(bool is_input)
{
size_t length = flushed_data;
glBindBuffer(GL_ARRAY_BUFFER, buffer);
uint8_t *destination = (uint8_t *)glMapBufferRange(GL_ARRAY_BUFFER, 0, (GLsizeiptr)length, GL_MAP_WRITE_BIT | GL_MAP_UNSYNCHRONIZED_BIT | GL_MAP_FLUSH_EXPLICIT_BIT);
memcpy(destination, data.data(), length);
glFlushMappedBufferRange(GL_ARRAY_BUFFER, 0, (GLsizeiptr)length);
glUnmapBuffer(GL_ARRAY_BUFFER);
if(submission_function_)
submission_function_(is_input, data.data(), length);
else
{
glBindBuffer(GL_ARRAY_BUFFER, buffer);
uint8_t *destination = (uint8_t *)glMapBufferRange(GL_ARRAY_BUFFER, 0, (GLsizeiptr)length, GL_MAP_WRITE_BIT | GL_MAP_UNSYNCHRONIZED_BIT | GL_MAP_FLUSH_EXPLICIT_BIT);
memcpy(destination, data.data(), length);
glFlushMappedBufferRange(GL_ARRAY_BUFFER, 0, (GLsizeiptr)length);
glUnmapBuffer(GL_ARRAY_BUFFER);
}
submitted_data = flushed_data;
return length;
}

11
Outputs/CRT/Internals/ArrayBuilder.hpp
View File

@ -32,6 +32,11 @@ class ArrayBuilder {
/// @c input_size bytes of storage for the input buffer.
ArrayBuilder(size_t input_size, size_t output_size);
/// Creates an instance of ArrayBuilder with @c output_size bytes of storage for the output buffer and
/// @c input_size bytes of storage for the input buffer that, rather than using OpenGL, will submit data
/// to the @c submission_function. [Teleological: this is provided as a testing hook.]
ArrayBuilder(size_t input_size, size_t output_size, std::function<void(bool is_input, uint8_t *, size_t)> submission_function);
/// Attempts to add @c size bytes
uint8_t *get_input_storage(size_t size);
uint8_t *reget_input_storage(size_t &size);
@ -52,7 +57,7 @@ class ArrayBuilder {
private:
struct Buffer {
Buffer(size_t size);
Buffer(size_t size, std::function<void(bool is_input, uint8_t *, size_t)> submission_function);
~Buffer();
std::vector<uint8_t> data;
@ -66,14 +71,16 @@ class ArrayBuilder {
uint8_t *reget_storage(size_t &size);
void flush();
size_t submit();
size_t submit(bool is_input);
void bind();
void reset();
std::function<void(bool is_input, uint8_t *, size_t)> submission_function_;
} output_, input_;
uint8_t *get_storage(size_t size, Buffer &buffer);
std::mutex buffer_mutex_;
bool is_full_;
;
};
}