510 |
|
static int inclose = 0; |
511 |
|
RAY res; |
512 |
|
int i, status = 0; |
513 |
+ |
/* check no child / in child */ |
514 |
+ |
if (ray_pnprocs <= 0) |
515 |
+ |
return; |
516 |
|
/* check recursion */ |
517 |
|
if (inclose) |
518 |
|
return; |
519 |
|
inclose++; |
517 |
– |
/* check no child / in child */ |
518 |
– |
if (ray_pnprocs <= 0) |
519 |
– |
return; |
520 |
|
/* check argument */ |
521 |
|
if ((nsub <= 0) | (nsub > ray_pnprocs)) |
522 |
|
nsub = ray_pnprocs; |
523 |
< |
/* clear our ray queue */ |
523 |
> |
i = 0; /* clear our ray queue */ |
524 |
|
while (ray_presult(&res,0) > 0) |
525 |
< |
; |
525 |
> |
++i; |
526 |
> |
if (i) { |
527 |
> |
sprintf(errmsg, "dropped %d ray results in ray_pclose()", i); |
528 |
> |
error(WARNING, errmsg); |
529 |
> |
} |
530 |
|
r_send_next = 0; /* hard reset in case of error */ |
531 |
|
r_recv_first = r_recv_next = RAYQLEN; |
532 |
|
/* close send pipes */ |