| # | Line 520 | Line 520 | ray_pclose( /* close one or more child processes */ | |
|---|---|---|
| 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 */ | |
| – | Removed lines |
| + | Added lines |
| < | Changed lines |
| > | Changed lines |