Searched refs:bytes_consumed (Results 1 – 4 of 4) sorted by relevance
80 int bytes_consumed = ScanForChunkRemaining(buf, buf_len); in FilterBuf() local81 if (bytes_consumed < 0) in FilterBuf()82 return bytes_consumed; // Error in FilterBuf()84 buf_len -= bytes_consumed; in FilterBuf()86 memmove(buf, buf + bytes_consumed, buf_len); in FilterBuf()96 int bytes_consumed = 0; in ScanForChunkRemaining() local103 bytes_consumed = static_cast<int>(index_of_lf) + 1; in ScanForChunkRemaining()145 bytes_consumed = buf_len; in ScanForChunkRemaining()153 return bytes_consumed; in ScanForChunkRemaining()
359 int* bytes_consumed) { in UTF8GenericScan() argument360 *bytes_consumed = 0; in UTF8GenericScan()462 *bytes_consumed = src - isrc; in UTF8GenericScan()469 int* bytes_consumed) { in UTF8GenericScanFastAscii() argument470 *bytes_consumed = 0; in UTF8GenericScanFastAscii()502 *bytes_consumed = src - isrc; in UTF8GenericScanFastAscii()528 int bytes_consumed = 0; in IsStructurallyValidUTF8() local530 buf, len, &bytes_consumed); in IsStructurallyValidUTF8()531 return (bytes_consumed == len); in IsStructurallyValidUTF8()
49 size_t bytes_consumed; /* bytes consumed in cur read subbuf */ member
934 size_t bytes_consumed = sm_interface_->ProcessInput(bytes, size); in DoConsumeReadData() local935 VLOG(2) << "consumed: " << bytes_consumed << " from socket fd: " << fd_; in DoConsumeReadData()936 if (bytes_consumed == 0) { in DoConsumeReadData()939 read_buffer_.AdvanceReadablePtr(bytes_consumed); in DoConsumeReadData()