-
Notifications
You must be signed in to change notification settings - Fork 143
/
13compute_shader_nbody.cpp
486 lines (395 loc) · 15.4 KB
/
13compute_shader_nbody.cpp
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
460
461
462
463
464
465
466
467
468
469
470
471
472
473
474
475
476
477
478
479
480
481
482
483
484
485
486
/* OpenGL example code - Compute Shader N-body
*
* N-body simulation with compute shaders.
*
* Autor: Jakob Progsch
*/
#include <GLXW/glxw.h>
#include <GLFW/glfw3.h>
//glm is used to create perspective and transform matrices
#define GLM_SWIZZLE
#include <glm/glm.hpp>
#include <glm/gtc/matrix_transform.hpp>
#include <glm/gtc/type_ptr.hpp>
#include <glm/gtc/random.hpp>
#include <iostream>
#include <string>
#include <vector>
#include <cstdlib>
#include <cmath>
// helper to check and display for shader compiler errors
bool check_shader_compile_status(GLuint obj) {
GLint status;
glGetShaderiv(obj, GL_COMPILE_STATUS, &status);
if(status == GL_FALSE) {
GLint length;
glGetShaderiv(obj, GL_INFO_LOG_LENGTH, &length);
std::vector<char> log(length);
glGetShaderInfoLog(obj, length, &length, &log[0]);
std::cerr << &log[0];
return false;
}
return true;
}
// helper to check and display for shader linker error
bool check_program_link_status(GLuint obj) {
GLint status;
glGetProgramiv(obj, GL_LINK_STATUS, &status);
if(status == GL_FALSE) {
GLint length;
glGetProgramiv(obj, GL_INFO_LOG_LENGTH, &length);
std::vector<char> log(length);
glGetProgramInfoLog(obj, length, &length, &log[0]);
std::cerr << &log[0];
return false;
}
return true;
}
int main() {
int width = 640;
int height = 480;
if(glfwInit() == GL_FALSE) {
std::cerr << "failed to init GLFW" << std::endl;
return 1;
}
// select opengl version
glfwWindowHint(GLFW_OPENGL_PROFILE, GLFW_OPENGL_CORE_PROFILE);
glfwWindowHint(GLFW_CONTEXT_VERSION_MAJOR, 4);
glfwWindowHint(GLFW_CONTEXT_VERSION_MINOR, 3);
// create a window
GLFWwindow *window;
if((window = glfwCreateWindow(width, height, "13compute_shader_nbody", 0, 0)) == 0) {
std::cerr << "failed to open window" << std::endl;
glfwTerminate();
return 1;
}
glfwMakeContextCurrent(window);
if(glxwInit()) {
std::cerr << "failed to init GL3W" << std::endl;
glfwDestroyWindow(window);
glfwTerminate();
return 1;
}
// shader source code
// the vertex shader simply passes through data
std::string vertex_source =
"#version 430\n"
"layout(location = 0) in vec4 vposition;\n"
"void main() {\n"
" gl_Position = vposition;\n"
"}\n";
// the geometry shader creates the billboard quads
std::string geometry_source =
"#version 430\n"
"layout(location = 0) uniform mat4 View;\n"
"layout(location = 1) uniform mat4 Projection;\n"
"layout (points) in;\n"
"layout (triangle_strip, max_vertices = 4) out;\n"
"out vec2 txcoord;\n"
"void main() {\n"
" vec4 pos = View*gl_in[0].gl_Position;\n"
" txcoord = vec2(-1,-1);\n"
" gl_Position = Projection*(pos+0.2*vec4(txcoord,0,0));\n"
" EmitVertex();\n"
" txcoord = vec2( 1,-1);\n"
" gl_Position = Projection*(pos+0.2*vec4(txcoord,0,0));\n"
" EmitVertex();\n"
" txcoord = vec2(-1, 1);\n"
" gl_Position = Projection*(pos+0.2*vec4(txcoord,0,0));\n"
" EmitVertex();\n"
" txcoord = vec2( 1, 1);\n"
" gl_Position = Projection*(pos+0.2*vec4(txcoord,0,0));\n"
" EmitVertex();\n"
"}\n";
// the fragment shader creates a bell like radial color distribution
std::string fragment_source =
"#version 330\n"
"in vec2 txcoord;\n"
"layout(location = 0) out vec4 FragColor;\n"
"void main() {\n"
" float s = (1/(1+15.*dot(txcoord, txcoord))-1/16.);\n"
" FragColor = s*vec4(0.3,0.3,1.0,1);\n"
"}\n";
// program and shader handles
GLuint shader_program, vertex_shader, geometry_shader, fragment_shader;
// we need these to properly pass the strings
const char *source;
int length;
// create and compiler vertex shader
vertex_shader = glCreateShader(GL_VERTEX_SHADER);
source = vertex_source.c_str();
length = vertex_source.size();
glShaderSource(vertex_shader, 1, &source, &length);
glCompileShader(vertex_shader);
if(!check_shader_compile_status(vertex_shader)) {
glfwDestroyWindow(window);
glfwTerminate();
return 1;
}
// create and compiler geometry shader
geometry_shader = glCreateShader(GL_GEOMETRY_SHADER);
source = geometry_source.c_str();
length = geometry_source.size();
glShaderSource(geometry_shader, 1, &source, &length);
glCompileShader(geometry_shader);
if(!check_shader_compile_status(geometry_shader)) {
glfwDestroyWindow(window);
glfwTerminate();
return 1;
}
// create and compiler fragment shader
fragment_shader = glCreateShader(GL_FRAGMENT_SHADER);
source = fragment_source.c_str();
length = fragment_source.size();
glShaderSource(fragment_shader, 1, &source, &length);
glCompileShader(fragment_shader);
if(!check_shader_compile_status(fragment_shader)) {
glfwDestroyWindow(window);
glfwTerminate();
return 1;
}
// create program
shader_program = glCreateProgram();
// attach shaders
glAttachShader(shader_program, vertex_shader);
glAttachShader(shader_program, geometry_shader);
glAttachShader(shader_program, fragment_shader);
// link the program and check for errors
glLinkProgram(shader_program);
check_program_link_status(shader_program);
// straight forward implementation of the nbody kernel
std::string acceleration_source =
"#version 430\n"
"layout(local_size_x=256) in;\n"
"layout(location = 0) uniform float dt;\n"
"layout(std430, binding=0) buffer pblock { vec4 positions[]; };\n"
"layout(std430, binding=1) buffer vblock { vec4 velocities[]; };\n"
"void main() {\n"
" int N = int(gl_NumWorkGroups.x*gl_WorkGroupSize.x);\n"
" int index = int(gl_GlobalInvocationID);\n"
" vec3 position = positions[index].xyz;\n"
" vec3 velocity = velocities[index].xyz;\n"
" vec3 acceleration = vec3(0,0,0);\n"
" for(int i = 0;i<N;++i) {\n"
" vec3 other = positions[i].xyz;\n"
" vec3 diff = position - other;\n"
" float invdist = 1.0/(length(diff)+0.001);\n"
" acceleration -= diff*0.1*invdist*invdist*invdist;\n"
" }\n"
" velocities[index] = vec4(velocity+dt*acceleration,0);\n"
"}\n";
// program and shader handles
GLuint acceleration_program, acceleration_shader;
// create and compiler vertex shader
acceleration_shader = glCreateShader(GL_COMPUTE_SHADER);
source = acceleration_source.c_str();
length = acceleration_source.size();
glShaderSource(acceleration_shader, 1, &source, &length);
glCompileShader(acceleration_shader);
if(!check_shader_compile_status(acceleration_shader)) {
glfwDestroyWindow(window);
glfwTerminate();
return 1;
}
// create program
acceleration_program = glCreateProgram();
// attach shaders
glAttachShader(acceleration_program, acceleration_shader);
// link the program and check for errors
glLinkProgram(acceleration_program);
check_program_link_status(acceleration_program);
// tiled version of the nbody shader that makes use of shared memory
// to reduce global memory transactions
std::string tiled_acceleration_source =
"#version 430\n"
"layout(local_size_x=256) in;\n"
"layout(location = 0) uniform float dt;\n"
"layout(std430, binding=0) buffer pblock { vec4 positions[]; };\n"
"layout(std430, binding=1) buffer vblock { vec4 velocities[]; };\n"
"shared vec4 tmp[gl_WorkGroupSize.x];\n"
"void main() {\n"
" int N = int(gl_NumWorkGroups.x*gl_WorkGroupSize.x);\n"
" int index = int(gl_GlobalInvocationID);\n"
" vec3 position = positions[index].xyz;\n"
" vec3 velocity = velocities[index].xyz;\n"
" vec3 acceleration = vec3(0,0,0);\n"
" for(int tile = 0;tile<N;tile+=int(gl_WorkGroupSize.x)) {\n"
" tmp[gl_LocalInvocationIndex] = positions[tile + int(gl_LocalInvocationIndex)];\n"
" groupMemoryBarrier();\n"
" barrier();\n"
" for(int i = 0;i<gl_WorkGroupSize.x;++i) {\n"
" vec3 other = tmp[i].xyz;\n"
" vec3 diff = position - other;\n"
" float invdist = 1.0/(length(diff)+0.001);\n"
" acceleration -= diff*0.1*invdist*invdist*invdist;\n"
" }\n"
" groupMemoryBarrier();\n"
" barrier();\n"
" }\n"
" velocities[index] = vec4(velocity+dt*acceleration,0);\n"
"}\n";
// program and shader handles
GLuint tiled_acceleration_program, tiled_acceleration_shader;
// create and compiler vertex shader
tiled_acceleration_shader = glCreateShader(GL_COMPUTE_SHADER);
source = tiled_acceleration_source.c_str();
length = tiled_acceleration_source.size();
glShaderSource(tiled_acceleration_shader, 1, &source, &length);
glCompileShader(tiled_acceleration_shader);
if(!check_shader_compile_status(tiled_acceleration_shader)) {
glfwDestroyWindow(window);
glfwTerminate();
return 1;
}
// create program
tiled_acceleration_program = glCreateProgram();
// attach shaders
glAttachShader(tiled_acceleration_program, tiled_acceleration_shader);
// link the program and check for errors
glLinkProgram(tiled_acceleration_program);
check_program_link_status(tiled_acceleration_program);
// the integrate shader does the second part of the euler integration
std::string integrate_source =
"#version 430\n"
"layout(local_size_x=256) in;\n"
"layout(location = 0) uniform float dt;\n"
"layout(std430, binding=0) buffer pblock { vec4 positions[]; };\n"
"layout(std430, binding=1) buffer vblock { vec4 velocities[]; };\n"
"void main() {\n"
" int index = int(gl_GlobalInvocationID);\n"
" vec4 position = positions[index];\n"
" vec4 velocity = velocities[index];\n"
" position.xyz += dt*velocity.xyz;\n"
" positions[index] = position;\n"
"}\n";
// program and shader handles
GLuint integrate_program, integrate_shader;
// create and compiler vertex shader
integrate_shader = glCreateShader(GL_COMPUTE_SHADER);
source = integrate_source.c_str();
length = integrate_source.size();
glShaderSource(integrate_shader, 1, &source, &length);
glCompileShader(integrate_shader);
if(!check_shader_compile_status(integrate_shader)) {
glfwDestroyWindow(window);
glfwTerminate();
return 1;
}
// create program
integrate_program = glCreateProgram();
// attach shaders
glAttachShader(integrate_program, integrate_shader);
// link the program and check for errors
glLinkProgram(integrate_program);
check_program_link_status(integrate_program);
const int particles = 8*1024;
// randomly place particles in a cube
std::vector<glm::vec4> positionData(particles);
std::vector<glm::vec4> velocityData(particles);
for(int i = 0;i<particles;++i) {
// initial position
positionData[i] = glm::gaussRand(glm::vec4(0,0,0,1), glm::vec4(1, 0.2, 1, 0));
velocityData[i] = glm::vec4(0);
}
// generate positions_vbos and vaos
GLuint vao, positions_vbo, velocities_vbo;
glGenVertexArrays(1, &vao);
glBindVertexArray(vao);
glGenBuffers(1, &positions_vbo);
glGenBuffers(1, &velocities_vbo);
glBindBuffer(GL_SHADER_STORAGE_BUFFER, velocities_vbo);
glBufferData(GL_SHADER_STORAGE_BUFFER, sizeof(glm::vec4)*particles, &velocityData[0], GL_STATIC_DRAW);
glBindBuffer(GL_ARRAY_BUFFER, positions_vbo);
// fill with initial data
glBufferData(GL_ARRAY_BUFFER, sizeof(glm::vec4)*particles, &positionData[0], GL_STATIC_DRAW);
// set up generic attrib pointers
glEnableVertexAttribArray(0);
glVertexAttribPointer(0, 4, GL_FLOAT, GL_FALSE, 4*sizeof(GLfloat), (char*)0 + 0*sizeof(GLfloat));
const GLuint ssbos[] = {positions_vbo, velocities_vbo};
glBindBuffersBase(GL_SHADER_STORAGE_BUFFER, 0, 2, ssbos);
// physical parameters
float dt = 1.0f/60.0f;
// setup uniforms
glUseProgram(tiled_acceleration_program);
glUniform1f(0, dt);
glUseProgram(acceleration_program);
glUniform1f(0, dt);
glUseProgram(integrate_program);
glUniform1f(0, dt);
// we are blending so no depth testing
glDisable(GL_DEPTH_TEST);
// enable blending
glEnable(GL_BLEND);
// and set the blend function to result = 1*source + 1*destination
glBlendFunc(GL_ONE, GL_ONE);
GLuint query;
glGenQueries(1, &query);
bool tiled = false;
bool space_down = false;
while(!glfwWindowShouldClose(window)) {
glfwPollEvents();
// switch force calculation method
if(glfwGetKey(window, GLFW_KEY_SPACE) && !space_down) {
tiled = !tiled;
}
space_down = glfwGetKey(window, GLFW_KEY_SPACE);
glBeginQuery(GL_TIME_ELAPSED, query);
if(tiled) {
glUseProgram(tiled_acceleration_program);
glDispatchCompute(particles/256, 1, 1);
} else {
glUseProgram(acceleration_program);
glDispatchCompute(particles/256, 1, 1);
}
glEndQuery(GL_TIME_ELAPSED);
glUseProgram(integrate_program);
glDispatchCompute(particles/256, 1, 1);
// clear first
glClear(GL_COLOR_BUFFER_BIT | GL_DEPTH_BUFFER_BIT);
// use the shader program
glUseProgram(shader_program);
// calculate ViewProjection matrix
glm::mat4 Projection = glm::perspective(90.0f, 4.0f / 3.0f, 0.1f, 100.f);
// translate the world/view position
glm::mat4 View = glm::translate(glm::mat4(1.0f), glm::vec3(0.0f, 0.0f, -30.0f));
// tilt the camera
View = glm::rotate(View, 30.0f, glm::vec3(1.0f, 0.0f, 0.0f));
// set the uniforms
glUniformMatrix4fv(0, 1, GL_FALSE, glm::value_ptr(View));
glUniformMatrix4fv(1, 1, GL_FALSE, glm::value_ptr(Projection));
// bind the current vao
glBindVertexArray(vao);
// draw
glDrawArrays(GL_POINTS, 0, particles);
// check for errors
GLenum error = glGetError();
if(error != GL_NO_ERROR) {
std::cerr << error << std::endl;
break;
}
// finally swap buffers
glfwSwapBuffers(window);
{
GLuint64 result;
glGetQueryObjectui64v(query, GL_QUERY_RESULT, &result);
std::cout << result*1.e-6 << " ms/frame" << std::endl;
}
}
// delete the created objects
glDeleteVertexArrays(1, &vao);
glDeleteBuffers(1, &positions_vbo);
glDeleteBuffers(1, &velocities_vbo);
glDetachShader(shader_program, vertex_shader);
glDetachShader(shader_program, geometry_shader);
glDetachShader(shader_program, fragment_shader);
glDeleteShader(vertex_shader);
glDeleteShader(geometry_shader);
glDeleteShader(fragment_shader);
glDeleteProgram(shader_program);
glDetachShader(acceleration_program, acceleration_shader);
glDeleteShader(acceleration_shader);
glDeleteProgram(acceleration_program);
glfwDestroyWindow(window);
glfwTerminate();
return 0;
}