Lines Matching refs:ta_
296 ta_.resize(kTaTypeNum); in TraceAnalyzer()
297 ta_[0].type_name = "get"; in TraceAnalyzer()
299 ta_[0].enabled = true; in TraceAnalyzer()
301 ta_[0].enabled = false; in TraceAnalyzer()
303 ta_[1].type_name = "put"; in TraceAnalyzer()
305 ta_[1].enabled = true; in TraceAnalyzer()
307 ta_[1].enabled = false; in TraceAnalyzer()
309 ta_[2].type_name = "delete"; in TraceAnalyzer()
311 ta_[2].enabled = true; in TraceAnalyzer()
313 ta_[2].enabled = false; in TraceAnalyzer()
315 ta_[3].type_name = "single_delete"; in TraceAnalyzer()
317 ta_[3].enabled = true; in TraceAnalyzer()
319 ta_[3].enabled = false; in TraceAnalyzer()
321 ta_[4].type_name = "range_delete"; in TraceAnalyzer()
323 ta_[4].enabled = true; in TraceAnalyzer()
325 ta_[4].enabled = false; in TraceAnalyzer()
327 ta_[5].type_name = "merge"; in TraceAnalyzer()
329 ta_[5].enabled = true; in TraceAnalyzer()
331 ta_[5].enabled = false; in TraceAnalyzer()
333 ta_[6].type_name = "iterator_Seek"; in TraceAnalyzer()
335 ta_[6].enabled = true; in TraceAnalyzer()
337 ta_[6].enabled = false; in TraceAnalyzer()
339 ta_[7].type_name = "iterator_SeekForPrev"; in TraceAnalyzer()
341 ta_[7].enabled = true; in TraceAnalyzer()
343 ta_[7].enabled = false; in TraceAnalyzer()
346 ta_[i].sample_count = 0; in TraceAnalyzer()
525 if (!ta_[type].enabled) { in MakeStatistics()
528 for (auto& stat : ta_[type].stats) { in MakeStatistics()
801 if (!ta_[type].enabled) { in MakeStatisticQPS()
804 for (auto& stat : ta_[type].stats) { in MakeStatisticQPS()
1012 if (!ta_[type].enabled || in ReProcessing()
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()
1080 if (!ta_[type].enabled) { in ReProcessing()
1083 TraceStats& stat = ta_[type].stats[cf_id]; in ReProcessing()
1140 if (!ta_[type].enabled || 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()
1218 auto found_stats = ta_[type].stats.find(cf_id); in KeyStatsInsertion()
1219 if (found_stats == ta_[type].stats.end()) { 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()
1325 ta_[type].stats[cf_id].time_series.push_back(trace_u); in KeyStatsInsertion()
1342 if (type_first >= static_cast<int>(ta_.size()) || in StatsUnitCorrelationUpdate()
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()
1455 if (!ta_[type].enabled) { in CloseOutputFiles()
1458 for (auto& stat : ta_[type].stats) { in CloseOutputFiles()
1520 if (ta_[TraceOperationType::kGet].sample_count >= sample_max_) { in HandleGet()
1521 ta_[TraceOperationType::kGet].sample_count = 0; in HandleGet()
1523 if (ta_[TraceOperationType::kGet].sample_count > 0) { in HandleGet()
1524 ta_[TraceOperationType::kGet].sample_count++; in HandleGet()
1527 ta_[TraceOperationType::kGet].sample_count++; in HandleGet()
1529 if (!ta_[TraceOperationType::kGet].enabled) { in HandleGet()
1556 if (ta_[TraceOperationType::kPut].sample_count >= sample_max_) { in HandlePut()
1557 ta_[TraceOperationType::kPut].sample_count = 0; in HandlePut()
1559 if (ta_[TraceOperationType::kPut].sample_count > 0) { in HandlePut()
1560 ta_[TraceOperationType::kPut].sample_count++; in HandlePut()
1563 ta_[TraceOperationType::kPut].sample_count++; in HandlePut()
1565 if (!ta_[TraceOperationType::kPut].enabled) { in HandlePut()
1589 if (ta_[TraceOperationType::kDelete].sample_count >= sample_max_) { in HandleDelete()
1590 ta_[TraceOperationType::kDelete].sample_count = 0; in HandleDelete()
1592 if (ta_[TraceOperationType::kDelete].sample_count > 0) { in HandleDelete()
1593 ta_[TraceOperationType::kDelete].sample_count++; in HandleDelete()
1596 ta_[TraceOperationType::kDelete].sample_count++; in HandleDelete()
1598 if (!ta_[TraceOperationType::kDelete].enabled) { in HandleDelete()
1622 if (ta_[TraceOperationType::kSingleDelete].sample_count >= sample_max_) { in HandleSingleDelete()
1623 ta_[TraceOperationType::kSingleDelete].sample_count = 0; in HandleSingleDelete()
1625 if (ta_[TraceOperationType::kSingleDelete].sample_count > 0) { in HandleSingleDelete()
1626 ta_[TraceOperationType::kSingleDelete].sample_count++; in HandleSingleDelete()
1629 ta_[TraceOperationType::kSingleDelete].sample_count++; in HandleSingleDelete()
1631 if (!ta_[TraceOperationType::kSingleDelete].enabled) { in HandleSingleDelete()
1656 if (ta_[TraceOperationType::kRangeDelete].sample_count >= sample_max_) { in HandleDeleteRange()
1657 ta_[TraceOperationType::kRangeDelete].sample_count = 0; in HandleDeleteRange()
1659 if (ta_[TraceOperationType::kRangeDelete].sample_count > 0) { in HandleDeleteRange()
1660 ta_[TraceOperationType::kRangeDelete].sample_count++; in HandleDeleteRange()
1663 ta_[TraceOperationType::kRangeDelete].sample_count++; in HandleDeleteRange()
1665 if (!ta_[TraceOperationType::kRangeDelete].enabled) { in HandleDeleteRange()
1691 if (ta_[TraceOperationType::kMerge].sample_count >= sample_max_) { in HandleMerge()
1692 ta_[TraceOperationType::kMerge].sample_count = 0; in HandleMerge()
1694 if (ta_[TraceOperationType::kMerge].sample_count > 0) { in HandleMerge()
1695 ta_[TraceOperationType::kMerge].sample_count++; in HandleMerge()
1698 ta_[TraceOperationType::kMerge].sample_count++; in HandleMerge()
1700 if (!ta_[TraceOperationType::kMerge].enabled) { in HandleMerge()
1736 if (ta_[type].sample_count >= sample_max_) { in HandleIter()
1737 ta_[type].sample_count = 0; in HandleIter()
1739 if (ta_[type].sample_count > 0) { in HandleIter()
1740 ta_[type].sample_count++; in HandleIter()
1743 ta_[type].sample_count++; in HandleIter()
1745 if (!ta_[type].enabled) { in HandleIter()
1763 if (!ta_[type].enabled) { in PrintStatistics()
1766 ta_[type].total_keys = 0; in PrintStatistics()
1767 ta_[type].total_access = 0; in PrintStatistics()
1768 ta_[type].total_succ_access = 0; in PrintStatistics()
1770 ta_[type].type_name.c_str()); in PrintStatistics()
1775 for (auto& stat_it : ta_[type].stats) { in PrintStatistics()
1801 ta_[type].total_keys += total_a_keys; in PrintStatistics()
1802 ta_[type].total_access += stat.a_count; in PrintStatistics()
1803 ta_[type].total_succ_access += stat.a_succ_count; in PrintStatistics()
1807 ta_[type].type_name.c_str(), stat.a_count); in PrintStatistics()
1879 printf("Total keys of '%s' is: %" PRIu64 "\n", ta_[type].type_name.c_str(), in PrintStatistics()
1880 ta_[type].total_keys); in PrintStatistics()
1881 printf("Total access is: %" PRIu64 "\n", ta_[type].total_access); in PrintStatistics()
1882 total_access_keys_ += ta_[type].total_keys; in PrintStatistics()
1909 if (!ta_[type].enabled) { in PrintStatistics()
1912 printf("Operation: '%s' has: %" PRIu64 "\n", ta_[type].type_name.c_str(), in PrintStatistics()
1913 ta_[type].total_access); in PrintStatistics()