| 59 |
|
rtargv[rtargc++] = "-I-"; |
| 60 |
|
rtargv[rtargc++] = "-h-"; |
| 61 |
|
rtargv[rtargc++] = "-ld-"; |
| 62 |
+ |
rtargv[rtargc++] = "-co-"; |
| 63 |
|
sprintf(buf1, "%d", RPACKSIZ); |
| 64 |
|
rtargv[rtargc++] = "-x"; rtargv[rtargc++] = buf1; |
| 65 |
|
rtargv[rtargc++] = "-y"; rtargv[rtargc++] = "0"; |
| 114 |
|
if (pqlen[i] == pqlen[pn]) |
| 115 |
|
cnt++; |
| 116 |
|
/* break ties fairly */ |
| 117 |
< |
if ((cnt = random() % cnt)) |
| 117 |
> |
if ((cnt = irandom(cnt))) |
| 118 |
|
for (i = pn; i < nprocs; i++) |
| 119 |
|
if (pqlen[i] == pqlen[pn] && !cnt--) |
| 120 |
|
return(i); |
| 147 |
|
packrays(rtbuf, p); |
| 148 |
|
if ((n = p->nr) < RPACKSIZ) /* add flush block? */ |
| 149 |
|
memset((char *)(rtbuf+6*n++), '\0', 6*sizeof(float)); |
| 150 |
< |
if (writebuf(rtpd[pn].w, (char *)rtbuf, 6*sizeof(float)*n) < 0) |
| 150 |
> |
if (writebuf(rtpd[pn].w, rtbuf, 6*sizeof(float)*n) < 0) |
| 151 |
|
error(SYSTEM, "write error in queue_packet"); |
| 152 |
|
p->next = NULL; |
| 153 |
|
if (!pqlen[pn]++) /* add it to the end of the queue */ |
| 282 |
|
if (rpl->nr < RPACKSIZ) |
| 283 |
|
nr++; /* add flush block */ |
| 284 |
|
} |
| 285 |
< |
n = readbuf(rtpd[i].r, (char *)rtbuf, |
| 285 |
< |
4*sizeof(float)*nr); |
| 285 |
> |
n = readbuf(rtpd[i].r, rtbuf, 4*sizeof(float)*nr); |
| 286 |
|
if (n < 0) |
| 287 |
|
error(SYSTEM, "read failure in flush_queue"); |
| 288 |
|
bp = rtbuf; /* process packets */ |