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