mitchellhansen
/
conways-game-of-life-gpu
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Cleaned up the decoder, weird failbit behaviour from gitline.

Browse Source
master
MitchellHansen 8 years ago
parent 66ca187f45
commit c7ddfd8ba5
6 changed files with 212 additions and 263 deletions
Show Stats Download Patch File Download Diff File

9
include/Decoder.h
Unescape View File

@ -1,6 +1,7 @@
#pragma once #pragma once
#include <iostream> #include <iostream>
#include <fstream>
#include <sstream>
#include <experimental/filesystem> #include <experimental/filesystem>
#include <vector> #include <vector>
#include <SFML/Graphics.hpp> #include <SFML/Graphics.hpp>
@ -12,7 +13,7 @@ struct pattern_info {
std::string comments; std::string comments;
sf::Vector2i dimensions; sf::Vector2i dimensions;
char *pattern; char *nodes;
}; };
@ -24,11 +25,11 @@ public:
~Decoder(); ~Decoder();
pattern_info decodePattern(std::string pattern); pattern_info decodePattern(std::string pattern);
std::vector<std::string> getPatternList(); std::vector<const char*> getPatternList();
private: private:
std::vector<std::string> pattern_list; std::vector<const char*> pattern_list;
}; };

2
include/OpenCL.h
Unescape View File

@ -56,6 +56,8 @@ public:
// Have CL create and manage the texture for the image buffer. Access Type is the read/write specifier required by OpenCL // Have CL create and manage the texture for the image buffer. Access Type is the read/write specifier required by OpenCL
bool create_image_buffer(std::string buffer_name, sf::Vector2i size, sf::Vector2f position, cl_int access_type); bool create_image_buffer(std::string buffer_name, sf::Vector2i size, sf::Vector2f position, cl_int access_type);
bool map_buffer(std::string buffer_name, unsigned int size, void* data = nullptr);
// Create a buffer with CL_MEM_READ_ONLY and CL_MEM_COPY_HOST_PTR // Create a buffer with CL_MEM_READ_ONLY and CL_MEM_COPY_HOST_PTR
int create_buffer(std::string buffer_name, cl_uint size, void* data); int create_buffer(std::string buffer_name, cl_uint size, void* data);

19
kernels/conways.cl
Unescape View File

@ -21,11 +21,10 @@ __kernel void conways (
size_t x_pixel = get_global_id(0); size_t x_pixel = get_global_id(0);
size_t y_pixel = get_global_id(1); size_t y_pixel = get_global_id(1);
//printf(": %i", y_pixel);
int2 pixel = (int2)(x_pixel, y_pixel); int2 pixel = (int2)(x_pixel, y_pixel);
// if (pixel.x == 0 && pixel.y == 0)
// printf("Run");
//if (pixel.x > 1800) //if (pixel.x > 1800)
// printf("%i, %i", pixel.x, pixel.y); // printf("%i, %i", pixel.x, pixel.y);
@ -39,6 +38,8 @@ __kernel void conways (
if (*buffer_flip == 0){ if (*buffer_flip == 0){
// if (pixel.x == 0 && pixel.y == 0)
// printf("Buffer 0");
// Top // Top
val = pixel_to_index(*image_res, (int2)(pixel.x, pixel.y+1)); val = pixel_to_index(*image_res, (int2)(pixel.x, pixel.y+1));
if (val >= 0) if (val >= 0)
@ -89,7 +90,7 @@ __kernel void conways (
second_node_buffer[base] = 0; second_node_buffer[base] = 0;
} }
} else { } else if (*buffer_flip == 1) {
// Top // Top
val = pixel_to_index(*image_res, (int2)(pixel.x, pixel.y+1)); val = pixel_to_index(*image_res, (int2)(pixel.x, pixel.y+1));
@ -140,5 +141,15 @@ __kernel void conways (
//write_imagef(image, pixel, mix(read_imagef(image, pixel), flavor, 0.01f)); //write_imagef(image, pixel, mix(read_imagef(image, pixel), flavor, 0.01f));
first_node_buffer[base] = 0; first_node_buffer[base] = 0;
} }
} else{
int base = pixel_to_index(*image_res, pixel);
if (first_node_buffer[base]){
write_imagef(image, pixel, alive);
first_node_buffer[base] = 1;
} else {
write_imagef(image, pixel, dead);
//write_imagef(image, pixel, mix(read_imagef(image, pixel), flavor, 0.01f));
first_node_buffer[base] = 0;
}
} }
} }

