Lines Matching refs:ts
83 struct tunnel_stream *ts) in tunnel_stream_init() argument
90 ts->state = H2_TUNNEL_INIT; in tunnel_stream_init()
91 ts->stream_id = -1; in tunnel_stream_init()
92 Curl_bufq_init2(&ts->recvbuf, PROXY_H2_CHUNK_SIZE, H2_TUNNEL_RECV_CHUNKS, in tunnel_stream_init()
94 Curl_bufq_init(&ts->sendbuf, PROXY_H2_CHUNK_SIZE, H2_TUNNEL_SEND_CHUNKS); in tunnel_stream_init()
100 ts->authority = /* host:port with IPv6 support */ in tunnel_stream_init()
103 if(!ts->authority) in tunnel_stream_init()
109 static void tunnel_stream_clear(struct tunnel_stream *ts) in tunnel_stream_clear() argument
111 Curl_http_resp_free(ts->resp); in tunnel_stream_clear()
112 Curl_bufq_free(&ts->recvbuf); in tunnel_stream_clear()
113 Curl_bufq_free(&ts->sendbuf); in tunnel_stream_clear()
114 Curl_safefree(ts->authority); in tunnel_stream_clear()
115 memset(ts, 0, sizeof(*ts)); in tunnel_stream_clear()
116 ts->state = H2_TUNNEL_INIT; in tunnel_stream_clear()
120 struct tunnel_stream *ts, in h2_tunnel_go_state() argument
126 if(ts->state == new_state) in h2_tunnel_go_state()
129 switch(ts->state) { in h2_tunnel_go_state()
139 CURL_TRC_CF(data, cf, "[%d] new tunnel state 'init'", ts->stream_id); in h2_tunnel_go_state()
140 tunnel_stream_clear(ts); in h2_tunnel_go_state()
144 CURL_TRC_CF(data, cf, "[%d] new tunnel state 'connect'", ts->stream_id); in h2_tunnel_go_state()
145 ts->state = H2_TUNNEL_CONNECT; in h2_tunnel_go_state()
149 CURL_TRC_CF(data, cf, "[%d] new tunnel state 'response'", ts->stream_id); in h2_tunnel_go_state()
150 ts->state = H2_TUNNEL_RESPONSE; 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()
163 ts->state = new_state; in h2_tunnel_go_state()
816 struct tunnel_stream *ts; in tunnel_send_callback() local
827 ts = nghttp2_session_get_stream_user_data(session, stream_id); in tunnel_send_callback()
828 if(!ts) in tunnel_send_callback()
830 DEBUGASSERT(ts == &ctx->tunnel); in tunnel_send_callback()
832 nread = Curl_bufq_read(&ts->sendbuf, buf, length, &result); in tunnel_send_callback()
838 if(ts->closed && Curl_bufq_is_empty(&ts->sendbuf)) in tunnel_send_callback()
842 ts->stream_id, nread); in tunnel_send_callback()
952 struct tunnel_stream *ts) in submit_CONNECT() argument
967 result = proxy_h2_submit(&ts->stream_id, cf, data, ctx->h2, req, in submit_CONNECT()
968 NULL, ts, tunnel_send_callback, cf); in submit_CONNECT()
971 ts->stream_id, nghttp2_strerror(ts->stream_id)); in submit_CONNECT()
984 struct tunnel_stream *ts) in inspect_response() argument
990 DEBUGASSERT(ts->resp); in inspect_response()
991 if(ts->resp->status/100 == 2) { in inspect_response()
992 infof(data, "CONNECT tunnel established, response %d", ts->resp->status); in inspect_response()
993 h2_tunnel_go_state(cf, ts, H2_TUNNEL_ESTABLISHED, data); in inspect_response()
997 if(ts->resp->status == 401) { in inspect_response()
998 auth_reply = Curl_dynhds_cget(&ts->resp->headers, "WWW-Authenticate"); in inspect_response()
1000 else if(ts->resp->status == 407) { in inspect_response()
1001 auth_reply = Curl_dynhds_cget(&ts->resp->headers, "Proxy-Authenticate"); in inspect_response()
1007 result = Curl_http_input_auth(data, ts->resp->status == 407, in inspect_response()
1014 h2_tunnel_go_state(cf, ts, H2_TUNNEL_INIT, data); in inspect_response()
1025 struct tunnel_stream *ts) in H2_CONNECT() argument
1030 DEBUGASSERT(ts); in H2_CONNECT()
1031 DEBUGASSERT(ts->authority); in H2_CONNECT()
1033 switch(ts->state) { in H2_CONNECT()
1036 CURL_TRC_CF(data, cf, "[0] CONNECT start for %s", ts->authority); in H2_CONNECT()
1037 result = submit_CONNECT(cf, data, ts); in H2_CONNECT()
1040 h2_tunnel_go_state(cf, ts, H2_TUNNEL_CONNECT, data); in H2_CONNECT()
1049 h2_tunnel_go_state(cf, ts, H2_TUNNEL_FAILED, data); in H2_CONNECT()
1053 if(ts->has_final_response) { in H2_CONNECT()
1054 h2_tunnel_go_state(cf, ts, H2_TUNNEL_RESPONSE, data); in H2_CONNECT()
1063 DEBUGASSERT(ts->has_final_response); in H2_CONNECT()
1064 result = inspect_response(cf, data, ts); in H2_CONNECT()
1079 } while(ts->state == H2_TUNNEL_INIT); in H2_CONNECT()
1083 h2_tunnel_go_state(cf, ts, H2_TUNNEL_FAILED, data); in H2_CONNECT()
1095 struct tunnel_stream *ts = &ctx->tunnel; in cf_h2_proxy_connect() local
1117 DEBUGASSERT(ts->authority); in cf_h2_proxy_connect()
1129 result = H2_CONNECT(cf, data, ts); in cf_h2_proxy_connect()
1132 *done = (result == CURLE_OK) && (ts->state == H2_TUNNEL_ESTABLISHED); in cf_h2_proxy_connect()
