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 */ |