Lines Matching refs:amt
92 ssize_t amt = TEMP_FAILURE_RETRY( in read() local
94 if (amt < 0) { in read()
101 } else if (amt == 0) { in read()
105 mBuffer->wp()->move(amt); in read()
128 ssize_t amt = in readFully() local
130 if (amt < 0) { in readFully()
133 } else if (amt == 0) { in readFully()
138 mBuffer->wp()->move(amt); in readFully()
209 ssize_t amt; in readProcessedDataInStream() local
211 amt = TEMP_FAILURE_RETRY(::read(fd, cirBuf + rpos, BUFFER_SIZE - rpos)); in readProcessedDataInStream()
213 amt = TEMP_FAILURE_RETRY(::read(fd, cirBuf + rpos, wpos - rpos)); in readProcessedDataInStream()
215 if (amt < 0) { in readProcessedDataInStream()
220 } else if (amt == 0) { in readProcessedDataInStream()
224 rpos += amt; in readProcessedDataInStream()
225 cirSize += amt; in readProcessedDataInStream()
231 ssize_t amt; in readProcessedDataInStream() local
233 amt = TEMP_FAILURE_RETRY(::write(toFd.get(), cirBuf + wpos, rpos - wpos)); in readProcessedDataInStream()
235 amt = TEMP_FAILURE_RETRY(::write(toFd.get(), cirBuf + wpos, BUFFER_SIZE - wpos)); in readProcessedDataInStream()
237 if (amt < 0) { in readProcessedDataInStream()
243 wpos += amt; in readProcessedDataInStream()
244 cirSize -= amt; in readProcessedDataInStream()
264 ssize_t amt = TEMP_FAILURE_RETRY( in readProcessedDataInStream() local
266 if (amt < 0) { in readProcessedDataInStream()
271 } else if (amt == 0) { in readProcessedDataInStream()
275 mBuffer->wp()->move(amt); in readProcessedDataInStream()