Lines Matching refs:second
247 correlation_map[it.first][it.second] = sequence; in SparseCorrelationInput()
529 stat.second.a_key_id = 0; in MakeStatistics()
530 for (auto& record : stat.second.a_key_stats) { in MakeStatistics()
531 record.second.key_id = stat.second.a_key_id; in MakeStatistics()
532 stat.second.a_key_id++; in MakeStatistics()
533 if (record.second.access_count <= in MakeStatistics()
540 if (stat.second.a_count_stats.find(record.second.access_count) == in MakeStatistics()
541 stat.second.a_count_stats.end()) { in MakeStatistics()
542 stat.second.a_count_stats[record.second.access_count] = 1; in MakeStatistics()
544 stat.second.a_count_stats[record.second.access_count]++; in MakeStatistics()
550 if (stat.second.a_key_size_stats.find(record.first.size()) == in MakeStatistics()
551 stat.second.a_key_size_stats.end()) { in MakeStatistics()
552 stat.second.a_key_size_stats[record.first.size()] = 1; in MakeStatistics()
554 stat.second.a_key_size_stats[record.first.size()]++; in MakeStatistics()
559 s = MakeStatisticCorrelation(stat.second, record.second); in MakeStatistics()
568 s = MakeStatisticKeyStatsOrPrefix(stat.second); in MakeStatistics()
575 if (FLAGS_output_access_count_stats && stat.second.a_count_dist_f) { in MakeStatistics()
576 for (auto& record : stat.second.a_count_stats) { in MakeStatistics()
579 record.first, record.second); in MakeStatistics()
584 s = stat.second.a_count_dist_f->Append(printout); in MakeStatistics()
595 for (auto& record : stat.second.a_key_size_stats) { in MakeStatistics()
596 k_count += record.second; in MakeStatistics()
597 if (!get_mid && k_count >= stat.second.a_key_mid) { in MakeStatistics()
598 stat.second.a_key_mid = record.first; in MakeStatistics()
601 if (FLAGS_output_key_distribution && stat.second.a_key_size_f) { in MakeStatistics()
603 record.first, record.second); in MakeStatistics()
608 s = stat.second.a_key_size_f->Append(printout); in MakeStatistics()
619 for (auto& record : stat.second.a_value_size_stats) { in MakeStatistics()
622 v_count += record.second; in MakeStatistics()
623 if (!get_mid && v_count >= stat.second.a_count / 2) { in MakeStatistics()
624 stat.second.a_value_mid = (v_begin + v_end) / 2; in MakeStatistics()
627 if (FLAGS_output_value_distribution && stat.second.a_value_size_f && in MakeStatistics()
633 v_begin, v_end, record.second); in MakeStatistics()
638 s = stat.second.a_value_size_f->Append(printout); in MakeStatistics()
675 stats.a_succ_count += record.second.succ_count; in MakeStatisticKeyStatsOrPrefix()
677 if (record.second.access_count > 0) { in MakeStatisticKeyStatsOrPrefix()
678 succ_ratio = (static_cast<double>(record.second.succ_count)) / in MakeStatisticKeyStatsOrPrefix()
679 record.second.access_count; in MakeStatisticKeyStatsOrPrefix()
682 "%u %zu %" PRIu64 " %" PRIu64 " %f\n", record.second.cf_id, in MakeStatisticKeyStatsOrPrefix()
683 record.second.value_size, record.second.key_id, in MakeStatisticKeyStatsOrPrefix()
684 record.second.access_count, succ_ratio); in MakeStatisticKeyStatsOrPrefix()
714 record.second.key_id, prefix_access, prefix_count, in MakeStatisticKeyStatsOrPrefix()
756 prefix_access += record.second.access_count; in MakeStatisticKeyStatsOrPrefix()
758 prefix_succ_access += record.second.succ_count; in MakeStatisticKeyStatsOrPrefix()
780 stats.correlation_output[i].second += unit.v_correlation[i].total_ts; in MakeStatisticCorrelation()
807 for (auto& time_it : stat.second.a_qps_stats) { in MakeStatisticQPS()
811 type_qps[time_it.first][kTaTypeNum] += time_it.second; in MakeStatisticQPS()
812 type_qps[time_it.first][type] += time_it.second; in MakeStatisticQPS()
813 cf_qps_sum += time_it.second; in MakeStatisticQPS()
814 if (time_it.second > stat.second.a_peak_qps) { in MakeStatisticQPS()
815 stat.second.a_peak_qps = time_it.second; in MakeStatisticQPS()
817 if (stat.second.a_qps_f) { in MakeStatisticQPS()
824 s = stat.second.a_qps_f->Append(printout); in MakeStatisticQPS()
831 ret = snprintf(buffer_, sizeof(buffer_), "%u\n", time_it.second); in MakeStatisticQPS()
836 s = stat.second.a_qps_f->Append(printout); in MakeStatisticQPS()
848 if (static_cast<int32_t>(stat.second.top_k_qps_sec.size()) < in MakeStatisticQPS()
850 stat.second.top_k_qps_sec.push( in MakeStatisticQPS()
851 std::make_pair(time_it.second, time_it.first)); in MakeStatisticQPS()
853 if (stat.second.top_k_qps_sec.size() > 0 && in MakeStatisticQPS()
854 stat.second.top_k_qps_sec.top().first < time_it.second) { in MakeStatisticQPS()
855 stat.second.top_k_qps_sec.pop(); in MakeStatisticQPS()
856 stat.second.top_k_qps_sec.push( in MakeStatisticQPS()
857 std::make_pair(time_it.second, time_it.first)); in MakeStatisticQPS()
863 stat.second.a_ave_qps = 0; in MakeStatisticQPS()
865 stat.second.a_ave_qps = (static_cast<double>(cf_qps_sum)) / duration; in MakeStatisticQPS()
869 if (stat.second.a_key_num_f) { in MakeStatisticQPS()
871 static_cast<uint64_t>(stat.second.a_key_stats.size()); in MakeStatisticQPS()
875 auto find_time = stat.second.uni_key_num.find(i); in MakeStatisticQPS()
876 if (find_time != stat.second.uni_key_num.end()) { in MakeStatisticQPS()
877 cur_ratio = (static_cast<double>(find_time->second)) / cur_uni_key; in MakeStatisticQPS()
878 cur_num = find_time->second; in MakeStatisticQPS()
886 s = stat.second.a_key_num_f->Append(printout); in MakeStatisticQPS()
896 if (FLAGS_output_prefix_cut > 0 && stat.second.a_top_qps_prefix_f) { in MakeStatisticQPS()
897 while (!stat.second.top_k_qps_sec.empty()) { in MakeStatisticQPS()
899 stat.second.top_k_qps_sec.top().second, in MakeStatisticQPS()
900 stat.second.top_k_qps_sec.top().first); in MakeStatisticQPS()
905 s = stat.second.a_top_qps_prefix_f->Append(printout); in MakeStatisticQPS()
910 uint32_t qps_time = stat.second.top_k_qps_sec.top().second; in MakeStatisticQPS()
911 stat.second.top_k_qps_sec.pop(); in MakeStatisticQPS()
912 if (stat.second.a_qps_prefix_stats.find(qps_time) != in MakeStatisticQPS()
913 stat.second.a_qps_prefix_stats.end()) { in MakeStatisticQPS()
914 for (auto& qps_prefix : stat.second.a_qps_prefix_stats[qps_time]) { in MakeStatisticQPS()
919 qps_prefix_out.c_str(), qps_prefix.second); in MakeStatisticQPS()
924 s = stat.second.a_top_qps_prefix_f->Append(pout); in MakeStatisticQPS()
1026 key_id = found->second.key_id; in ReProcessing()
1149 std::make_pair(record.second.access_count, record.first)); in ReProcessing()
1151 if (record.second.access_count > stat.top_k_queue.top().first) { in ReProcessing()
1154 std::make_pair(record.second.access_count, record.first)); in ReProcessing()
1250 found_stats->second.a_count++; in KeyStatsInsertion()
1251 found_stats->second.a_key_size_sqsum += MultiplyCheckOverflow( in KeyStatsInsertion()
1253 found_stats->second.a_key_size_sum += key.size(); in KeyStatsInsertion()
1254 found_stats->second.a_value_size_sqsum += MultiplyCheckOverflow( in KeyStatsInsertion()
1256 found_stats->second.a_value_size_sum += value_size; in KeyStatsInsertion()
1257 auto found_key = found_stats->second.a_key_stats.find(key); in KeyStatsInsertion()
1258 if (found_key == found_stats->second.a_key_stats.end()) { in KeyStatsInsertion()
1259 found_stats->second.a_key_stats[key] = unit; in KeyStatsInsertion()
1261 found_key->second.access_count++; in KeyStatsInsertion()
1263 found_key->second.succ_count++; in KeyStatsInsertion()
1266 s = StatsUnitCorrelationUpdate(found_key->second, type, ts, key); in KeyStatsInsertion()
1270 found_stats->second.uni_key_num[cur_time_sec_] = in KeyStatsInsertion()
1271 static_cast<uint64_t>(found_stats->second.a_key_stats.size()); in KeyStatsInsertion()
1276 found_stats->second.a_value_size_stats.find(dist_value_size); in KeyStatsInsertion()
1277 if (found_value == found_stats->second.a_value_size_stats.end()) { in KeyStatsInsertion()
1278 found_stats->second.a_value_size_stats[dist_value_size] = 1; in KeyStatsInsertion()
1280 found_value->second++; in KeyStatsInsertion()
1283 auto found_qps = found_stats->second.a_qps_stats.find(time_in_sec); in KeyStatsInsertion()
1284 if (found_qps == found_stats->second.a_qps_stats.end()) { in KeyStatsInsertion()
1285 found_stats->second.a_qps_stats[time_in_sec] = 1; in KeyStatsInsertion()
1287 found_qps->second++; in KeyStatsInsertion()
1292 found_stats->second.a_qps_prefix_stats.find(time_in_sec); in KeyStatsInsertion()
1293 if (found_qps_prefix == found_stats->second.a_qps_prefix_stats.end()) { in KeyStatsInsertion()
1295 found_stats->second.a_qps_prefix_stats[time_in_sec] = tmp_qps_map; in KeyStatsInsertion()
1297 if (found_stats->second.a_qps_prefix_stats[time_in_sec].find(prefix) == in KeyStatsInsertion()
1298 found_stats->second.a_qps_prefix_stats[time_in_sec].end()) { in KeyStatsInsertion()
1299 found_stats->second.a_qps_prefix_stats[time_in_sec][prefix] = 1; in KeyStatsInsertion()
1301 found_stats->second.a_qps_prefix_stats[time_in_sec][prefix]++; in KeyStatsInsertion()
1459 if (stat.second.time_series_f) { in CloseOutputFiles()
1460 stat.second.time_series_f->Close(); in CloseOutputFiles()
1463 if (stat.second.a_key_f) { in CloseOutputFiles()
1464 stat.second.a_key_f->Close(); in CloseOutputFiles()
1467 if (stat.second.a_key_num_f) { in CloseOutputFiles()
1468 stat.second.a_key_num_f->Close(); in CloseOutputFiles()
1471 if (stat.second.a_count_dist_f) { in CloseOutputFiles()
1472 stat.second.a_count_dist_f->Close(); in CloseOutputFiles()
1475 if (stat.second.a_prefix_cut_f) { in CloseOutputFiles()
1476 stat.second.a_prefix_cut_f->Close(); in CloseOutputFiles()
1479 if (stat.second.a_value_size_f) { in CloseOutputFiles()
1480 stat.second.a_value_size_f->Close(); in CloseOutputFiles()
1483 if (stat.second.a_key_size_f) { in CloseOutputFiles()
1484 stat.second.a_key_size_f->Close(); in CloseOutputFiles()
1487 if (stat.second.a_qps_f) { in CloseOutputFiles()
1488 stat.second.a_qps_f->Close(); in CloseOutputFiles()
1491 if (stat.second.a_top_qps_prefix_f) { in CloseOutputFiles()
1492 stat.second.a_top_qps_prefix_f->Close(); in CloseOutputFiles()
1495 if (stat.second.w_key_f) { in CloseOutputFiles()
1496 stat.second.w_key_f->Close(); in CloseOutputFiles()
1498 if (stat.second.w_prefix_cut_f) { in CloseOutputFiles()
1499 stat.second.w_prefix_cut_f->Close(); in CloseOutputFiles()
1776 if (stat_it.second.a_count == 0) { in PrintStatistics()
1779 TraceStats& stat = stat_it.second; in PrintStatistics()
1826 stat.top_k_queue.top().second); in PrintStatistics()
1839 stat.top_k_prefix_access.top().second.c_str(), in PrintStatistics()
1848 stat.top_k_prefix_ave.top().second.c_str(), in PrintStatistics()
1862 taIndexToOpt[analyzer_opts_.correlation_list[correlation].second] in PrintStatistics()
1870 stat.correlation_output[correlation].second)) / in PrintStatistics()
1891 printf("The whole key space key numbers: %" PRIu64 "\n", cf.second.w_count); in PrintStatistics()
1893 cf.second.a_count); in PrintStatistics()