Searched refs:header_size (Results 1 – 3 of 3) sorted by relevance
56 const int header_size = in AddRecord() local67 if (leftover < header_size) { in AddRecord()72 assert(header_size <= 11); in AddRecord()83 assert(static_cast<int64_t>(kBlockSize - block_offset_) >= header_size); in AddRecord()85 const size_t avail = kBlockSize - block_offset_ - header_size; in AddRecord()120 size_t header_size; in EmitPhysicalRecord() local132 header_size = kHeaderSize; in EmitPhysicalRecord()136 header_size = kRecyclableHeaderSize; in EmitPhysicalRecord()153 IOStatus s = dest_->Append(Slice(buf, header_size)); in EmitPhysicalRecord()157 block_offset_ += header_size + n; in EmitPhysicalRecord()
312 int header_size = in TEST_P() local314 const int n = kBlockSize - 2 * header_size; in TEST_P()327 int header_size = in TEST_P() local329 const int n = kBlockSize - 2 * header_size; in TEST_P()341 int header_size = in TEST_P() local355 int header_size = in TEST_P() local614 ForceEOF(3 + header_size + 2); in TEST_P()633 ForceEOF(n + num_full_blocks * header_size + header_size + 3); in TEST_P()826 size_t delta = header_size - 1; in TEST_P()869 size_t delta = header_size + 1; in TEST_P()[all …]
333 int header_size = kHeaderSize; in ReadPhysicalRecord() local338 header_size = kRecyclableHeaderSize; in ReadPhysicalRecord()352 if (header_size + length > buffer_.size()) { in ReadPhysicalRecord()392 buffer_.remove_prefix(header_size + length); in ReadPhysicalRecord()394 *result = Slice(header + header_size, length); in ReadPhysicalRecord()565 int header_size = kHeaderSize; in TryReadFragment() local570 header_size = kRecyclableHeaderSize; in TryReadFragment()588 while (header_size + length > buffer_.size()) { in TryReadFragment()607 uint32_t actual_crc = crc32c::Value(header + 6, length + header_size - 6); in TryReadFragment()616 buffer_.remove_prefix(header_size + length); in TryReadFragment()[all …]