Lines Matching refs:h2
173 nghttp2_session *h2; member
198 if(ctx->h2) { in cf_h2_proxy_ctx_clear()
199 nghttp2_session_del(ctx->h2); in cf_h2_proxy_ctx_clear()
294 rc = nghttp2_session_client_new3(&ctx->h2, cbs, cf, o, &mem); in proxy_h2_client_new()
299 static ssize_t on_session_send(nghttp2_session *h2,
334 DEBUGASSERT(!ctx->h2); in cf_h2_proxy_ctx_init()
378 rc = nghttp2_submit_settings(ctx->h2, NGHTTP2_FLAG_NONE, iv, 3); in cf_h2_proxy_ctx_init()
387 rc = nghttp2_session_set_local_window_size(ctx->h2, NGHTTP2_FLAG_NONE, 0, in cf_h2_proxy_ctx_init()
409 return !nghttp2_session_want_read(ctx->h2) && in proxy_h2_should_close_session()
410 !nghttp2_session_want_write(ctx->h2); in proxy_h2_should_close_session()
454 rv = nghttp2_session_mem_recv(ctx->h2, (const uint8_t *)buf, blen); in proxy_h2_process_pending_input()
532 while(!rv && !ctx->nw_out_blocked && nghttp2_session_want_write(ctx->h2)) in proxy_h2_progress_egress()
533 rv = nghttp2_session_send(ctx->h2); in proxy_h2_progress_egress()
543 static ssize_t on_session_send(nghttp2_session *h2, in on_session_send() argument
553 (void)h2; in on_session_send()
899 nghttp2_session *h2, in proxy_h2_submit() argument
929 stream_id = nghttp2_submit_request(h2, pri_spec, nva, nheader, in proxy_h2_submit()
933 stream_id = nghttp2_submit_request(h2, pri_spec, nva, nheader, in proxy_h2_submit()
969 result = proxy_h2_submit(&ts->stream_id, cf, data, ctx->h2, req, in submit_CONNECT()
1114 if(!ctx->h2) { in cf_h2_proxy_connect()
1180 if(!cf->connected || !ctx->h2 || cf->shutdown || ctx->conn_closed) { in cf_h2_proxy_shutdown()
1188 rv = nghttp2_submit_goaway(ctx->h2, NGHTTP2_FLAG_NONE, in cf_h2_proxy_shutdown()
1202 if(nghttp2_session_want_write(ctx->h2)) in cf_h2_proxy_shutdown()
1204 if(!result && nghttp2_session_want_read(ctx->h2)) in cf_h2_proxy_shutdown()
1208 (!result && !nghttp2_session_want_write(ctx->h2) && in cf_h2_proxy_shutdown()
1209 !nghttp2_session_want_read(ctx->h2))); in cf_h2_proxy_shutdown()
1236 if(!cf->connected && ctx->h2) { in cf_h2_proxy_adjust_pollset()
1237 want_send = nghttp2_session_want_write(ctx->h2) || in cf_h2_proxy_adjust_pollset()
1240 want_recv = nghttp2_session_want_read(ctx->h2); in cf_h2_proxy_adjust_pollset()
1245 if(ctx->h2 && (want_recv || want_send)) { in cf_h2_proxy_adjust_pollset()
1249 c_exhaust = !nghttp2_session_get_remote_window_size(ctx->h2); in cf_h2_proxy_adjust_pollset()
1252 ctx->h2, ctx->tunnel.stream_id); in cf_h2_proxy_adjust_pollset()
1255 (!c_exhaust && nghttp2_session_want_write(ctx->h2)) || in cf_h2_proxy_adjust_pollset()
1267 want_send = nghttp2_session_want_write(ctx->h2) || in cf_h2_proxy_adjust_pollset()
1270 want_recv = nghttp2_session_want_read(ctx->h2); in cf_h2_proxy_adjust_pollset()
1376 nghttp2_session_consume(ctx->h2, ctx->tunnel.stream_id, (size_t)nread); in cf_h2_proxy_recv()
1429 rv = nghttp2_session_resume_data(ctx->h2, ctx->tunnel.stream_id); in cf_h2_proxy_send()
1478 ctx->h2, ctx->tunnel.stream_id), in cf_h2_proxy_send()
1479 nghttp2_session_get_remote_window_size(ctx->h2), in cf_h2_proxy_send()
1496 int rv = nghttp2_session_resume_data(ctx->h2, ctx->tunnel.stream_id); in cf_h2_proxy_flush()
1510 ctx->h2, ctx->tunnel.stream_id), in cf_h2_proxy_flush()
1511 nghttp2_session_get_remote_window_size(ctx->h2), in cf_h2_proxy_flush()
1564 result = (ctx && ctx->h2 && proxy_h2_connisalive(cf, data, input_pending)); in cf_h2_proxy_is_alive()
