Home | History | Annotate | Download | only in unit

Lines Matching defs:elems

21 init_elems_simple(elem_t *elems, int nelems, int thread) {
23 elems[i].thread = thread;
24 elems[i].idx = i;
25 ql_elm_new(&elems[i], link);
43 elem_t elems[NELEMS];
56 init_elems_simple(elems, NELEMS, 0);
58 ql_tail_insert(&list, &elems[i], link);
66 init_elems_simple(elems, NELEMS, 0);
68 elem_mpsc_queue_push(&queue, &elems[i]);
76 init_elems_simple(elems, NELEMS, 0);
78 ql_tail_insert(&list, &elems[i], link);
81 elem_mpsc_queue_push(&queue, &elems[i]);
100 elem_t elems[NELEMS];
101 init_elems_simple(elems, NELEMS, 0);
110 elem_mpsc_queue_push(&queue, &elems[next_idx]);
115 ql_tail_insert(&list, &elems[next_idx], link);
125 ql_tail_insert(&list, &elems[next_idx], link);
131 expect_d_eq(NELEMS, next_idx, "Miscomputed number of elems to push.");
141 elem_t elems[NELEMS];
142 init_elems_simple(elems, NELEMS, 0);
153 elem_mpsc_queue_push(&queue, &elems[next_idx]);
158 ql_tail_insert(&push_list, &elems[next_idx], link);
166 ql_tail_insert(&push_list, &elems[next_idx], link);
172 elem_mpsc_queue_push(&queue, &elems[next_idx]);
187 elem_t *elems;
209 ql_tail_insert(&list, &arg->elems[next_idx], link);
216 elem_mpsc_queue_push(arg->queue, &arg->elems[next_idx]);
262 elem_t *elems = calloc(NPUSHERS * NELEMS_PER_PUSHER, sizeof(elem_t));
263 elem_t *elem_iter = elems;
267 pusher_arg[i].elems = elem_iter;
293 free(elems);