241
src/Decoder.cpp
Unescape View File

@ -6,7 +6,12 @@ Decoder::Decoder() {
std::cout << "Loading patterns..."; std::cout << "Loading patterns...";
for (std::experimental::filesystem::directory_entry p : std::experimental::filesystem::directory_iterator("../assets/patterns/")) { for (std::experimental::filesystem::directory_entry p : std::experimental::filesystem::directory_iterator("../assets/patterns/")) {
pattern_list.push_back(p.path().generic_string()); // good lord c++
std::string s = p.path().generic_string();
const char* char_shit = new const char[s.size() + 1];
memcpy((void*)char_shit, s.c_str(), s.size()+1);
pattern_list.push_back(char_shit);
} }
std::cout << "Done" << std::endl; std::cout << "Done" << std::endl;
@ -20,124 +25,130 @@ pattern_info Decoder::decodePattern(std::string pattern) {
pattern_info info; pattern_info info;
//for (int i = 0; i < dimensions.x * dimensions.y; i++) { std::ifstream file(pattern);
// nodes[i] = 0;
//} if (!file.is_open()) {
std::cout << "unable to open file" << std::endl;
return info;
//std::ifstream file(filename); }
//if (!file.is_open()) { std::vector<std::vector<char>> grid;
// std::cout << "unable to open file" << std::endl; std::stringstream rle_stream;
// return info;
//} for (std::string line; std::getline(file, line); )
{
//for (std::string line; std::getline(file, line); ) // Grab the header comments
//{ if (line[0] == '#') {
// // Grab the header comments
// if (line[0] == '#') { std::string data = line.substr(3, line.size() - 3);
// std::string data = line.substr(3, line.size() - 3); switch (line[1]) {
// switch (line[1]) { case 'C': {
info.comments += data;
// case 'C': { break;
// info.comments += data; }
// break; case 'O': {
// } info.author += data;
// case 'O': { break;
// info.author += data; }
// break; case 'N': {
// } info.title += data;
// case 'N': { break;
// info.title += data; }
// break; default: {
// } std::cout << "Case : " << line[1] << " not supported" << std::endl;
// default: { }
// std::cout << "Case : " << line[1] << " not supported" << std::endl;
// } }
// } }
// }
// grab the dimensions
// // grab the dimensions else if (line[0] == 'x') {
// else if (line[0] == 'x') {
// Naively assume that it is in the exact form "x = <num>, y = <num>,"
// // Naively assume that it is in the exact form "x = <num>, y = <num>," std::stringstream ss(line);
// std::stringstream ss(line);
std::string temp;
// std::string temp; ss >> temp >> temp >> temp;
// ss >> temp >> temp >> temp; info.dimensions.x = std::stoi(temp.substr(0, temp.size() - 1));
// info.dimensions.x = std::stoi(temp.substr(0, temp.size() - 1));
ss >> temp >> temp >> temp;
// ss >> temp >> temp >> temp; info.dimensions.y = std::stoi(temp.substr(0, temp.size() - 1));
// info.dimensions.y = std::stoi(temp.substr(0, temp.size() - 1)); }
// }
// Decode the RLE
// // Decode the RLE else {
// else {
rle_stream << line;
// std::vector<std::vector<char>> grid; std::string token;
// std::stringstream ss(line); while (std::getline(rle_stream, token, '$')) {
// std::string token;
if (rle_stream.eof()) {
// while (std::getline(ss, token, '$')) {
if (token.back() != '!') {
// std::vector<char> char_line; rle_stream.seekg(-token.size(), std::ios::end);
// unsigned int token_pos = 0; break;
// std::string tmp; }
}
// while (token_pos < token.size()) {
std::vector<char> char_line;
// char status = -1; unsigned int token_pos = 0;
// if (token[token_pos] == 'b') std::string tmp;
// status = 0;
// else if (token[token_pos] == 'o') while (token_pos < token.size()) {
// status = 1;
// else if (token[token_pos] == '!') char status = -1;
// break; if (token[token_pos] == 'b')
// else status = 0;
// tmp += token[token_pos]; else if (token[token_pos] == 'o')
status = 1;
// token_pos++; else if (token[token_pos] == '!')
break;
// if (status >= 0) { else
// if (tmp.empty()) { tmp += token[token_pos];
// char_line.push_back(status);
// } token_pos++;
// else {
// int count = std::stoi(tmp); if (status >= 0) {
// for (int i = 0; i < count; i++) { if (tmp.empty()) {
// char_line.push_back(status); char_line.push_back(status);
// } }
// tmp.clear(); else {
// } int count = std::stoi(tmp);
// } for (int i = 0; i < count; i++) {
char_line.push_back(status);
// } }
tmp.clear();
// grid.push_back(char_line); }
// } }
// int y_mod = 200; }
// int x_mod = 200;
// for (int y = 0; y < grid.size(); y++) { char_line.resize(info.dimensions.x);
// for (int x = 0; x < grid.at(y).size(); x++) { grid.push_back(char_line);
// nodes[(y + y_mod) * dimensions.x + (x + x_mod)] = grid.at(y).at(x); }
// }
// } rle_stream.clear();
// } }
//} }
//std::cout << info.author << std::endl; info.dimensions = sf::Vector2i(grid.at(0).size(), grid.size());
//std::cout << info.title << std::endl; info.nodes = new char[info.dimensions.x * info.dimensions.y];
//std::cout << info.comments << std::endl;
for (int y = 0; y < grid.size(); y++) {
for (int x = 0; x < grid.at(y).size(); x++) {
info.nodes[y * info.dimensions.x + x] = grid.at(y).at(x);
}
}
file.close();
return info; return info;
} }
std::vector<std::string> Decoder::getPatternList() { std::vector<const char*> Decoder::getPatternList() {
return pattern_list; return pattern_list;

16
src/OpenCL.cpp
Unescape View File

@ -279,6 +279,22 @@ bool OpenCL::create_image_buffer(std::string buffer_name, sf::Vector2i size, sf:
return true; return true;
} }
bool OpenCL::map_buffer(std::string buffer_name, unsigned int size, void* data) {
data = clEnqueueMapBuffer(command_queue,
buffer_map.at(buffer_name),
true,
CL_MEM_READ_ONLY | CL_MEM_USE_HOST_PTR,
0,
size,0,nullptr,nullptr,&error
);
if (vr_assert(error, "clEnqueueMapBuffer"))
return -1;
return true;
}
int OpenCL::create_buffer(std::string buffer_name, cl_uint size, void* data) { int OpenCL::create_buffer(std::string buffer_name, cl_uint size, void* data) {
if (buffer_map.count(buffer_name) > 0) { if (buffer_map.count(buffer_name) > 0) {

182
src/main.cpp
Unescape View File

@ -53,141 +53,34 @@ void generate_nodes(sf::Uint8* nodes) {
} }
struct rle_info { void copy_pattern (sf::Uint8* nodes, sf::Vector2i dimensions, sf::Vector2u position, pattern_info pattern) {
std::string title; for (int x = 0; x < pattern.dimensions.x; x++) {
std::string author; for (int y = 0; y < pattern.dimensions.y; y++) {
std::string comments;
sf::Vector2i dimensions;
}; if (position.x + pattern.dimensions.x < dimensions.x ||
position.y + pattern.dimensions.y < dimensions.y ) {
rle_info load_rle(sf::Uint8* nodes, sf::Vector2i dimensions, std::string filename) { nodes[(y+position.y) * dimensions.x + (x+position.x)] = pattern.nodes[y * pattern.dimensions.x + x];
rle_info info;
for (int i = 0; i < dimensions.x * dimensions.y; i++) {
nodes[i] = 0;
}
std::ifstream file(filename);
if (!file.is_open()) {
std::cout << "unable to open file" << std::endl;
return info;
}
for (std::string line; std::getline(file, line); )
{
// Grab the header comments
if (line[0] == '#') {
std::string data = line.substr(3, line.size() - 3);
switch (line[1]) {
case 'C': {
info.comments += data;
break;
}
case 'O': {
info.author += data;
break;
}
case 'N': {
info.title += data;
break;
}
default : {
std::cout << "Case : " << line[1] << " not supported" << std::endl;
}
}
}
// grab the dimensions
else if (line[0] == 'x') {
// Naively assume that it is in the exact form "x = <num>, y = <num>,"
std::stringstream ss(line);
std::string temp;
ss >> temp >> temp >> temp;
info.dimensions.x = std::stoi(temp.substr(0, temp.size() - 1));
ss >> temp >> temp >> temp;
info.dimensions.y = std::stoi(temp.substr(0, temp.size() - 1));
}
// Decode the RLE
else {
std::vector<std::vector<char>> grid;
std::stringstream ss(line);
std::string token;
while (std::getline(ss, token, '$')) {
std::vector<char> char_line;
unsigned int token_pos = 0;
std::string tmp;
while (token_pos < token.size()) {
char status = -1;
if (token[token_pos] == 'b')
status = 0;
else if (token[token_pos] == 'o')
status = 1;
else if (token[token_pos] == '!')
break;
else
tmp += token[token_pos];
token_pos++;
if (status >= 0) {
if (tmp.empty()) {
char_line.push_back(status);
}
else {
int count = std::stoi(tmp);
for (int i = 0; i < count; i++) {
char_line.push_back(status);
}
tmp.clear();
}
}
}
grid.push_back(char_line);
} }
int y_mod = 200;
int x_mod = 200;
for (int y = 0; y < grid.size(); y++) {
for (int x = 0; x < grid.at(y).size(); x++) {
nodes[(y+y_mod) * dimensions.x + (x+x_mod)] = grid.at(y).at(x);
} }
} }
}
void clear_nodes(sf::Uint8 *nodes, sf::Vector2i dimensions) {
for (int i = 0; i < dimensions.x * dimensions.y; i++) {
nodes[i] = 0;
} }
}
std::cout << info.author << std::endl;
std::cout << info.title << std::endl;
std::cout << info.comments << std::endl;
return info;
} }
int main() { int main() {
srand(time(NULL)); srand(time(NULL));
Decoder d; Decoder d;
std::vector<const char*> pattern_list = d.getPatternList();
sf::RenderWindow window(sf::VideoMode(WINDOW_X, WINDOW_Y), "conways-game-of-life-opencl"); sf::RenderWindow window(sf::VideoMode(WINDOW_X, WINDOW_Y), "conways-game-of-life-opencl");
int simulation_speed = 100; int simulation_speed = 100;
@ -231,7 +124,6 @@ int main() {
sf::Clock sf_delta_clock; sf::Clock sf_delta_clock;
fps_counter render_fps; fps_counter render_fps;
fps_counter physic_fps;
int c = 0; int c = 0;
@ -274,18 +166,13 @@ int main() {
while (accumulator_time >= physic_step) { // While the frame has sim time, update while (accumulator_time >= physic_step) { // While the frame has sim time, update
accumulator_time -= physic_step; accumulator_time -= physic_step;
physic_time += physic_step; physic_time += physic_step;
//physic_fps.frame(accumulator_time);
} }
cl.run_kernel("conways", image_resolution);
ImGui::SFML::Update(window, sf_delta_clock.restart()); ImGui::SFML::Update(window, sf_delta_clock.restart());
render_fps.frame(delta_time); render_fps.frame(delta_time);
window.clear(sf::Color::White);
cl.draw(&window); window.clear(sf::Color::White);
ImGui::Begin("Sim"); ImGui::Begin("Sim");
@ -293,36 +180,57 @@ int main() {
if (ImGui::SliderInt("Simulation Speed", &simulation_speed, 30, 500)) { if (ImGui::SliderInt("Simulation Speed", &simulation_speed, 30, 500)) {
window.setFramerateLimit(simulation_speed); window.setFramerateLimit(simulation_speed);
} }
if (ImGui::Button("One shot")) {
if (ImGui::Button("Rerun")) { std::cout << "sim" << std::endl;
generate_nodes(nodes);
/*std::cout << buffer_flip << std::endl;
cl.map_buffer("buffer_flip", sizeof(char), &buffer_flip);*/
}
cl.run_kernel("conways", image_resolution);
cl.draw(&window);
if (buffer_flip == 1)
buffer_flip = 0;
else
buffer_flip = 1;
ImGui::Columns(2);
if (ImGui::Button("Load Pattern")) {
clear_nodes(nodes, sf::Vector2i(WINDOW_X, WINDOW_Y));
pattern_info p = d.decodePattern(pattern_list.at(c));
copy_pattern(nodes, sf::Vector2i(WINDOW_X, WINDOW_Y), sf::Vector2u(100, 300), p);
cl.create_buffer("first_node_buffer", WINDOW_X * WINDOW_Y, (void*)nodes, CL_MEM_READ_WRITE | CL_MEM_COPY_HOST_PTR); cl.create_buffer("first_node_buffer", WINDOW_X * WINDOW_Y, (void*)nodes, CL_MEM_READ_WRITE | CL_MEM_COPY_HOST_PTR);
cl.create_buffer("second_node_buffer", WINDOW_X * WINDOW_Y, (void*)nodes, CL_MEM_READ_WRITE | CL_MEM_COPY_HOST_PTR); cl.create_buffer("second_node_buffer", WINDOW_X * WINDOW_Y, (void*)nodes, CL_MEM_READ_WRITE | CL_MEM_COPY_HOST_PTR);
cl.set_kernel_arg("conways", 2, "first_node_buffer"); cl.set_kernel_arg("conways", 2, "first_node_buffer");
cl.set_kernel_arg("conways", 3, "second_node_buffer"); cl.set_kernel_arg("conways", 3, "second_node_buffer");
} }
const char* l[] = { "Apple", "Banana", "Cherry", "Kiwi", "Mango", "Orange", "Pineapple", "Strawberry", "Watermelon" }; if (ImGui::ListBox("", &c, pattern_list.data(), pattern_list.size(), 30)) {
if(ImGui::ListBox("asdf", &c, l, 9)) {
} }
ImGui::NextColumn();
if (ImGui::Button("Rerun")) {
generate_nodes(nodes);
cl.create_buffer("first_node_buffer", WINDOW_X * WINDOW_Y, (void*)nodes, CL_MEM_READ_WRITE | CL_MEM_COPY_HOST_PTR);
cl.create_buffer("second_node_buffer", WINDOW_X * WINDOW_Y, (void*)nodes, CL_MEM_READ_WRITE | CL_MEM_COPY_HOST_PTR);
cl.set_kernel_arg("conways", 2, "first_node_buffer");
cl.set_kernel_arg("conways", 3, "second_node_buffer");
}
ImGui::End(); ImGui::End();
render_fps.draw(); render_fps.draw();
physic_fps.draw();
ImGui::Render(); ImGui::Render();
if (buffer_flip == 1)
buffer_flip = 0;
else
buffer_flip = 1;
// ImGui screws stuff up after the render, rendering a drawable resets it // ImGui screws stuff up after the render, rendering a drawable resets it
window.draw(sf::CircleShape(0)); window.draw(sf::CircleShape(0));

Write Preview
Loading…
Cancel
Save