Lines Matching refs:stream_id
451 curl_int64_t stream_id = (curl_int64_t)SSL_get_stream_id(stream_ssl); in cf_osslq_h3conn_add_stream() local
456 stream_id); in cf_osslq_h3conn_add_stream()
463 nstream->id = stream_id; in cf_osslq_h3conn_add_stream()
467 stream_id); in cf_osslq_h3conn_add_stream()
472 " stream", stream_id); in cf_osslq_h3conn_add_stream()
668 int64_t stream_id) in cf_osslq_get_qstream() argument
673 if(stream && stream->s.id == stream_id) { in cf_osslq_get_qstream()
676 else if(ctx->h3.s_ctrl.id == stream_id) { in cf_osslq_get_qstream()
679 else if(ctx->h3.s_qpack_enc.id == stream_id) { in cf_osslq_get_qstream()
682 else if(ctx->h3.s_qpack_dec.id == stream_id) { in cf_osslq_get_qstream()
693 if(stream && stream->s.id == stream_id) { in cf_osslq_get_qstream()
730 static int cb_h3_stream_close(nghttp3_conn *conn, int64_t stream_id, in cb_h3_stream_close() argument
739 (void)stream_id; in cb_h3_stream_close()
825 static int cb_h3_deferred_consume(nghttp3_conn *conn, int64_t stream_id, in cb_h3_deferred_consume() argument
835 (void)stream_id; in cb_h3_deferred_consume()
848 curl_int64_t stream_id = sid; in cb_h3_recv_header() local
856 (void)stream_id; in cb_h3_recv_header()
875 CURL_TRC_CF(data, cf, "[%" FMT_PRId64 "] status: %s", stream_id, line); in cb_h3_recv_header()
884 stream_id, (int)h3name.len, h3name.base, in cb_h3_recv_header()
912 curl_int64_t stream_id = sid; in cb_h3_end_headers() local
916 (void)stream_id; in cb_h3_end_headers()
929 stream_id, stream->status_code); in cb_h3_end_headers()
944 curl_int64_t stream_id = sid; in cb_h3_stop_sending() local
952 CURL_TRC_CF(data, cf, "[%" FMT_PRId64 "] stop_sending", stream_id); in cb_h3_stop_sending()
963 curl_int64_t stream_id = sid; in cb_h3_reset_stream() local
972 CURL_TRC_CF(data, cf, "[%" FMT_PRId64 "] reset -> %d", stream_id, rv); in cb_h3_reset_stream()
981 cb_h3_read_req_body(nghttp3_conn *conn, int64_t stream_id, in cb_h3_read_req_body() argument
994 (void)stream_id; in cb_h3_read_req_body()
1046 static int cb_h3_acked_stream_data(nghttp3_conn *conn, int64_t stream_id, in cb_h3_acked_stream_data() argument
1071 int rv = nghttp3_conn_resume_stream(conn, stream_id); in cb_h3_acked_stream_data()
1500 int64_t stream_id; in h3_send_streams() local
1506 n = nghttp3_conn_writev_stream(ctx->h3.conn, &stream_id, &eos, in h3_send_streams()
1514 if(stream_id < 0) { in h3_send_streams()
1520 s = cf_osslq_get_qstream(cf, data, stream_id); in h3_send_streams()
1523 FMT_PRId64, (curl_int64_t)stream_id); in h3_send_streams()
1528 DEBUGASSERT(s->id == stream_id); in h3_send_streams()
