Lines Matching refs:stream_id
291 int64_t stream_id, in get_stream_easy() argument
299 if(stream && stream->id == stream_id) { in get_stream_easy()
311 if(stream && stream->id == stream_id) { in get_stream_easy()
369 static int cb_h3_acked_req_body(nghttp3_conn *conn, int64_t stream_id,
507 curl_int64_t stream_id = (curl_int64_t)sid; in cb_recv_stream_data() local
515 nghttp3_conn_read_stream(ctx->h3conn, stream_id, buf, buflen, fin); in cb_recv_stream_data()
520 stream_id, buflen, nconsumed); in cb_recv_stream_data()
522 struct h3_stream_ctx *stream = H3_STREAM_CTX_ID(ctx, stream_id); in cb_recv_stream_data()
526 stream_id, stream->reset, stream->closed); in cb_recv_stream_data()
534 ngtcp2_conn_extend_max_stream_offset(tconn, stream_id, (uint64_t)nconsumed); in cb_recv_stream_data()
541 cb_acked_stream_data_offset(ngtcp2_conn *tconn, int64_t stream_id, in cb_acked_stream_data_offset() argument
548 (void)stream_id; in cb_acked_stream_data_offset()
554 rv = nghttp3_conn_add_ack_offset(ctx->h3conn, stream_id, datalen); in cb_acked_stream_data_offset()
569 curl_int64_t stream_id = (curl_int64_t)sid; in cb_stream_close() local
583 rv = nghttp3_conn_close_stream(ctx->h3conn, stream_id, app_error_code); in cb_stream_close()
585 FMT_PRIu64 ") -> %d", stream_id, (curl_uint64_t)app_error_code, in cb_stream_close()
601 curl_int64_t stream_id = (curl_int64_t)sid; in cb_stream_reset() local
609 rv = nghttp3_conn_shutdown_stream_read(ctx->h3conn, stream_id); in cb_stream_reset()
610 CURL_TRC_CF(data, cf, "[%" FMT_PRId64 "] reset -> %d", stream_id, rv); in cb_stream_reset()
618 static int cb_stream_stop_sending(ngtcp2_conn *tconn, int64_t stream_id, in cb_stream_stop_sending() argument
629 rv = nghttp3_conn_shutdown_stream_read(ctx->h3conn, stream_id); in cb_stream_stop_sending()
660 curl_int64_t stream_id = (curl_int64_t)sid; in cb_extend_max_stream_data() local
669 rv = nghttp3_conn_unblock_stream(ctx->h3conn, stream_id); in cb_extend_max_stream_data()
673 s_data = get_stream_easy(cf, data, stream_id, &stream); in cb_extend_max_stream_data()
675 CURL_TRC_CF(s_data, cf, "[%" FMT_PRId64 "] unblock quic flow", stream_id); in cb_extend_max_stream_data()
881 curl_int64_t stream_id = (curl_int64_t)sid; in cb_h3_stream_close() local
884 (void)stream_id; in cb_h3_stream_close()
985 curl_int64_t stream_id = (curl_int64_t)sid; in cb_h3_end_headers() local
988 (void)stream_id; in cb_h3_end_headers()
998 stream_id, stream->status_code); in cb_h3_end_headers()
1013 curl_int64_t stream_id = (curl_int64_t)sid; in cb_h3_recv_header() local
1020 (void)stream_id; in cb_h3_recv_header()
1046 stream_id, Curl_dyn_ptr(&ctx->scratch)); in cb_h3_recv_header()
1054 stream_id, (int)h3name.len, h3name.base, in cb_h3_recv_header()
1073 static int cb_h3_stop_sending(nghttp3_conn *conn, int64_t stream_id, in cb_h3_stop_sending() argument
1083 rv = ngtcp2_conn_shutdown_stream_read(ctx->qconn, 0, stream_id, in cb_h3_stop_sending()
1097 curl_int64_t stream_id = (curl_int64_t)sid; in cb_h3_reset_stream() local
1103 rv = ngtcp2_conn_shutdown_stream_write(ctx->qconn, 0, stream_id, in cb_h3_reset_stream()
1105 CURL_TRC_CF(data, cf, "[%" FMT_PRId64 "] reset -> %d", stream_id, rv); in cb_h3_reset_stream()
1284 static int cb_h3_acked_req_body(nghttp3_conn *conn, int64_t stream_id, in cb_h3_acked_req_body() argument
1309 int rv = nghttp3_conn_resume_stream(conn, stream_id); in cb_h3_acked_req_body()
1318 cb_h3_read_req_body(nghttp3_conn *conn, int64_t stream_id, in cb_h3_read_req_body() argument
1331 (void)stream_id; in cb_h3_read_req_body()
1697 int64_t stream_id; in read_pkt_to_send() local
1701 stream_id = -1; in read_pkt_to_send()
1716 veccnt = nghttp3_conn_writev_stream(ctx->h3conn, &stream_id, &fin, vec, in read_pkt_to_send()
1731 &ndatalen, flags, stream_id, in read_pkt_to_send()
1744 nghttp3_conn_block_stream(ctx->h3conn, stream_id); in read_pkt_to_send()
1746 (curl_int64_t)stream_id); in read_pkt_to_send()
1755 nghttp3_conn_shutdown_stream_write(ctx->h3conn, stream_id); in read_pkt_to_send()
1777 int rv = nghttp3_conn_add_write_offset(ctx->h3conn, stream_id, ndatalen); in read_pkt_to_send()
