Lines Matching refs:h2r
232 static request_st * h2_init_stream (request_st * const h2r, connection * const con);
1008 request_st * const h2r = &con->request; in h2_recv_data() local
1009 if (h2r->h2_rwin <= 0 && 0 != alen) { /*(always proceed if 0 == alen)*/ in h2_recv_data()
1044 h2_send_window_update_unit(con, h2r, len); /*(h2r->h2_rwin)*/ in h2_recv_data()
1058 h2_send_window_update_unit(con, h2r, len); /*(h2r->h2_rwin)*/ in h2_recv_data()
1083 h2_send_window_update_unit(con, h2r, len); /*(h2r->h2_rwin)*/ in h2_recv_data()
1526 request_st * const h2r = &con->request; in h2_recv_headers() local
1539 r = h2_init_stream(h2r, con); in h2_recv_headers()
1947 h2_init_con (request_st * const restrict h2r, connection * const restrict con, const buffer * const… in h2_init_con() argument
1951 con->keep_alive_idle = h2r->conf.max_keep_alive_idle; in h2_init_con()
1953 h2r->h2_rwin = 262144; /* h2 connection recv window (256k)*/ in h2_init_con()
1954 h2r->h2_swin = 65535; /* h2 connection send window */ in h2_init_con()
1955 h2r->h2_rwin_fudge = 0; in h2_init_con()
2023 buffer_string_prepare_copy(h2r->tmp_buf, 65535); in h2_init_con()
2571 request_st * const h2r = &con->request;
2573 if (h2r->h2_swin < 0) return 0;
2575 if ((int32_t)dlen > h2r->h2_swin) dlen = (uint32_t)h2r->h2_swin;
2578 h2r->h2_swin -= (int32_t)dlen;
2645 request_st * const h2r = &con->request; in h2_send_cqdata() local
2647 if (h2r->h2_swin < 0) return 0; in h2_send_cqdata()
2649 if ((int32_t)dlen > h2r->h2_swin) dlen = (uint32_t)h2r->h2_swin; in h2_send_cqdata()
2712 h2r->h2_swin -= (int32_t)sent; in h2_send_cqdata()
2780 h2_init_stream (request_st * const h2r, connection * const con) in h2_init_stream() argument
2802 r->conditional_is_valid = h2r->conditional_is_valid; in h2_init_stream()
2803 memcpy(r->cond_cache, h2r->cond_cache, used * sizeof(cond_cache_t)); in h2_init_stream()
2806 memcpy(r->cond_match, h2r->cond_match, in h2_init_stream()
2810 r->server_name = h2r->server_name; in h2_init_stream()
2811 memcpy(&r->conf, &h2r->conf, sizeof(request_config)); in h2_init_stream()
2865 h2_retire_con (request_st * const h2r, connection * const con) in h2_retire_con() argument
2870 if (h2r->state != CON_STATE_ERROR) { /*(CON_STATE_RESPONSE_END)*/ in h2_retire_con()
2891 if (h2r->conf.global_bytes_per_second_cnt_ptr) in h2_retire_con()
2892 *(h2r->conf.global_bytes_per_second_cnt_ptr) += written; in h2_retire_con()
2913 h2_con_upgrade_h2c (request_st * const h2r, const buffer * const http2_settings) in h2_con_upgrade_h2c() argument
2923 chunkqueue_append_mem(&h2r->write_queue, in h2_con_upgrade_h2c()
2925 h2r->resp_header_len = sizeof(switch_proto)-1; in h2_con_upgrade_h2c()
2927 h2r->http_status = 101; in h2_con_upgrade_h2c()
2928 http_header_response_set(h2r, HTTP_HEADER_UPGRADE, CONST_STR_LEN("Upgrade"), in h2_con_upgrade_h2c()
2930 http_response_write_header(h2r); in h2_con_upgrade_h2c()
2931 http_response_reset(h2r); in h2_con_upgrade_h2c()
2932 h2r->http_status = 0; in h2_con_upgrade_h2c()
2935 connection * const con = h2r->con; in h2_con_upgrade_h2c()
2936 h2_init_con(h2r, con, http2_settings); in h2_con_upgrade_h2c()
2945 request_st * const r = h2_init_stream(h2r, con); in h2_con_upgrade_h2c()
2950 r->http_method = h2r->http_method; in h2_con_upgrade_h2c()
2953 r->rqst_htags = h2r->rqst_htags; in h2_con_upgrade_h2c()
2954 h2r->rqst_htags = 0; in h2_con_upgrade_h2c()
2955 r->rqst_header_len = h2r->rqst_header_len; in h2_con_upgrade_h2c()
2956 h2r->rqst_header_len = 0; in h2_con_upgrade_h2c()
2957 r->rqst_headers = h2r->rqst_headers; /* copy struct */ in h2_con_upgrade_h2c()
2958 memset(&h2r->rqst_headers, 0, sizeof(array)); in h2_con_upgrade_h2c()
2959 r->uri = h2r->uri; /* copy struct */ in h2_con_upgrade_h2c()
2961 r->physical = h2r->physical; /* copy struct */ in h2_con_upgrade_h2c()
2962 r->env = h2r->env; /* copy struct */ in h2_con_upgrade_h2c()
2964 memset(&h2r->rqst_headers, 0, sizeof(array)); in h2_con_upgrade_h2c()
2965 memset(&h2r->uri, 0, sizeof(request_uri)); in h2_con_upgrade_h2c()
2967 memset(&h2r->physical, 0, sizeof(physical)); in h2_con_upgrade_h2c()
2968 memset(&h2r->env, 0, sizeof(array)); in h2_con_upgrade_h2c()
2971 r->reqbody_length = h2r->reqbody_length; /* currently always 0 */ in h2_con_upgrade_h2c()
2972 r->te_chunked = h2r->te_chunked; /* must be 0 */ in h2_con_upgrade_h2c()
2973 r->resp_body_scratchpad = h2r->resp_body_scratchpad; /*(not started yet)*/ in h2_con_upgrade_h2c()
2974 swap(&r->reqbody_queue,&h2r->reqbody_queue);/*currently always empty queue*/ in h2_con_upgrade_h2c()
2976 r->http_host = h2r->http_host; in h2_con_upgrade_h2c()
2977 h2r->http_host = NULL; in h2_con_upgrade_h2c()
2979 r->server_name = h2r->server_name; in h2_con_upgrade_h2c()
2980 h2r->server_name = &h2r->uri.authority; /*(is not null)*/ in h2_con_upgrade_h2c()
2982 r->target = h2r->target; /* copy struct */ in h2_con_upgrade_h2c()
2983 r->target_orig = h2r->target_orig; /* copy struct */ in h2_con_upgrade_h2c()
2985 r->pathinfo = h2r->pathinfo; /* copy struct */ in h2_con_upgrade_h2c()
2986 r->server_name_buf = h2r->server_name_buf; /* copy struct */ in h2_con_upgrade_h2c()
2988 memset(&h2r->target, 0, sizeof(buffer)); in h2_con_upgrade_h2c()
2989 memset(&h2r->target_orig, 0, sizeof(buffer)); in h2_con_upgrade_h2c()
2991 memset(&h2r->pathinfo, 0, sizeof(buffer)); in h2_con_upgrade_h2c()
2992 memset(&h2r->server_name_buf, 0, sizeof(buffer)); in h2_con_upgrade_h2c()
3002 r->loops_per_request = h2r->loops_per_request; in h2_con_upgrade_h2c()
3003 r->async_callback = h2r->async_callback; in h2_con_upgrade_h2c()
3005 r->keep_alive = h2r->keep_alive; in h2_con_upgrade_h2c()
3006 r->tmp_buf = h2r->tmp_buf; /* shared; same as srv->tmp_buf */ in h2_con_upgrade_h2c()
3007 r->start_hp = h2r->start_hp; /* copy struct */ in h2_con_upgrade_h2c()