- asort_radix(w->ctx, w->in, w->out, w->num_elts, w->shift, w->swap_output);
- DBG("Thread %d: Finishing done", thr->id);
+ asort_radix(w->ctx, w->array, w->buffer, w->num_elts, w->shift, w->swap_output);
+ if (thr)
+ DBG("Thread %d: Finishing done", thr->id);
+}
+
+static void
+rs_wait_small(struct asort_context *ctx)
+{
+ struct rs_work *w;
+
+ while (w = (struct rs_work *) work_wait(ctx->rs_work_queue))
+ {
+ DBG("Reaping small chunk of %d items", w->num_elts);
+ ep_free(ctx->eltpool, w);
+ }