Lines Matching defs:conn
223 SSL *conn,
230 s->ssl = SSL_new_stream(conn, flags);
258 nghttp3_conn *conn;
271 if(h3->conn)
272 nghttp3_conn_del(h3->conn);
469 cf->conn->bits.multiplex = TRUE; /* at least potentially multiplexed */
470 cf->conn->httpversion = 30;
471 cf->conn->bundle->multiuse = BUNDLE_MULTIPLEX;
547 if(ctx->h3.conn && !stream->closed) {
548 nghttp3_conn_shutdown_stream_read(ctx->h3.conn, stream->s.id);
549 nghttp3_conn_close_stream(ctx->h3.conn, stream->s.id,
551 nghttp3_conn_set_stream_user_data(ctx->h3.conn, stream->s.id, NULL);
587 if((sdata->conn == data->conn) && H3_STREAM_ID(sdata) == stream_id) {
624 static int cb_h3_stream_close(nghttp3_conn *conn, int64_t stream_id,
631 (void)conn;
688 static int cb_h3_recv_data(nghttp3_conn *conn, int64_t stream3_id,
697 (void)conn;
716 static int cb_h3_deferred_consume(nghttp3_conn *conn, int64_t stream_id,
724 (void)conn;
732 static int cb_h3_recv_header(nghttp3_conn *conn, int64_t stream_id,
743 (void)conn;
794 static int cb_h3_end_headers(nghttp3_conn *conn, int64_t stream_id,
801 (void)conn;
823 static int cb_h3_stop_sending(nghttp3_conn *conn, int64_t stream_id,
830 (void)conn;
841 static int cb_h3_reset_stream(nghttp3_conn *conn, int64_t stream_id,
848 (void)conn;
863 cb_h3_read_req_body(nghttp3_conn *conn, int64_t stream_id,
874 (void)conn;
928 static int cb_h3_acked_stream_data(nghttp3_conn *conn, int64_t stream_id,
952 int rv = nghttp3_conn_resume_stream(conn, stream_id);
978 static CURLcode cf_osslq_h3conn_init(struct cf_osslq_ctx *ctx, SSL *conn,
986 rc = nghttp3_conn_client_new(&h3->conn,
996 result = cf_osslq_stream_open(&h3->s_ctrl, conn,
1003 result = cf_osslq_stream_open(&h3->s_qpack_enc, conn,
1010 result = cf_osslq_stream_open(&h3->s_qpack_dec, conn,
1018 rc = nghttp3_conn_bind_control_stream(h3->conn, h3->s_ctrl.id);
1023 rc = nghttp3_conn_bind_qpack_streams(h3->conn, h3->s_qpack_enc.id,
1206 nread = nghttp3_conn_read_stream(ctx->h3.conn, s->id,
1234 rv = nghttp3_conn_close_stream(ctx->h3.conn, s->id, app_error);
1244 rv = nghttp3_conn_close_stream(ctx->h3.conn, s->id,
1290 if(ctx->h3.conn) {
1299 if(ctx->h3.conn) {
1305 if(sdata->conn == data->conn && CURL_WANT_RECV(sdata)) {
1330 if(ctx->h3.conn) {
1332 if(sdata->conn == data->conn) {
1336 nghttp3_conn_unblock_stream(ctx->h3.conn, stream->s.id);
1353 if(!ctx->tls.ssl || !ctx->h3.conn)
1366 n = nghttp3_conn_writev_stream(ctx->h3.conn, &stream_id, &eos,
1414 nghttp3_conn_block_stream(ctx->h3.conn, s->id);
1429 rv = nghttp3_conn_add_write_offset(ctx->h3.conn, s->id, acked_len);
1436 rv = nghttp3_conn_add_ack_offset(ctx->h3.conn, s->id, acked_len);
1578 cf->conn->alpn = CURL_HTTP_VERSION_3;
1580 connkeep(cf->conn, "HTTP/3 default");
1734 rc = nghttp3_conn_submit_request(ctx->h3.conn, stream->s.id,
1780 DEBUGASSERT(ctx->h3.conn);
1848 (void)nghttp3_conn_resume_stream(ctx->h3.conn, stream->s.id);
1920 DEBUGASSERT(ctx->h3.conn);
2026 (void)nghttp3_conn_resume_stream(ctx->h3.conn, stream->s.id);
2173 struct connectdata *conn,
2192 result = Curl_cf_udp_create(&udp_cf, data, conn, ai, TRNSPRT_QUIC);
2196 cf->conn = conn;
2197 udp_cf->conn = cf->conn;
2213 const struct connectdata *conn,
2216 struct Curl_cfilter *cf = conn? conn->cfilter[sockindex] : NULL;