Method ResStat

phxqueue/comm/utils/benchmark_util.cpp:184–239

void BenchMark::ResStat() {
    timeval now;
    gettimeofday(&now, nullptr);
    long diff_ms{(now.tv_sec - impl_->last_stat_time.tv_sec) * 1000 + (now.tv_usec - impl_->last_stat_time.tv_usec) / 1000};
    impl_->last_stat_time = now;

    const uint32_t time_split[] = {1, 2, 5, 10, 20, 50, 100, 200, 500, 1000};
    const int time_split_size = sizeof(time_split) / sizeof(int);
    int time_split_cnt[sizeof(time_split) / sizeof(int) + 1];
    memset(time_split_cnt, 0, sizeof(time_split_cnt));

    map<int, uint32_t> m;
    uint32_t total{0};
    uint64_t total_time_ms{0};
    uint32_t nroutine_sleep{0};
    for (int i{0}; i < impl_->nthread; ++i) {
        StatData *stat = &impl_->stats[i];
        MutexGuard guard(&stat->mutex);

        for (auto &&it : stat->res_st) {
            m[it.first] += it.second;
            total += it.second;
        }
        stat->res_st.clear();

        for (auto &&it : stat->time_st) {
            int j{0};
            for (; j < time_split_size; ++j)
                if (it.first < time_split[j]) break;
            time_split_cnt[j] += it.second;
            total_time_ms += (uint64_t)it.first * it.second;
        }
        stat->time_st.clear();

        nroutine_sleep += stat->nroutine_sleep;
        stat->nroutine_sleep = 0;
    }

    // log
    printf("\n-------------------------------------------\n");
    printf("--\ttotal:\t%u\n", total);
    printf("--\ttime(ms):\t%ld\n", diff_ms);
    printf("--\tqps:\t%.2lf\n", (double)total / diff_ms * 1000);
    printf("--\troutine_sleep:\t%.2lf%%\n", (double)nroutine_sleep / total * 100.0);
    printf("--\tretcode\tcnt\tpercent\n");
    for (auto it : m) {
        printf("--\t%d\t%u\t%.2lf\n", it.first, it.second, (double)it.second / total * 100.0);
    }

    printf("--\tusetime(ms)\tcnt\tpercent\n");
    for (int i{0}; i < time_split_size; ++i) {
        printf("--\t< %d\t\t%u\t%.2lf\n", time_split[i], time_split_cnt[i], (double)time_split_cnt[i] / total * 100.0);
    }
    printf("--\t>= %d\t\t%u\t%.2lf\n", time_split[time_split_size - 1], time_split_cnt[time_split_size], (double)time_split_cnt[time_split_size] / total * 100.0);
	printf("--\tavg_usetime(ms):\t%.2lf\n", (double)total_time_ms / total);
}