| 147 |
|
#include "selcall.h" |
| 148 |
|
|
| 149 |
|
#ifndef RAYQLEN |
| 150 |
< |
#define RAYQLEN 96 /* # rays to send at once */ |
| 150 |
> |
#define RAYQLEN 24 /* # rays to send at once */ |
| 151 |
|
#endif |
| 152 |
|
|
| 153 |
|
#ifndef MAX_RPROCS |
| 162 |
|
|
| 163 |
|
int ray_pnprocs = 0; /* number of child processes */ |
| 164 |
|
int ray_pnidle = 0; /* number of idle children */ |
| 165 |
+ |
int ray_pnbatch = 0; /* throughput over responsiveness? */ |
| 166 |
|
|
| 167 |
|
static struct child_proc { |
| 168 |
|
RT_PID pid; /* child process id */ |
| 213 |
|
for (i = ray_pnprocs; nc && i--; ) { |
| 214 |
|
if (r_proc[i].npending > 0) |
| 215 |
|
continue; /* child looks busy */ |
| 216 |
< |
n = (r_send_next - sfirst)/nc--; |
| 216 |
> |
n = r_send_next - sfirst; |
| 217 |
> |
if (ray_pnbatch) |
| 218 |
> |
nc--; /* maximize bundling for batch calc */ |
| 219 |
> |
else |
| 220 |
> |
n /= nc--; /* distribute work for interactivity */ |
| 221 |
|
if (!n) |
| 222 |
|
continue; |
| 223 |
|
/* smuggle set size in crtype */ |