aboutsummaryrefslogtreecommitdiffstats
path: root/gpu/dgl.c
diff options
context:
space:
mode:
Diffstat (limited to 'gpu/dgl.c')
-rw-r--r--gpu/dgl.c20
1 files changed, 10 insertions, 10 deletions
diff --git a/gpu/dgl.c b/gpu/dgl.c
index dc68ead..42a3ae2 100644
--- a/gpu/dgl.c
+++ b/gpu/dgl.c
@@ -177,7 +177,7 @@ void* rt_thread(void* _ctx)
177 xfprintf(stdout, "ikglp od = %d\n", ctx->ikglp); 177 xfprintf(stdout, "ikglp od = %d\n", ctx->ikglp);
178 } 178 }
179 179
180 180
181 for (i = 0; i < NUM_SEMS; i++) { 181 for (i = 0; i < NUM_SEMS; i++) {
182 if(!USE_PRIOQ) { 182 if(!USE_PRIOQ) {
183 ctx->od[i] = open_fifo_sem(ctx->fd, i+1); 183 ctx->od[i] = open_fifo_sem(ctx->fd, i+1);
@@ -208,29 +208,29 @@ void* rt_thread(void* _ctx)
208 int last = (first + NEST_DEPTH - 1 >= NUM_SEMS) ? NUM_SEMS - 1 : first + NEST_DEPTH - 1; 208 int last = (first + NEST_DEPTH - 1 >= NUM_SEMS) ? NUM_SEMS - 1 : first + NEST_DEPTH - 1;
209 int dgl_size = last - first + 1; 209 int dgl_size = last - first + 1;
210 int dgl[dgl_size]; 210 int dgl[dgl_size];
211 211
212 // construct the DGL 212 // construct the DGL
213 for(i = first; i <= last; ++i) { 213 for(i = first; i <= last; ++i) {
214 dgl[i-first] = ctx->od[i]; 214 dgl[i-first] = ctx->od[i];
215 } 215 }
216 216
217 217
218 if(NUM_REPLICAS) { 218 if(NUM_REPLICAS) {
219 replica = litmus_lock(ctx->ikglp); 219 replica = litmus_lock(ctx->ikglp);
220 xfprintf(stdout, "[%d] got ikglp replica %d.\n", ctx->id, replica); 220 xfprintf(stdout, "[%d] got ikglp replica %d.\n", ctx->id, replica);
221 } 221 }
222 222
223 223
224 litmus_dgl_lock(dgl, dgl_size); 224 litmus_dgl_lock(dgl, dgl_size);
225 xfprintf(stdout, "[%d] acquired dgl.\n", ctx->id); 225 xfprintf(stdout, "[%d] acquired dgl.\n", ctx->id);
226 226
227 do_exit = job(ctx); 227 do_exit = job(ctx);
228 228
229 229
230 xfprintf(stdout, "[%d] unlocking dgl.\n", ctx->id); 230 xfprintf(stdout, "[%d] unlocking dgl.\n", ctx->id);
231 litmus_dgl_unlock(dgl, dgl_size); 231 litmus_dgl_unlock(dgl, dgl_size);
232 232
233 if(NUM_REPLICAS) { 233 if(NUM_REPLICAS) {
234 xfprintf(stdout, "[%d]: freeing ikglp replica %d.\n", ctx->id, replica); 234 xfprintf(stdout, "[%d]: freeing ikglp replica %d.\n", ctx->id, replica);
235 litmus_unlock(ctx->ikglp); 235 litmus_unlock(ctx->ikglp);
236 } 236 }
@@ -249,7 +249,7 @@ void* rt_thread(void* _ctx)
249 return NULL; 249 return NULL;
250} 250}
251 251
252void dirty_kb(int kb) 252void dirty_kb(int kb)
253{ 253{
254 int32_t one_kb[256]; 254 int32_t one_kb[256];
255 int32_t sum = 0; 255 int32_t sum = 0;