Lines Matching refs:stream_id
586 newstream->stream_id = frame->promised_stream_id; in push_promise()
642 int32_t stream_id = frame->hd.stream_id; in on_frame_recv() local
645 if(!stream_id) { in on_frame_recv()
670 data_s = nghttp2_session_get_stream_user_data(session, stream_id); in on_frame_recv()
674 stream_id)); in on_frame_recv()
681 stream_id)); in on_frame_recv()
686 frame->hd.type, stream_id)); in on_frame_recv()
693 stream_id, NGHTTP2_PROTOCOL_ERROR); in on_frame_recv()
732 ncopy, stream_id, stream->mem)); in on_frame_recv()
760 frame->hd.type, stream_id)); in on_frame_recv()
767 int32_t stream_id, in on_data_chunk_recv() argument
778 DEBUGASSERT(stream_id); /* should never be a zero stream ID here */ in on_data_chunk_recv()
781 data_s = nghttp2_session_get_stream_user_data(session, stream_id); in on_data_chunk_recv()
805 nread, stream_id, in on_data_chunk_recv()
814 len - nread, stream_id)); in on_data_chunk_recv()
815 data_s->conn->proto.httpc.pause_stream_id = stream_id; in on_data_chunk_recv()
823 data_s->conn->proto.httpc.pause_stream_id = stream_id; in on_data_chunk_recv()
831 static int on_stream_close(nghttp2_session *session, int32_t stream_id, in on_stream_close() argument
839 (void)stream_id; in on_stream_close()
841 if(stream_id) { in on_stream_close()
845 data_s = nghttp2_session_get_stream_user_data(session, stream_id); in on_stream_close()
852 http2_strerror(error_code), error_code, stream_id)); in on_stream_close()
863 rv = nghttp2_session_set_stream_user_data(session, stream_id, 0); in on_stream_close()
866 stream_id); in on_stream_close()
869 if(stream_id == httpc->pause_stream_id) { in on_stream_close()
873 H2BUGF(infof(data_s, "Removed stream %u hash!\n", stream_id)); in on_stream_close()
874 stream->stream_id = 0; /* cleared */ in on_stream_close()
886 data_s = nghttp2_session_get_stream_user_data(session, frame->hd.stream_id); in on_begin_headers()
947 int32_t stream_id = frame->hd.stream_id; in on_header() local
952 DEBUGASSERT(stream_id); /* should never be a zero stream ID here */ in on_header()
955 data_s = nghttp2_session_get_stream_user_data(session, stream_id); in on_header()
986 stream_id, NGHTTP2_PROTOCOL_ERROR); in on_header()
1100 int32_t stream_id, in data_source_read_callback() argument
1112 if(stream_id) { in data_source_read_callback()
1115 data_s = nghttp2_session_get_stream_user_data(session, stream_id); in data_source_read_callback()
1144 nread, stream_id)); in data_source_read_callback()
1210 http->stream_id, NGHTTP2_STREAM_CLOSED)) in Curl_http2_done()
1213 if(http->stream_id == httpc->pause_stream_id) { in Curl_http2_done()
1219 if(http->stream_id > 0) { in Curl_http2_done()
1221 http->stream_id, 0); in Curl_http2_done()
1224 http->stream_id); in Curl_http2_done()
1227 http->stream_id = 0; in Curl_http2_done()
1426 (void)nghttp2_session_resume_data(h2, stream->stream_id); in Curl_http2_done_sending()
1442 if(httpc->pause_stream_id == stream->stream_id) { in http2_handle_stream_close()
1460 stream->stream_id)); in http2_handle_stream_close()
1468 stream->stream_id, http2_strerror(httpc->error_code), in http2_handle_stream_close()
1477 stream->stream_id); in http2_handle_stream_close()
1518 int32_t depstream_id = depstream? depstream->stream_id:0; in h2_pri_spec()
1545 stream->stream_id, data)); in h2_session_send()
1546 rv = nghttp2_submit_priority(h2, NGHTTP2_FLAG_NONE, stream->stream_id, in h2_session_send()
1600 data, stream->stream_id)); in http2_recv()
1604 stream->memlen, stream->stream_id, in http2_recv()
1613 if(httpc->pause_stream_id == stream->stream_id && !stream->pausedata) { in http2_recv()
1624 DEBUGASSERT(httpc->pause_stream_id == stream->stream_id); in http2_recv()
1633 H2BUGF(infof(data, "Unpaused by stream %u\n", stream->stream_id)); in http2_recv()
1634 DEBUGASSERT(httpc->pause_stream_id == stream->stream_id); in http2_recv()
1653 nread, stream->stream_id)); in http2_recv()
1666 stream->stream_id, httpc->pause_stream_id)); in http2_recv()
1747 retlen, stream->stream_id)); in http2_recv()
1750 if(httpc->pause_stream_id == stream->stream_id) { in http2_recv()
1754 stream->stream_id)); in http2_recv()
1769 stream->stream_id)); in http2_recv()
1864 int32_t stream_id; in http2_send() local
1872 if(stream->stream_id != -1) { in http2_send()
1874 infof(conn->data, "stream %d closed\n", stream->stream_id); in http2_send()
1885 nghttp2_session_resume_data(h2, stream->stream_id); in http2_send()
1909 nghttp2_session_resume_data(h2, stream->stream_id); in http2_send()
1913 stream->stream_id)); in http2_send()
2100 stream_id = nghttp2_submit_request(h2, &pri_spec, nva, nheader, in http2_send()
2104 stream_id = nghttp2_submit_request(h2, &pri_spec, nva, nheader, in http2_send()
2110 if(stream_id < 0) { in http2_send()
2117 stream_id, (void *)conn->data); in http2_send()
2118 stream->stream_id = stream_id; in http2_send()
2135 if(stream->stream_id != -1) { in http2_send()
2144 nghttp2_session_resume_data(h2, stream->stream_id); in http2_send()
2161 stream->stream_id = -1; in Curl_http2_setup()
2226 stream->stream_id = 1; in Curl_http2_switched()
2237 stream->stream_id, in Curl_http2_switched()
2241 stream->stream_id); in Curl_http2_switched()
2249 stream->stream_id = -1; in Curl_http2_switched()