Lines Matching refs:amt
84 ssize_t amt = TEMP_FAILURE_RETRY( in read() local
86 if (amt < 0) { in read()
93 } else if (amt == 0) { in read()
97 mBuffer->wp()->move(amt); in read()
120 ssize_t amt = in readFully() local
122 if (amt < 0) { in readFully()
125 } else if (amt == 0) { in readFully()
130 mBuffer->wp()->move(amt); in readFully()
201 ssize_t amt; in readProcessedDataInStream() local
203 amt = TEMP_FAILURE_RETRY(::read(fd, cirBuf + rpos, BUFFER_SIZE - rpos)); in readProcessedDataInStream()
205 amt = TEMP_FAILURE_RETRY(::read(fd, cirBuf + rpos, wpos - rpos)); in readProcessedDataInStream()
207 if (amt < 0) { in readProcessedDataInStream()
212 } else if (amt == 0) { in readProcessedDataInStream()
216 rpos += amt; in readProcessedDataInStream()
217 cirSize += amt; in readProcessedDataInStream()
223 ssize_t amt; in readProcessedDataInStream() local
225 amt = TEMP_FAILURE_RETRY(::write(toFd.get(), cirBuf + wpos, rpos - wpos)); in readProcessedDataInStream()
227 amt = TEMP_FAILURE_RETRY(::write(toFd.get(), cirBuf + wpos, BUFFER_SIZE - wpos)); in readProcessedDataInStream()
229 if (amt < 0) { in readProcessedDataInStream()
235 wpos += amt; in readProcessedDataInStream()
236 cirSize -= amt; in readProcessedDataInStream()
256 ssize_t amt = TEMP_FAILURE_RETRY( in readProcessedDataInStream() local
258 if (amt < 0) { in readProcessedDataInStream()
263 } else if (amt == 0) { in readProcessedDataInStream()
267 mBuffer->wp()->move(amt); in readProcessedDataInStream()