diff options
Diffstat (limited to 'gpu/dgl.c')
-rw-r--r-- | gpu/dgl.c | 20 |
1 files changed, 10 insertions, 10 deletions
@@ -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 | ||
252 | void dirty_kb(int kb) | 252 | void 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; |