Lines Matching refs:h3
268 static void cf_osslq_h3conn_cleanup(struct cf_osslq_h3conn *h3) in cf_osslq_h3conn_cleanup() argument
272 if(h3->conn) in cf_osslq_h3conn_cleanup()
273 nghttp3_conn_del(h3->conn); in cf_osslq_h3conn_cleanup()
274 cf_osslq_stream_cleanup(&h3->s_ctrl); in cf_osslq_h3conn_cleanup()
275 cf_osslq_stream_cleanup(&h3->s_qpack_enc); in cf_osslq_h3conn_cleanup()
276 cf_osslq_stream_cleanup(&h3->s_qpack_dec); in cf_osslq_h3conn_cleanup()
277 for(i = 0; i < h3->remote_ctrl_n; ++i) { in cf_osslq_h3conn_cleanup()
278 cf_osslq_stream_cleanup(&h3->remote_ctrl[i]); in cf_osslq_h3conn_cleanup()
287 struct cf_osslq_h3conn h3; member
329 cf_osslq_h3conn_cleanup(&ctx->h3); in cf_osslq_ctx_close()
445 static CURLcode cf_osslq_h3conn_add_stream(struct cf_osslq_h3conn *h3, in cf_osslq_h3conn_add_stream() argument
453 if(h3->remote_ctrl_n >= ARRAYSIZE(h3->remote_ctrl)) { in cf_osslq_h3conn_add_stream()
462 struct cf_osslq_stream *nstream = &h3->remote_ctrl[h3->remote_ctrl_n++]; in cf_osslq_h3conn_add_stream()
654 if(ctx->h3.conn && !stream->closed) { in h3_data_done()
655 nghttp3_conn_shutdown_stream_read(ctx->h3.conn, stream->s.id); in h3_data_done()
656 nghttp3_conn_close_stream(ctx->h3.conn, stream->s.id, in h3_data_done()
658 nghttp3_conn_set_stream_user_data(ctx->h3.conn, stream->s.id, NULL); in h3_data_done()
676 else if(ctx->h3.s_ctrl.id == stream_id) { in cf_osslq_get_qstream()
677 return &ctx->h3.s_ctrl; in cf_osslq_get_qstream()
679 else if(ctx->h3.s_qpack_enc.id == stream_id) { in cf_osslq_get_qstream()
680 return &ctx->h3.s_qpack_enc; in cf_osslq_get_qstream()
682 else if(ctx->h3.s_qpack_dec.id == stream_id) { in cf_osslq_get_qstream()
683 return &ctx->h3.s_qpack_dec; in cf_osslq_get_qstream()
1100 struct cf_osslq_h3conn *h3 = &ctx->h3; in cf_osslq_h3conn_init() local
1104 nghttp3_settings_default(&h3->settings); in cf_osslq_h3conn_init()
1105 rc = nghttp3_conn_client_new(&h3->conn, in cf_osslq_h3conn_init()
1107 &h3->settings, in cf_osslq_h3conn_init()
1115 result = cf_osslq_stream_open(&h3->s_ctrl, conn, in cf_osslq_h3conn_init()
1122 result = cf_osslq_stream_open(&h3->s_qpack_enc, conn, in cf_osslq_h3conn_init()
1129 result = cf_osslq_stream_open(&h3->s_qpack_dec, conn, in cf_osslq_h3conn_init()
1137 rc = nghttp3_conn_bind_control_stream(h3->conn, h3->s_ctrl.id); in cf_osslq_h3conn_init()
1142 rc = nghttp3_conn_bind_qpack_streams(h3->conn, h3->s_qpack_enc.id, in cf_osslq_h3conn_init()
1143 h3->s_qpack_dec.id); in cf_osslq_h3conn_init()
1342 nread = nghttp3_conn_read_stream(ctx->h3.conn, s->id, in cf_osslq_stream_recv()
1370 rv = nghttp3_conn_close_stream(ctx->h3.conn, s->id, app_error); in cf_osslq_stream_recv()
1380 rv = nghttp3_conn_close_stream(ctx->h3.conn, s->id, in cf_osslq_stream_recv()
1419 (void)cf_osslq_h3conn_add_stream(&ctx->h3, snew, cf, data); in cf_progress_ingress()
1427 if(ctx->h3.conn) { in cf_progress_ingress()
1429 for(i = 0; i < ctx->h3.remote_ctrl_n; ++i) { in cf_progress_ingress()
1430 result = cf_osslq_stream_recv(&ctx->h3.remote_ctrl[i], cf, data); in cf_progress_ingress()
1436 if(ctx->h3.conn) { in cf_progress_ingress()
1467 if(ctx->h3.conn) { in cf_osslq_check_and_unblock()
1475 nghttp3_conn_unblock_stream(ctx->h3.conn, stream->s.id); in cf_osslq_check_and_unblock()
1492 if(!ctx->tls.ossl.ssl || !ctx->h3.conn) in h3_send_streams()
1505 n = nghttp3_conn_writev_stream(ctx->h3.conn, &stream_id, &eos, in h3_send_streams()
1556 nghttp3_conn_block_stream(ctx->h3.conn, s->id); in h3_send_streams()
1572 rv = nghttp3_conn_add_write_offset(ctx->h3.conn, s->id, acked_len); in h3_send_streams()
1579 rv = nghttp3_conn_add_ack_offset(ctx->h3.conn, s->id, acked_len); in h3_send_streams()
1874 rc = nghttp3_conn_submit_request(ctx->h3.conn, stream->s.id, in h3_stream_open()
1923 DEBUGASSERT(ctx->h3.conn); in cf_osslq_send()
1976 (void)nghttp3_conn_resume_stream(ctx->h3.conn, stream->s.id); in cf_osslq_send()
2038 DEBUGASSERT(ctx->h3.conn); in cf_osslq_recv()
2146 (void)nghttp3_conn_resume_stream(ctx->h3.conn, stream->s.id); in cf_osslq_data_event()
