Lines Matching defs:client
369 auto client = static_cast<HttpClient *>(ev_userdata(loop));
373 error = nghttp2_submit_data(client->session, NGHTTP2_FLAG_END_STREAM,
379 nghttp2_submit_rst_stream(client->session, NGHTTP2_FLAG_NONE,
383 client->signal_write();
417 auto client = static_cast<HttpClient *>(htp->data);
418 client->upgrade_response_status_code = htp->status_code;
419 client->upgrade_response_complete = true;
453 int submit_request(HttpClient *client, const Headers &headers, Request *req) {
458 {":authority", client->hostport},
524 stream_id = nghttp2_submit_headers(client->session, 0, -1, &req->pri_spec,
528 nghttp2_submit_request(client->session, &req->pri_spec, nva.data(),
541 client->request_done(req);
546 auto timer = std::make_unique<ContinueTimer>(client->loop, req);
556 auto client = static_cast<HttpClient *>(w->data);
557 if (client->do_read() != 0) {
558 client->disconnect();
565 auto client = static_cast<HttpClient *>(w->data);
566 auto rv = client->do_write();
568 client->connect_fail();
572 client->disconnect();
579 auto client = static_cast<HttpClient *>(w->data);
581 client->disconnect();
587 auto client = static_cast<HttpClient *>(w->data);
590 nghttp2_session_terminate_session(client->session, NGHTTP2_SETTINGS_TIMEOUT);
592 client->signal_write();
1680 void update_html_parser(HttpClient *client, Request *req, const uint8_t *data,
1716 if (client->add_request(uri, nullptr, 0, pri_spec, req->level + 1)) {
1717 submit_request(client, config.headers, client->reqvec.back().get());
1734 auto client = get_client(user_data);
1767 update_html_parser(client, req, out.data(), outlen, 0);
1779 update_html_parser(client, req, data, len, 0);
1856 auto client = get_client(user_data);
1889 client->request_done(req.get());
1891 client->reqvec.push_back(std::move(req));
1978 auto client = get_client(user_data);
1990 ++client->success;
2027 ++client->success;
2036 ev_timer_stop(client->loop, &client->settings_timer);
2078 if (client->path_cache.count(uri)) {
2086 client->path_cache.insert(uri);
2164 auto client = get_client(user_data);
2177 update_html_parser(client, req, nullptr, 0, 1);
2178 ++client->complete;
2180 if (client->all_requests_processed()) {
2193 void print_stats(const HttpClient &client) {
2197 reqs.reserve(client.reqvec.size());
2198 for (const auto &req : client.reqvec) {
2233 const auto &base = client.timing.connect_end_time;
2363 HttpClient client{callbacks, loop, ssl_ctx};
2377 client.add_request(std::get<0>(req), std::get<1>(req), std::get<2>(req),
2381 client.update_hostport();
2383 client.record_start_time();
2385 if (client.resolve_host(host, port) != 0) {
2389 client.record_domain_lookup_end_time();
2391 if (client.initiate_connection() != 0) {
2397 ev_set_userdata(loop, &client);
2411 client.output_har(outfile);
2423 if (client.success != client.reqvec.size()) {
2425 << client.reqvec.size() << ", processed=" << client.success
2429 print_stats(client);
2665 HTTP/2 client)"
2712 Use the specified client certificate file. The file
2714 --key=<KEY> Use the client private key file. The file must be in
2768 The number of concurrent pushed streams this client