Lines Matching refs:record

112     const BlockCacheTraceRecord& record, const Slice& block_key,  in WriteBlockAccess()  argument
119 trace.ts = record.access_timestamp; in WriteBlockAccess()
120 trace.type = record.block_type; in WriteBlockAccess()
122 PutFixed64(&trace.payload, record.block_size); in WriteBlockAccess()
123 PutFixed64(&trace.payload, record.cf_id); in WriteBlockAccess()
125 PutFixed32(&trace.payload, record.level); in WriteBlockAccess()
126 PutFixed64(&trace.payload, record.sst_fd_number); in WriteBlockAccess()
127 trace.payload.push_back(record.caller); in WriteBlockAccess()
128 trace.payload.push_back(record.is_cache_hit); in WriteBlockAccess()
129 trace.payload.push_back(record.no_insert); in WriteBlockAccess()
130 if (BlockCacheTraceHelper::IsGetOrMultiGet(record.caller)) { in WriteBlockAccess()
131 PutFixed64(&trace.payload, record.get_id); in WriteBlockAccess()
132 trace.payload.push_back(record.get_from_user_specified_snapshot); in WriteBlockAccess()
135 if (BlockCacheTraceHelper::IsGetOrMultiGetOnDataBlock(record.block_type, in WriteBlockAccess()
136 record.caller)) { in WriteBlockAccess()
137 PutFixed64(&trace.payload, record.referenced_data_size); in WriteBlockAccess()
138 PutFixed64(&trace.payload, record.num_keys_in_block); in WriteBlockAccess()
139 trace.payload.push_back(record.referenced_key_exist_in_block); in WriteBlockAccess()
204 Status BlockCacheTraceReader::ReadAccess(BlockCacheTraceRecord* record) { in ReadAccess() argument
205 assert(record); in ReadAccess()
216 record->access_timestamp = trace.ts; in ReadAccess()
217 record->block_type = trace.type; in ReadAccess()
225 record->block_key = block_key.ToString(); in ReadAccess()
226 if (!GetFixed64(&enc_slice, &record->block_size)) { in ReadAccess()
230 if (!GetFixed64(&enc_slice, &record->cf_id)) { in ReadAccess()
239 record->cf_name = cf_name.ToString(); in ReadAccess()
240 if (!GetFixed32(&enc_slice, &record->level)) { in ReadAccess()
244 if (!GetFixed64(&enc_slice, &record->sst_fd_number)) { in ReadAccess()
252 record->caller = static_cast<TableReaderCaller>(enc_slice[0]); in ReadAccess()
258 record->is_cache_hit = static_cast<Boolean>(enc_slice[0]); in ReadAccess()
264 record->no_insert = static_cast<Boolean>(enc_slice[0]); in ReadAccess()
266 if (BlockCacheTraceHelper::IsGetOrMultiGet(record->caller)) { in ReadAccess()
267 if (!GetFixed64(&enc_slice, &record->get_id)) { in ReadAccess()
276 record->get_from_user_specified_snapshot = in ReadAccess()
284 record->referenced_key = referenced_key.ToString(); in ReadAccess()
286 if (BlockCacheTraceHelper::IsGetOrMultiGetOnDataBlock(record->block_type, in ReadAccess()
287 record->caller)) { in ReadAccess()
288 if (!GetFixed64(&enc_slice, &record->referenced_data_size)) { in ReadAccess()
292 if (!GetFixed64(&enc_slice, &record->num_keys_in_block)) { in ReadAccess()
302 record->referenced_key_exist_in_block = static_cast<Boolean>(enc_slice[0]); in ReadAccess()
369 BlockCacheTraceRecord* record) { in ReadAccess() argument
385 record->access_timestamp = ParseUint64(record_strs[0]); in ReadAccess()
387 record->block_type = static_cast<TraceType>(ParseUint64(record_strs[2])); in ReadAccess()
388 record->block_size = ParseUint64(record_strs[3]); in ReadAccess()
389 record->cf_id = ParseUint64(record_strs[4]); in ReadAccess()
390 record->cf_name = record_strs[5]; in ReadAccess()
391 record->level = static_cast<uint32_t>(ParseUint64(record_strs[6])); in ReadAccess()
392 record->sst_fd_number = ParseUint64(record_strs[7]); in ReadAccess()
393 record->caller = static_cast<TableReaderCaller>(ParseUint64(record_strs[8])); in ReadAccess()
394 record->no_insert = static_cast<Boolean>(ParseUint64(record_strs[9])); in ReadAccess()
395 record->get_id = ParseUint64(record_strs[10]); in ReadAccess()
398 record->referenced_data_size = ParseUint64(record_strs[12]); in ReadAccess()
399 record->is_cache_hit = static_cast<Boolean>(ParseUint64(record_strs[13])); in ReadAccess()
400 record->referenced_key_exist_in_block = in ReadAccess()
402 record->num_keys_in_block = ParseUint64(record_strs[15]); in ReadAccess()
411 record->get_from_user_specified_snapshot = Boolean::kTrue; in ReadAccess()
424 while (record->block_key.size() < block_key_size - tmp_block_key.size()) { in ReadAccess()
425 record->block_key += "1"; in ReadAccess()
427 record->block_key += tmp_block_key; in ReadAccess()
433 PutFixed32(&record->referenced_key, static_cast<uint32_t>(table_id)); in ReadAccess()
435 while (record->referenced_key.size() < get_key_size - tmp_get_key.size()) { in ReadAccess()
436 record->referenced_key += "1"; in ReadAccess()
438 record->referenced_key += tmp_get_key; in ReadAccess()
470 Status BlockCacheTracer::WriteBlockAccess(const BlockCacheTraceRecord& record, in WriteBlockAccess() argument
481 return writer_.load()->WriteBlockAccess(record, block_key, cf_name, in WriteBlockAccess()