Lines Matching refs:h2
129 nghttp2_session *h2; member
188 if(ctx->h2) { in cf_h2_ctx_close()
189 nghttp2_session_del(ctx->h2); in cf_h2_ctx_close()
302 ctx->h2, stream->id); in cf_h2_update_local_win()
304 rv = nghttp2_submit_window_update(ctx->h2, NGHTTP2_FLAG_NONE, in cf_h2_update_local_win()
316 rv = nghttp2_session_set_local_window_size(ctx->h2, NGHTTP2_FLAG_NONE, in cf_h2_update_local_win()
405 if(ctx->h2) { in http2_data_done()
408 (void)nghttp2_session_set_stream_user_data(ctx->h2, stream->id, NULL); in http2_data_done()
416 nghttp2_submit_rst_stream(ctx->h2, NGHTTP2_FLAG_NONE, in http2_data_done()
422 nghttp2_session_send(ctx->h2); in http2_data_done()
447 rc = nghttp2_session_client_new3(&ctx->h2, cbs, cf, o, &mem); in h2_client_new()
479 static ssize_t send_callback(nghttp2_session *h2,
513 DEBUGASSERT(!ctx->h2); in cf_h2_ctx_open()
565 rc = nghttp2_session_upgrade2(ctx->h2, binsettings, (size_t)binlen, in cf_h2_ctx_open()
575 rc = nghttp2_session_set_stream_user_data(ctx->h2, stream->id, in cf_h2_ctx_open()
589 rc = nghttp2_submit_settings(ctx->h2, NGHTTP2_FLAG_NONE, in cf_h2_ctx_open()
599 rc = nghttp2_session_set_local_window_size(ctx->h2, NGHTTP2_FLAG_NONE, 0, in cf_h2_ctx_open()
624 return ctx->drain_total == 0 && !nghttp2_session_want_read(ctx->h2) && in should_close_session()
625 !nghttp2_session_want_write(ctx->h2); in should_close_session()
644 rv = nghttp2_session_mem_recv(ctx->h2, (const uint8_t *)buf, blen); in h2_process_pending_input()
662 if(nghttp2_session_check_request_allowed(ctx->h2) == 0) { in h2_process_pending_input()
724 rc = nghttp2_submit_ping(ctx->h2, 0, ZERO_NULL); in http2_send_ping()
731 rc = nghttp2_session_send(ctx->h2); in http2_send_ping()
745 nghttp2_info *h2 = nghttp2_version(0); in Curl_http2_ver() local
746 (void)msnprintf(p, len, "nghttp2/%s", h2->version_str); in Curl_http2_ver()
777 static ssize_t send_callback(nghttp2_session *h2, in send_callback() argument
787 (void)h2; in send_callback()
1028 rv = nghttp2_session_set_stream_user_data(ctx->h2, in push_promise()
1085 nghttp2_submit_rst_stream(ctx->h2, 0, stream->id, in h2_xfer_write_resp()
1109 ctx->h2, stream->id), in on_stream_frame()
1111 ctx->h2, stream->id)); in on_stream_frame()
1114 rv = nghttp2_submit_rst_stream(ctx->h2, NGHTTP2_FLAG_NONE, in on_stream_frame()
1152 rv = nghttp2_submit_rst_stream(ctx->h2, NGHTTP2_FLAG_NONE, in on_stream_frame()
1178 rv = nghttp2_session_resume_data(ctx->h2, stream->id); in on_stream_frame()
1196 nghttp2_submit_rst_stream(ctx->h2, NGHTTP2_FLAG_NONE, in on_stream_frame()
1406 nghttp2_session_consume(ctx->h2, stream_id, len); in on_data_chunk_recv()
1900 rv = nghttp2_submit_priority(ctx->h2, NGHTTP2_FLAG_NONE, in h2_progress_egress()
1907 while(!rv && !ctx->nw_out_blocked && nghttp2_session_want_write(ctx->h2)) in h2_progress_egress()
1908 rv = nghttp2_session_send(ctx->h2); in h2_progress_egress()
2060 nghttp2_session_consume(ctx->h2, stream->id, (size_t)nread); in cf_h2_recv()
2084 ctx->h2, stream->id), in cf_h2_recv()
2086 ctx->h2, stream->id), in cf_h2_recv()
2087 nghttp2_session_get_local_window_size(ctx->h2), in cf_h2_recv()
2132 int rv = nghttp2_session_resume_data(ctx->h2, stream->id); in cf_h2_body_send()
2190 if(!nghttp2_session_check_request_allowed(ctx->h2)) in h2_submit()
2200 stream_id = nghttp2_submit_request(ctx->h2, &pri_spec, nva, nheader, in h2_submit()
2204 stream_id = nghttp2_submit_request(ctx->h2, &pri_spec, nva, nheader, in h2_submit()
2342 ctx->h2, stream->id), in cf_h2_send()
2343 nghttp2_session_get_remote_window_size(ctx->h2), in cf_h2_send()
2351 nghttp2_session_get_remote_window_size(ctx->h2), in cf_h2_send()
2369 int rv = nghttp2_session_resume_data(ctx->h2, stream->id); in cf_h2_flush()
2385 ctx->h2, stream->id), in cf_h2_flush()
2386 nghttp2_session_get_remote_window_size(ctx->h2), in cf_h2_flush()
2393 result, nghttp2_session_get_remote_window_size(ctx->h2), in cf_h2_flush()
2409 if(!ctx->h2) in cf_h2_adjust_pollset()
2419 c_exhaust = want_send && !nghttp2_session_get_remote_window_size(ctx->h2); in cf_h2_adjust_pollset()
2421 !nghttp2_session_get_stream_remote_window_size(ctx->h2, in cf_h2_adjust_pollset()
2425 (!c_exhaust && nghttp2_session_want_write(ctx->h2)) || in cf_h2_adjust_pollset()
2434 want_send = nghttp2_session_want_write(ctx->h2) || in cf_h2_adjust_pollset()
2436 want_recv = nghttp2_session_want_read(ctx->h2); in cf_h2_adjust_pollset()
2467 if(!ctx->h2) { in cf_h2_connect()
2531 if(!cf->connected || !ctx->h2 || cf->shutdown || ctx->conn_closed) { in cf_h2_shutdown()
2539 rv = nghttp2_submit_goaway(ctx->h2, NGHTTP2_FLAG_NONE, in cf_h2_shutdown()
2553 if(nghttp2_session_want_write(ctx->h2) || in cf_h2_shutdown()
2556 if(!result && nghttp2_session_want_read(ctx->h2)) in cf_h2_shutdown()
2563 (!result && !nghttp2_session_want_write(ctx->h2) && in cf_h2_shutdown()
2564 !nghttp2_session_want_read(ctx->h2) && in cf_h2_shutdown()
2581 if(ctx && ctx->h2 && stream) { in http2_data_pause()
2652 result = (ctx && ctx->h2 && http2_connisalive(cf, data, input_pending)); in cf_h2_is_alive()
2684 if(nghttp2_session_check_request_allowed(ctx->h2) == 0) { in cf_h2_query()
