Lines Matching refs:cf_id
194 void DecodeCFAndKeyFromString(std::string& buffer, uint32_t* cf_id, Slice* key) { in DecodeCFAndKeyFromString() argument
196 GetFixed32(&buf, cf_id); in DecodeCFAndKeyFromString()
255 cf_id = 0; in TraceStats()
485 uint32_t cf_id = 0; in StartProcessing() local
487 DecodeCFAndKeyFromString(trace.payload, &cf_id, &key); in StartProcessing()
490 s = HandleGet(cf_id, key.ToString(), trace.ts, 1); in StartProcessing()
497 uint32_t cf_id = 0; in StartProcessing() local
499 DecodeCFAndKeyFromString(trace.payload, &cf_id, &key); in StartProcessing()
500 s = HandleIter(cf_id, key.ToString(), trace.ts, trace.type); in StartProcessing()
682 "%u %zu %" PRIu64 " %" PRIu64 " %f\n", record.second.cf_id, in MakeStatisticKeyStatsOrPrefix()
1007 uint32_t cf_id = cf_it.first; in ReProcessing() local
1013 ta_[type].stats.find(cf_id) == ta_[type].stats.end()) { in ReProcessing()
1016 TraceStats& stat = ta_[type].stats[cf_id]; in ReProcessing()
1019 ta_[type].type_name.c_str(), cf_id); in ReProcessing()
1049 FLAGS_key_space_dir + "/" + std::to_string(cf_id) + ".txt"; in ReProcessing()
1059 cf_id); in ReProcessing()
1070 for (cfs_[cf_id].w_count = 0; in ReProcessing()
1072 ++cfs_[cf_id].w_count) { in ReProcessing()
1083 TraceStats& stat = ta_[type].stats[cf_id]; in ReProcessing()
1087 "%" PRIu64 " %" PRIu64 "\n", cfs_[cf_id].w_count, in ReProcessing()
1109 cfs_[cf_id].w_count, prefix_out.c_str()); in ReProcessing()
1126 if (cfs_[cf_id].w_key_size_stats.find(input_key.size()) == in ReProcessing()
1127 cfs_[cf_id].w_key_size_stats.end()) { in ReProcessing()
1128 cfs_[cf_id].w_key_size_stats[input_key.size()] = 1; in ReProcessing()
1130 cfs_[cf_id].w_key_size_stats[input_key.size()]++; in ReProcessing()
1141 ta_[type].stats.find(cf_id) == ta_[type].stats.end()) { in ReProcessing()
1144 TraceStats& stat = ta_[type].stats[cf_id]; in ReProcessing()
1180 const uint32_t& cf_id, in KeyStatsInsertion() argument
1187 unit.cf_id = cf_id; in KeyStatsInsertion()
1218 auto found_stats = ta_[type].stats.find(cf_id); in KeyStatsInsertion()
1220 ta_[type].stats[cf_id].cf_id = cf_id; in KeyStatsInsertion()
1221 ta_[type].stats[cf_id].cf_name = std::to_string(cf_id); in KeyStatsInsertion()
1222 ta_[type].stats[cf_id].a_count = 1; in KeyStatsInsertion()
1223 ta_[type].stats[cf_id].a_key_id = 0; in KeyStatsInsertion()
1224 ta_[type].stats[cf_id].a_key_size_sqsum = MultiplyCheckOverflow( in KeyStatsInsertion()
1226 ta_[type].stats[cf_id].a_key_size_sum = key.size(); in KeyStatsInsertion()
1227 ta_[type].stats[cf_id].a_value_size_sqsum = MultiplyCheckOverflow( in KeyStatsInsertion()
1229 ta_[type].stats[cf_id].a_value_size_sum = value_size; in KeyStatsInsertion()
1230 s = OpenStatsOutputFiles(ta_[type].type_name, ta_[type].stats[cf_id]); in KeyStatsInsertion()
1234 ta_[type].stats[cf_id].a_key_stats[key] = unit; in KeyStatsInsertion()
1235 ta_[type].stats[cf_id].a_value_size_stats[dist_value_size] = 1; in KeyStatsInsertion()
1236 ta_[type].stats[cf_id].a_qps_stats[time_in_sec] = 1; in KeyStatsInsertion()
1237 ta_[type].stats[cf_id].correlation_output.resize( in KeyStatsInsertion()
1242 ta_[type].stats[cf_id].a_qps_prefix_stats[time_in_sec] = tmp_qps_map; in KeyStatsInsertion()
1245 ta_[type].stats[cf_id].uni_key_num[cur_time_sec_] = in KeyStatsInsertion()
1246 static_cast<uint64_t>(ta_[type].stats[cf_id].a_key_stats.size()); in KeyStatsInsertion()
1306 if (cfs_.find(cf_id) == cfs_.end()) { in KeyStatsInsertion()
1308 cf_unit.cf_id = cf_id; in KeyStatsInsertion()
1311 cfs_[cf_id] = cf_unit; in KeyStatsInsertion()
1315 cfs_[cf_id].cf_qps[time_in_sec]++; in KeyStatsInsertion()
1324 trace_u.cf_id = cf_id; in KeyStatsInsertion()
1325 ta_[type].stats[cf_id].time_series.push_back(trace_u); in KeyStatsInsertion()
1347 ta_[type_first].stats.find(unit.cf_id) == ta_[type_first].stats.end() || in StatsUnitCorrelationUpdate()
1348 ta_[type_first].stats[unit.cf_id].a_key_stats.find(key) == in StatsUnitCorrelationUpdate()
1349 ta_[type_first].stats[unit.cf_id].a_key_stats.end() || in StatsUnitCorrelationUpdate()
1350 ta_[type_first].stats[unit.cf_id].a_key_stats[key].latest_ts == ts) { in StatsUnitCorrelationUpdate()
1364 (ts - ta_[type_first].stats[unit.cf_id].a_key_stats[key].latest_ts); in StatsUnitCorrelationUpdate()
1800 cfs_[stat.cf_id].a_count += total_a_keys; in PrintStatistics()
1805 printf("colume family id: %u\n", stat.cf_id); in PrintStatistics()
1920 const uint32_t& cf_id, in WriteTraceSequence() argument
1927 cf_id, value_size, ts); in WriteTraceSequence()