| # | Line 295 | Line 295 | ray_presult( /* check for a completed ray */ | |
|---|---|---|
| 295 | /* check queued results first */ | |
| 296 | if (r_recv_first < r_recv_next) { | |
| 297 | *r = r_queue[r_recv_first++]; | |
| 298 | + | /* make sure send queue has room */ |
| 299 | + | if (sendq_full() && ray_pflush() <= 0) |
| 300 | + | return(-1); |
| 301 | return(1); | |
| 302 | } | |
| 303 | n = ray_pnprocs - ray_pnidle; /* pending before flush? */ | |
| – | Removed lines |
| + | Added lines |
| < | Changed lines |
| > | Changed lines |