walkero
/
nghttp2
1
0
Fork 0
Code Issues Pull Requests Projects Releases 1 Wiki Activity

clang-format

This commit is contained in:
Tatsuhiro Tsujikawa 2015-05-03 16:47:32 +09:00
parent 555d5abac9
commit b4e8bea4b5
2 changed files with 61 additions and 37 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

78
src/h2load.cc
View File

@ -150,8 +150,8 @@ void readcb(struct ev_loop *loop, ev_io *w, int revents) {
Client::Client(Worker *worker, size_t req_todo) Client::Client(Worker *worker, size_t req_todo)
: worker(worker), ssl(nullptr), next_addr(config.addrs), reqidx(0), : worker(worker), ssl(nullptr), next_addr(config.addrs), reqidx(0),
state(CLIENT_IDLE), first_byte_received(false), req_todo(req_todo), req_started(0), req_done(0), state(CLIENT_IDLE), first_byte_received(false), req_todo(req_todo),
fd(-1) { req_started(0), req_done(0), fd(-1) {
ev_io_init(&wev, writecb, 0, EV_WRITE); ev_io_init(&wev, writecb, 0, EV_WRITE);
ev_io_init(&rev, readcb, 0, EV_READ); ev_io_init(&rev, readcb, 0, EV_READ);
@ -759,7 +759,8 @@ void Worker::run() {
namespace { namespace {
double within_sd(const std::vector<std::unique_ptr<Worker>> &workers, double within_sd(const std::vector<std::unique_ptr<Worker>> &workers,
const std::chrono::microseconds &mean, const std::chrono::microseconds &mean,
const std::chrono::microseconds &sd, size_t n, TimeStatType type) { const std::chrono::microseconds &sd, size_t n,
TimeStatType type) {
auto upper = mean.count() + sd.count(); auto upper = mean.count() + sd.count();
auto lower = mean.count() - sd.count(); auto lower = mean.count() - sd.count();
size_t m = 0; size_t m = 0;
@ -769,7 +770,8 @@ double within_sd(const std::vector<std::unique_ptr<Worker>> &workers,
if (!req_stat.completed) { if (!req_stat.completed) {
continue; continue;
} }
auto t = std::chrono::duration_cast<std::chrono::microseconds>(req_stat.stream_close_time - req_stat.request_time); auto t = std::chrono::duration_cast<std::chrono::microseconds>(
req_stat.stream_close_time - req_stat.request_time);
if (lower <= t.count() && t.count() <= upper) { if (lower <= t.count() && t.count() <= upper) {
++m; ++m;
} }
@ -777,14 +779,18 @@ double within_sd(const std::vector<std::unique_ptr<Worker>> &workers,
} else { } else {
const auto &stat = w->stats; const auto &stat = w->stats;
for (unsigned int i = 0; i < stat.start_times.size(); i++) { for (unsigned int i = 0; i < stat.start_times.size(); i++) {
if (i >= stat.connect_times.size() || i >= stat.time_to_first_bytes.size()) { if (i >= stat.connect_times.size() ||
continue; //rule out cases where we started but didn't connect or get the first byte (errors) i >= stat.time_to_first_bytes.size()) {
continue; // rule out cases where we started but didn't connect or get
// the first byte (errors)
} }
std::chrono::microseconds t; std::chrono::microseconds t;
if (type == STAT_CONNECT) { if (type == STAT_CONNECT) {
t = std::chrono::duration_cast<std::chrono::microseconds>(stat.connect_times[i] - stat.start_times[i]); t = std::chrono::duration_cast<std::chrono::microseconds>(
stat.connect_times[i] - stat.start_times[i]);
} else if (type == STAT_FIRST_BYTE) { } else if (type == STAT_FIRST_BYTE) {
t = std::chrono::duration_cast<std::chrono::microseconds>(stat.time_to_first_bytes[i] - stat.start_times[i]); t = std::chrono::duration_cast<std::chrono::microseconds>(
stat.time_to_first_bytes[i] - stat.start_times[i]);
} else { } else {
return -1; return -1;
} }
@ -839,28 +845,34 @@ process_time_stats(const std::vector<std::unique_ptr<Worker>> &workers) {
request_sum += request_t.count(); request_sum += request_t.count();
auto request_na = request_a + (request_t.count() - request_a) / n; auto request_na = request_a + (request_t.count() - request_a) / n;
request_q = request_q + (request_t.count() - request_a) * (request_t.count() - request_na); request_q =
request_q +
(request_t.count() - request_a) * (request_t.count() - request_na);
request_a = request_na; request_a = request_na;
} }
for (unsigned int i = 0; i < stat.start_times.size(); i++) { for (unsigned int i = 0; i < stat.start_times.size(); i++) {
if (i >= stat.connect_times.size() || i >= stat.time_to_first_bytes.size()) { if (i >= stat.connect_times.size() ||
continue; //rule out cases where we started but didn't connect or get the first byte (errors) i >= stat.time_to_first_bytes.size()) {
continue; // rule out cases where we started but didn't connect or get
// the first byte (errors)
} }
++m; ++m;
auto connect_t = std::chrono::duration_cast<std::chrono::microseconds>( auto connect_t = std::chrono::duration_cast<std::chrono::microseconds>(
stat.connect_times[i] - stat.start_times[i]); stat.connect_times[i] - stat.start_times[i]);
ts.connect_time_min = std::min(ts.connect_time_min, connect_t); ts.connect_time_min = std::min(ts.connect_time_min, connect_t);
ts.connect_time_max = std::max(ts.connect_time_max, connect_t); ts.connect_time_max = std::max(ts.connect_time_max, connect_t);
connect_sum += connect_t.count(); connect_sum += connect_t.count();
auto ttfb_t = std::chrono::duration_cast<std::chrono::microseconds>( auto ttfb_t = std::chrono::duration_cast<std::chrono::microseconds>(
stat.time_to_first_bytes[i] - stat.start_times[i]); stat.time_to_first_bytes[i] - stat.start_times[i]);
ts.ttfb_min = std::min(ts.ttfb_min, ttfb_t); ts.ttfb_min = std::min(ts.ttfb_min, ttfb_t);
ts.ttfb_max = std::max(ts.ttfb_max, ttfb_t); ts.ttfb_max = std::max(ts.ttfb_max, ttfb_t);
ttfb_sum += ttfb_t.count(); ttfb_sum += ttfb_t.count();
auto connect_na = connect_a + (connect_t.count() - connect_a) / m; auto connect_na = connect_a + (connect_t.count() - connect_a) / m;
connect_q = connect_q + (connect_t.count() - connect_a) * (connect_t.count() - connect_na); connect_q =
connect_q +
(connect_t.count() - connect_a) * (connect_t.count() - connect_na);
connect_a = connect_na; connect_a = connect_na;
auto ttfb_na = ttfb_a + (ttfb_t.count() - ttfb_a) / m; auto ttfb_na = ttfb_a + (ttfb_t.count() - ttfb_a) / m;
@ -869,8 +881,10 @@ process_time_stats(const std::vector<std::unique_ptr<Worker>> &workers) {
} }
} }
if (n == 0) { if (n == 0) {
ts.request_time_max = ts.request_time_min = std::chrono::microseconds::zero(); ts.request_time_max = ts.request_time_min =
ts.connect_time_max = ts.connect_time_min = std::chrono::microseconds::zero(); std::chrono::microseconds::zero();
ts.connect_time_max = ts.connect_time_min =
std::chrono::microseconds::zero();
ts.ttfb_max = ts.ttfb_min = std::chrono::microseconds::zero(); ts.ttfb_max = ts.ttfb_min = std::chrono::microseconds::zero();
return ts; return ts;
} }
@ -887,10 +901,12 @@ process_time_stats(const std::vector<std::unique_ptr<Worker>> &workers) {
ts.ttfb_sd = std::chrono::microseconds( ts.ttfb_sd = std::chrono::microseconds(
static_cast<std::chrono::microseconds::rep>(sqrt(ttfb_q / m))); static_cast<std::chrono::microseconds::rep>(sqrt(ttfb_q / m)));
ts.request_within_sd = within_sd(workers, ts.request_time_mean,
ts.request_within_sd = within_sd(workers, ts.request_time_mean, ts.request_time_sd, n, STAT_REQUEST); ts.request_time_sd, n, STAT_REQUEST);
ts.connect_within_sd = within_sd(workers, ts.connect_time_mean, ts.connect_time_sd, m, STAT_CONNECT); ts.connect_within_sd = within_sd(workers, ts.connect_time_mean,
ts.ttfb_within_sd = within_sd(workers, ts.ttfb_mean, ts.ttfb_sd, m, STAT_FIRST_BYTE); ts.connect_time_sd, m, STAT_CONNECT);
ts.ttfb_within_sd =
within_sd(workers, ts.ttfb_mean, ts.ttfb_sd, m, STAT_FIRST_BYTE);
return ts; return ts;
} }
} // namespace } // namespace
@ -1540,17 +1556,23 @@ traffic: )" << stats.bytes_total << " bytes total, " << stats.bytes_head
min max mean sd +/- sd min max mean sd +/- sd
time for request: )" << std::setw(10) time for request: )" << std::setw(10)
<< util::format_duration(time_stats.request_time_min) << " " << util::format_duration(time_stats.request_time_min) << " "
<< std::setw(10) << util::format_duration(time_stats.request_time_max) << std::setw(10)
<< " " << std::setw(10) << util::format_duration(time_stats.request_time_max) << " "
<< std::setw(10)
<< util::format_duration(time_stats.request_time_mean) << " " << util::format_duration(time_stats.request_time_mean) << " "
<< std::setw(10) << util::format_duration(time_stats.request_time_sd) << std::setw(10)
<< std::setw(9) << util::dtos(time_stats.request_within_sd) << "%" << "\ntime for connect: " << std::setw(10) << util::format_duration(time_stats.request_time_sd) << std::setw(9)
<< util::dtos(time_stats.request_within_sd) << "%"
<< "\ntime for connect: " << std::setw(10)
<< util::format_duration(time_stats.connect_time_min) << " " << util::format_duration(time_stats.connect_time_min) << " "
<< std::setw(10) << util::format_duration(time_stats.connect_time_max) << std::setw(10)
<< " " << std::setw(10) << util::format_duration(time_stats.connect_time_max) << " "
<< std::setw(10)
<< util::format_duration(time_stats.connect_time_mean) << " " << util::format_duration(time_stats.connect_time_mean) << " "
<< std::setw(10) << util::format_duration(time_stats.connect_time_sd) << std::setw(10)
<< std::setw(9) << util::dtos(time_stats.connect_within_sd) << "%" << "\ntime to 1st byte: " << std::setw(10) << util::format_duration(time_stats.connect_time_sd) << std::setw(9)
<< util::dtos(time_stats.connect_within_sd) << "%"
<< "\ntime to 1st byte: " << std::setw(10)
<< util::format_duration(time_stats.ttfb_min) << " " << util::format_duration(time_stats.ttfb_min) << " "
<< std::setw(10) << util::format_duration(time_stats.ttfb_max) << std::setw(10) << util::format_duration(time_stats.ttfb_max)
<< " " << std::setw(10) << " " << std::setw(10)

10
src/h2load.h
View File

@ -87,7 +87,7 @@ struct RequestStat {
std::chrono::steady_clock::time_point request_time; std::chrono::steady_clock::time_point request_time;
// time point when stream was closed // time point when stream was closed
std::chrono::steady_clock::time_point stream_close_time; std::chrono::steady_clock::time_point stream_close_time;
// upload data length sent so far // upload data length sent so far
int64_t data_offset; int64_t data_offset;
// true if stream was successfully closed. This means stream was // true if stream was successfully closed. This means stream was
// not reset, but it does not mean HTTP level error (e.g., 404). // not reset, but it does not mean HTTP level error (e.g., 404).
@ -96,11 +96,13 @@ struct RequestStat {
struct TimeStats { struct TimeStats {
// time for request: max, min, mean and sd (standard deviation) // time for request: max, min, mean and sd (standard deviation)
std::chrono::microseconds request_time_max, request_time_min, request_time_mean, request_time_sd; std::chrono::microseconds request_time_max, request_time_min,
request_time_mean, request_time_sd;
// percentage of number of requests inside mean -/+ sd // percentage of number of requests inside mean -/+ sd
double request_within_sd; double request_within_sd;
// time for connect: max, min, mean and sd (standard deviation) // time for connect: max, min, mean and sd (standard deviation)
std::chrono::microseconds connect_time_max, connect_time_min, connect_time_mean, connect_time_sd; std::chrono::microseconds connect_time_max, connect_time_min,
connect_time_mean, connect_time_sd;
// percentage of number of connects inside mean -/+ sd // percentage of number of connects inside mean -/+ sd
double connect_within_sd; double connect_within_sd;
// time to first byte: max, min, mean and sd (standard deviation) // time to first byte: max, min, mean and sd (standard deviation)
@ -142,7 +144,7 @@ struct Stats {
std::array<size_t, 6> status; std::array<size_t, 6> status;
// The statistics per request // The statistics per request
std::vector<RequestStat> req_stats; std::vector<RequestStat> req_stats;
// time connect starts // time connect starts
std::vector<std::chrono::steady_clock::time_point> start_times; std::vector<std::chrono::steady_clock::time_point> start_times;
// time to connect // time to connect
std::vector<std::chrono::steady_clock::time_point> connect_times; std::vector<std::chrono::steady_clock::time_point> connect_times;