Lines Matching refs:Client
207 auto client = static_cast<Client *>(w->data);
210 if (rv == Client::ERR_CONNECT_FAIL) {
233 auto client = static_cast<Client *>(w->data);
262 std::make_unique<Client>(worker->next_client_id++, worker, req_todo);
337 auto client = static_cast<Client *>(w->data);
387 auto client = static_cast<Client *>(w->data);
399 bool check_stop_client_request_timeout(Client *client, ev_timer *w) {
412 auto client = static_cast<Client *>(w->data);
453 Client::Client(uint32_t id, Worker *worker, size_t req_todo)
514 Client::~Client() {
531 int Client::do_read() { return readfn(*this); }
532 int Client::do_write() { return writefn(*this); }
534 int Client::make_socket(addrinfo *addr) {
607 int Client::connect() {
660 readfn = &Client::read_quic;
661 writefn = &Client::write_quic;
664 writefn = &Client::connected;
670 void Client::timeout() {
676 void Client::restart_timeout() {
682 int Client::try_again_or_fail() {
712 void Client::fail() {
718 void Client::disconnect() {
763 int Client::submit_request() {
787 void Client::process_timedout_streams() {
804 void Client::process_abandoned_streams() {
818 void Client::process_request_failure() {
890 void Client::report_tls_info() {
900 void Client::report_app_info() {
907 void Client::terminate_session() {
920 void Client::on_request(int32_t stream_id) { streams[stream_id] = Stream(); }
922 void Client::on_header(int32_t stream_id, const uint8_t *name, size_t namelen,
970 void Client::on_status_code(int32_t stream_id, uint16_t status) {
997 void Client::on_stream_close(int32_t stream_id, bool success, bool final) {
1086 RequestStat *Client::get_req_stat(int32_t stream_id) {
1095 int Client::connection_made() {
1241 int Client::on_read(const uint8_t *data, size_t len) {
1253 int Client::on_write() {
1264 int Client::read_clear() {
1290 int Client::write_clear() {
1324 int Client::connected() {
1334 readfn = &Client::tls_handshake;
1335 writefn = &Client::tls_handshake;
1340 readfn = &Client::read_clear;
1341 writefn = &Client::write_clear;
1350 int Client::tls_handshake() {
1371 readfn = &Client::read_tls;
1372 writefn = &Client::write_tls;
1381 int Client::read_tls() {
1408 int Client::write_tls() {
1450 int Client::write_udp(const sockaddr *addr, socklen_t addrlen,
1494 void Client::record_request_time(RequestStat *req_stat) {
1499 void Client::record_connect_start_time() {
1503 void Client::record_connect_time() {
1507 void Client::record_ttfb() {
1515 void Client::clear_connect_times() {
1521 void Client::record_client_start_time() {
1531 void Client::record_client_end_time() {
1537 void Client::signal_write() { ev_io_start(worker->loop, &wev); }
1539 void Client::try_new_connection() { new_connection_requested = true; }
1619 void Worker::free_client(Client *deleted_client) {
1640 auto client = std::make_unique<Client>(next_client_id++, this, req_todo);