Lines Matching refs:mBuffer
37 :mBuffer(new EncodedBuffer(BUFFER_SIZE)), in FdBuffer()
54 if (mBuffer->size() >= MAX_BUFFER_COUNT * BUFFER_SIZE) { in read()
59 if (mBuffer->writeBuffer() == NULL) { in read()
85 ::read(fd, mBuffer->writeBuffer(), mBuffer->currentToWrite())); in read()
97 mBuffer->wp()->move(amt); in read()
109 if (mBuffer->size() >= MAX_BUFFER_COUNT * BUFFER_SIZE) { in readFully()
115 if (mBuffer->writeBuffer() == NULL) { in readFully()
121 TEMP_FAILURE_RETRY(::read(fd, mBuffer->writeBuffer(), mBuffer->currentToWrite())); in readFully()
126 VLOG("Done reading %zu bytes", mBuffer->size()); in readFully()
130 mBuffer->wp()->move(amt); in readFully()
159 if (mBuffer->size() >= MAX_BUFFER_COUNT * BUFFER_SIZE) { in readProcessedDataInStream()
164 if (mBuffer->writeBuffer() == NULL) { in readProcessedDataInStream()
257 ::read(fromFd.get(), mBuffer->writeBuffer(), mBuffer->currentToWrite())); in readProcessedDataInStream()
267 mBuffer->wp()->move(amt); in readProcessedDataInStream()
276 return mBuffer->writeRaw(buf, size); in write()
280 return mBuffer->writeRaw(reader); in write()
284 return mBuffer->writeRaw(reader, size); in write()
288 return mBuffer->size(); in size()
292 return mBuffer; in data()