Searched refs:wpos (Results 1 – 1 of 1) sorted by relevance
155 int rpos = 0, wpos = 0; in readProcessedDataInStream() local202 if (rpos >= wpos) { in readProcessedDataInStream()205 amt = TEMP_FAILURE_RETRY(::read(fd, cirBuf + rpos, wpos - rpos)); in readProcessedDataInStream()224 if (rpos > wpos) { in readProcessedDataInStream()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()235 wpos += amt; in readProcessedDataInStream()251 if (wpos >= BUFFER_SIZE) { in readProcessedDataInStream()252 wpos = 0; in readProcessedDataInStream()