Lines Matching defs:stream_id
231 int64_t stream_id)
236 if(H3_STREAM_ID(data) == stream_id) {
242 if((sdata->conn == data->conn) && H3_STREAM_ID(sdata) == stream_id) {
305 static int cb_h3_acked_req_body(nghttp3_conn *conn, int64_t stream_id,
421 int64_t stream_id, uint64_t offset,
434 nghttp3_conn_read_stream(ctx->h3conn, stream_id, buf, buflen, fin);
436 stream_id, buflen, nconsumed);
441 "used by us, ignored", stream_id);
453 ngtcp2_conn_extend_max_stream_offset(tconn, stream_id, nconsumed);
460 cb_acked_stream_data_offset(ngtcp2_conn *tconn, int64_t stream_id,
467 (void)stream_id;
473 rv = nghttp3_conn_add_ack_offset(ctx->h3conn, stream_id, datalen);
511 static int cb_stream_reset(ngtcp2_conn *tconn, int64_t stream_id,
524 rv = nghttp3_conn_shutdown_stream_read(ctx->h3conn, stream_id);
525 CURL_TRC_CF(data, cf, "[%" PRId64 "] reset -> %d", stream_id, rv);
533 static int cb_stream_stop_sending(ngtcp2_conn *tconn, int64_t stream_id,
544 rv = nghttp3_conn_shutdown_stream_read(ctx->h3conn, stream_id);
563 static int cb_extend_max_stream_data(ngtcp2_conn *tconn, int64_t stream_id,
577 rv = nghttp3_conn_unblock_stream(ctx->h3conn, stream_id);
581 s_data = get_stream_easy(cf, data, stream_id);
584 CURL_TRC_CF(data, cf, "[%" PRId64 "] unblock quic flow", stream_id);
770 static int cb_h3_stream_close(nghttp3_conn *conn, int64_t stream_id,
778 (void)stream_id;
876 static int cb_h3_end_headers(nghttp3_conn *conn, int64_t stream_id,
884 (void)stream_id;
897 stream_id, stream->status_code);
905 static int cb_h3_recv_header(nghttp3_conn *conn, int64_t stream_id,
917 (void)stream_id;
936 CURL_TRC_CF(data, cf, "[%" PRId64 "] status: %s", stream_id, line);
945 stream_id, (int)h3name.len, h3name.base,
967 static int cb_h3_stop_sending(nghttp3_conn *conn, int64_t stream_id,
977 rv = ngtcp2_conn_shutdown_stream_read(ctx->qconn, 0, stream_id,
986 static int cb_h3_reset_stream(nghttp3_conn *conn, int64_t stream_id,
996 rv = ngtcp2_conn_shutdown_stream_write(ctx->qconn, 0, stream_id,
998 CURL_TRC_CF(data, cf, "[%" PRId64 "] reset -> %d", stream_id, rv);
1198 static int cb_h3_acked_req_body(nghttp3_conn *conn, int64_t stream_id,
1222 int rv = nghttp3_conn_resume_stream(conn, stream_id);
1231 cb_h3_read_req_body(nghttp3_conn *conn, int64_t stream_id,
1243 (void)stream_id;
1641 int64_t stream_id;
1645 stream_id = -1;
1660 veccnt = nghttp3_conn_writev_stream(ctx->h3conn, &stream_id, &fin, vec,
1677 &ndatalen, flags, stream_id,
1690 nghttp3_conn_block_stream(ctx->h3conn, stream_id);
1692 stream_id);
1701 nghttp3_conn_shutdown_stream_write(ctx->h3conn, stream_id);
1723 int rv = nghttp3_conn_add_write_offset(ctx->h3conn, stream_id, ndatalen);