Lines Matching refs:record
62 BlockCacheTraceRecord record; in WriteBlockAccess() local
63 record.block_type = block_type; in WriteBlockAccess()
64 record.block_size = kBlockSize + key_id; in WriteBlockAccess()
65 record.block_key = (kBlockKeyPrefix + std::to_string(key_id)); in WriteBlockAccess()
66 record.access_timestamp = env_->NowMicros(); in WriteBlockAccess()
67 record.cf_id = kCFId; in WriteBlockAccess()
68 record.cf_name = kDefaultColumnFamilyName; in WriteBlockAccess()
69 record.caller = GetCaller(key_id); in WriteBlockAccess()
70 record.level = kLevel; in WriteBlockAccess()
71 record.sst_fd_number = kSSTFDNumber + key_id; in WriteBlockAccess()
72 record.is_cache_hit = Boolean::kFalse; in WriteBlockAccess()
73 record.no_insert = Boolean::kFalse; in WriteBlockAccess()
76 record.get_id = key_id + 1; in WriteBlockAccess()
77 record.get_from_user_specified_snapshot = Boolean::kTrue; in WriteBlockAccess()
81 record.referenced_key = (kRefKeyPrefix + std::to_string(key_id)); in WriteBlockAccess()
82 record.referenced_key_exist_in_block = Boolean::kTrue; in WriteBlockAccess()
83 record.num_keys_in_block = kNumKeysInBlock; in WriteBlockAccess()
84 record.referenced_data_size = kReferencedDataSize + key_id; in WriteBlockAccess()
86 record, record.block_key, record.cf_name, record.referenced_key)); in WriteBlockAccess()
92 BlockCacheTraceRecord record; in GenerateAccessRecord() local
93 record.block_type = TraceType::kBlockTraceDataBlock; in GenerateAccessRecord()
94 record.block_size = kBlockSize; in GenerateAccessRecord()
95 record.block_key = kBlockKeyPrefix + std::to_string(key_id); in GenerateAccessRecord()
96 record.access_timestamp = env_->NowMicros(); in GenerateAccessRecord()
97 record.cf_id = kCFId; in GenerateAccessRecord()
98 record.cf_name = kDefaultColumnFamilyName; in GenerateAccessRecord()
99 record.caller = GetCaller(key_id); in GenerateAccessRecord()
100 record.level = kLevel; in GenerateAccessRecord()
101 record.sst_fd_number = kSSTFDNumber + key_id; in GenerateAccessRecord()
102 record.is_cache_hit = Boolean::kFalse; in GenerateAccessRecord()
103 record.no_insert = Boolean::kFalse; in GenerateAccessRecord()
104 record.referenced_key = kRefKeyPrefix + std::to_string(key_id); in GenerateAccessRecord()
105 record.referenced_key_exist_in_block = Boolean::kTrue; in GenerateAccessRecord()
106 record.num_keys_in_block = kNumKeysInBlock; in GenerateAccessRecord()
107 return record; in GenerateAccessRecord()
115 BlockCacheTraceRecord record; in VerifyAccess() local
116 ASSERT_OK(reader->ReadAccess(&record)); in VerifyAccess()
117 ASSERT_EQ(block_type, record.block_type); in VerifyAccess()
118 ASSERT_EQ(kBlockSize + key_id, record.block_size); in VerifyAccess()
119 ASSERT_EQ(kBlockKeyPrefix + std::to_string(key_id), record.block_key); in VerifyAccess()
120 ASSERT_EQ(kCFId, record.cf_id); in VerifyAccess()
121 ASSERT_EQ(kDefaultColumnFamilyName, record.cf_name); in VerifyAccess()
122 ASSERT_EQ(GetCaller(key_id), record.caller); in VerifyAccess()
123 ASSERT_EQ(kLevel, record.level); in VerifyAccess()
124 ASSERT_EQ(kSSTFDNumber + key_id, record.sst_fd_number); in VerifyAccess()
125 ASSERT_EQ(Boolean::kFalse, record.is_cache_hit); in VerifyAccess()
126 ASSERT_EQ(Boolean::kFalse, record.no_insert); in VerifyAccess()
127 if (record.caller == TableReaderCaller::kUserGet || in VerifyAccess()
128 record.caller == TableReaderCaller::kUserMultiGet) { in VerifyAccess()
129 ASSERT_EQ(key_id + 1, record.get_id); in VerifyAccess()
130 ASSERT_EQ(Boolean::kTrue, record.get_from_user_specified_snapshot); in VerifyAccess()
132 record.referenced_key); in VerifyAccess()
134 ASSERT_EQ(BlockCacheTraceHelper::kReservedGetId, record.get_id); in VerifyAccess()
135 ASSERT_EQ(Boolean::kFalse, record.get_from_user_specified_snapshot); in VerifyAccess()
136 ASSERT_EQ("", record.referenced_key); in VerifyAccess()
139 (record.caller == TableReaderCaller::kUserGet || in VerifyAccess()
140 record.caller == TableReaderCaller::kUserMultiGet)) { in VerifyAccess()
141 ASSERT_EQ(Boolean::kTrue, record.referenced_key_exist_in_block); in VerifyAccess()
142 ASSERT_EQ(kNumKeysInBlock, record.num_keys_in_block); in VerifyAccess()
143 ASSERT_EQ(kReferencedDataSize + key_id, record.referenced_data_size); in VerifyAccess()
146 ASSERT_EQ(Boolean::kFalse, record.referenced_key_exist_in_block); in VerifyAccess()
147 ASSERT_EQ(0, record.num_keys_in_block); in VerifyAccess()
148 ASSERT_EQ(0, record.referenced_data_size); in VerifyAccess()
159 BlockCacheTraceRecord record = GenerateAccessRecord(); in TEST_F() local
167 ASSERT_OK(writer.WriteBlockAccess(record, record.block_key, record.cf_name, in TEST_F()
168 record.referenced_key)); in TEST_F()
183 BlockCacheTraceRecord record = GenerateAccessRecord(); in TEST_F() local
191 ASSERT_OK(writer.WriteBlockAccess(record, record.block_key, record.cf_name, in TEST_F()
192 record.referenced_key)); in TEST_F()
206 ASSERT_NOK(reader.ReadAccess(&record)); in TEST_F()
222 BlockCacheTraceRecord record = GenerateAccessRecord(); in TEST_F() local
230 ASSERT_OK(writer.WriteBlockAccess(record, record.block_key, record.cf_name, in TEST_F()
231 record.referenced_key)); in TEST_F()
235 ASSERT_OK(writer.WriteBlockAccess(record, record.block_key, record.cf_name, in TEST_F()
236 record.referenced_key)); in TEST_F()
250 ASSERT_NOK(reader.ReadAccess(&record)); in TEST_F()
319 BlockCacheTraceRecord record; in TEST_F() local
320 ASSERT_NOK(reader.ReadAccess(&record)); in TEST_F()
325 BlockCacheTraceRecord record = GenerateAccessRecord(); in TEST_F() local
326 record.get_id = 1; in TEST_F()
327 record.referenced_key = ""; in TEST_F()
328 record.caller = TableReaderCaller::kUserGet; in TEST_F()
329 record.get_from_user_specified_snapshot = Boolean::kTrue; in TEST_F()
330 record.referenced_data_size = kReferencedDataSize; in TEST_F()
331 PutFixed32(&record.referenced_key, 111); in TEST_F()
332 PutLengthPrefixedSlice(&record.referenced_key, "get_key"); in TEST_F()
333 PutFixed64(&record.referenced_key, 2 << 8); in TEST_F()
334 PutLengthPrefixedSlice(&record.block_key, "block_key"); in TEST_F()
335 PutVarint64(&record.block_key, 333); in TEST_F()
340 ASSERT_OK(writer.WriteHumanReadableTraceRecord(record, 1, 1)); in TEST_F()
363 ASSERT_EQ(record.block_key.size(), read_record.block_key.size()); in TEST_F()
364 ASSERT_EQ(record.referenced_key.size(), record.referenced_key.size()); in TEST_F()