Lines Matching refs:stream_id
74 int32_t stream_id; member
91 ts->stream_id = -1; in tunnel_stream_init()
139 CURL_TRC_CF(data, cf, "[%d] new tunnel state 'init'", ts->stream_id); in h2_tunnel_go_state()
144 CURL_TRC_CF(data, cf, "[%d] new tunnel state 'connect'", ts->stream_id); in h2_tunnel_go_state()
149 CURL_TRC_CF(data, cf, "[%d] new tunnel state 'response'", ts->stream_id); in h2_tunnel_go_state()
155 ts->stream_id); in h2_tunnel_go_state()
162 CURL_TRC_CF(data, cf, "[%d] new tunnel state 'failed'", ts->stream_id); in h2_tunnel_go_state()
230 tunnel->stream_id, bits); in drain_tunnel()
311 int32_t stream_id,
320 int32_t stream_id,
658 CURL_TRC_CF(data, cf, "[%d] -> %s", frame->hd.stream_id, buffer); in proxy_h2_on_frame_send()
671 int32_t stream_id = frame->hd.stream_id; in proxy_h2_on_frame_recv() local
681 CURL_TRC_CF(data, cf, "[%d] <- %s",frame->hd.stream_id, buffer); in proxy_h2_on_frame_recv()
685 if(!stream_id) { in proxy_h2_on_frame_recv()
708 if(stream_id != ctx->tunnel.stream_id) { in proxy_h2_on_frame_recv()
709 CURL_TRC_CF(data, cf, "[%d] rcvd FRAME not for tunnel", stream_id); in proxy_h2_on_frame_recv()
722 stream_id, ctx->tunnel.resp->status); in proxy_h2_on_frame_recv()
750 int32_t stream_id = frame->hd.stream_id; in proxy_h2_on_header() local
756 DEBUGASSERT(stream_id); /* should never be a zero stream ID here */ in proxy_h2_on_header()
757 if(stream_id != ctx->tunnel.stream_id) { in proxy_h2_on_header()
759 "%.*s: %.*s", stream_id, in proxy_h2_on_header()
789 stream_id, ctx->tunnel.resp->status); in proxy_h2_on_header()
803 stream_id, (int)namelen, name, (int)valuelen, value); in proxy_h2_on_header()
809 int32_t stream_id, in tunnel_send_callback() argument
826 if(!stream_id) in tunnel_send_callback()
829 ts = nghttp2_session_get_stream_user_data(session, stream_id); in tunnel_send_callback()
844 ts->stream_id, nread); in tunnel_send_callback()
849 int32_t stream_id, in tunnel_recv_callback() argument
859 DEBUGASSERT(stream_id); /* should never be a zero stream ID here */ in tunnel_recv_callback()
861 if(stream_id != ctx->tunnel.stream_id) in tunnel_recv_callback()
875 int32_t stream_id, in proxy_h2_on_stream_close() argument
885 if(stream_id != ctx->tunnel.stream_id) in proxy_h2_on_stream_close()
889 stream_id, nghttp2_http2_strerror(error_code), error_code); in proxy_h2_on_stream_close()
908 int32_t stream_id = -1; in proxy_h2_submit() local
929 stream_id = nghttp2_submit_request(h2, pri_spec, nva, nheader, in proxy_h2_submit()
933 stream_id = nghttp2_submit_request(h2, pri_spec, nva, nheader, in proxy_h2_submit()
937 if(stream_id < 0) { in proxy_h2_submit()
939 nghttp2_strerror(stream_id), stream_id); in proxy_h2_submit()
948 *pstream_id = stream_id; in proxy_h2_submit()
969 result = proxy_h2_submit(&ts->stream_id, cf, data, ctx->h2, req, in submit_CONNECT()
973 ts->stream_id, nghttp2_strerror(ts->stream_id)); in submit_CONNECT()
1250 s_exhaust = ctx->tunnel.stream_id >= 0 && in cf_h2_proxy_adjust_pollset()
1252 ctx->h2, ctx->tunnel.stream_id); in cf_h2_proxy_adjust_pollset()
1287 "connection", ctx->tunnel.stream_id); in h2_handle_tunnel_close()
1294 ctx->tunnel.stream_id, nghttp2_http2_strerror(ctx->tunnel.error), in h2_handle_tunnel_close()
1300 failf(data, "HTTP/2 stream %u was reset", ctx->tunnel.stream_id); in h2_handle_tunnel_close()
1308 ctx->tunnel.stream_id, rv, *err); in h2_handle_tunnel_close()
1334 ctx->last_stream_id < ctx->tunnel.stream_id)) { in tunnel_recv()
1346 ctx->tunnel.stream_id, len, nread, *err); in tunnel_recv()
1375 ctx->tunnel.stream_id, nread); in cf_h2_proxy_recv()
1376 nghttp2_session_consume(ctx->h2, ctx->tunnel.stream_id, (size_t)nread); in cf_h2_proxy_recv()
1393 ctx->tunnel.stream_id, len, nread, *err); in cf_h2_proxy_recv()
1429 rv = nghttp2_session_resume_data(ctx->h2, ctx->tunnel.stream_id); in cf_h2_proxy_send()
1476 ctx->tunnel.stream_id, len, nwritten, *err, in cf_h2_proxy_send()
1478 ctx->h2, ctx->tunnel.stream_id), in cf_h2_proxy_send()
1496 int rv = nghttp2_session_resume_data(ctx->h2, ctx->tunnel.stream_id); in cf_h2_proxy_flush()
1508 ctx->tunnel.stream_id, result, in cf_h2_proxy_flush()
1510 ctx->h2, ctx->tunnel.stream_id), in cf_h2_proxy_flush()
