Lines Matching refs:data_s
638 struct Curl_easy *data_s = NULL; in on_frame_recv() local
670 data_s = nghttp2_session_get_stream_user_data(session, stream_id); in on_frame_recv()
671 if(!data_s) { in on_frame_recv()
678 stream = data_s->req.protop; in on_frame_recv()
680 H2BUGF(infof(data_s, "No proto pointer for stream: %x\n", in on_frame_recv()
685 H2BUGF(infof(data_s, "on_frame_recv() header %x stream %x\n", in on_frame_recv()
731 H2BUGF(infof(data_s, "Store %zu bytes headers from stream %u at %p\n", in on_frame_recv()
737 drain_this(data_s, httpc); in on_frame_recv()
743 if(conn_s->data != data_s) in on_frame_recv()
744 Curl_expire(data_s, 0, EXPIRE_RUN_NOW); in on_frame_recv()
748 rv = push_promise(data_s, conn, &frame->push_promise); in on_frame_recv()
759 H2BUGF(infof(data_s, "Got frame type %x for stream %u!\n", in on_frame_recv()
771 struct Curl_easy *data_s; in on_data_chunk_recv() local
781 data_s = nghttp2_session_get_stream_user_data(session, stream_id); in on_data_chunk_recv()
782 if(!data_s) in on_data_chunk_recv()
787 stream = data_s->req.protop; in on_data_chunk_recv()
797 drain_this(data_s, &conn->proto.httpc); in on_data_chunk_recv()
800 if(conn->data != data_s) in on_data_chunk_recv()
801 Curl_expire(data_s, 0, EXPIRE_RUN_NOW); in on_data_chunk_recv()
803 H2BUGF(infof(data_s, "%zu data received for stream %u " in on_data_chunk_recv()
812 H2BUGF(infof(data_s, "NGHTTP2_ERR_PAUSE - %zu bytes out of buffer" in on_data_chunk_recv()
815 data_s->conn->proto.httpc.pause_stream_id = stream_id; in on_data_chunk_recv()
822 if(conn->data != data_s) { in on_data_chunk_recv()
823 data_s->conn->proto.httpc.pause_stream_id = stream_id; in on_data_chunk_recv()
834 struct Curl_easy *data_s; in on_stream_close() local
845 data_s = nghttp2_session_get_stream_user_data(session, stream_id); in on_stream_close()
846 if(!data_s) { in on_stream_close()
851 H2BUGF(infof(data_s, "on_stream_close(), %s (err %d), stream %u\n", in on_stream_close()
853 stream = data_s->req.protop; in on_stream_close()
859 drain_this(data_s, httpc); in on_stream_close()
865 infof(data_s, "http/2: failed to clear user_data for stream %d!\n", in on_stream_close()
870 H2BUGF(infof(data_s, "Stopped the pause stream!\n")); in on_stream_close()
873 H2BUGF(infof(data_s, "Removed stream %u hash!\n", stream_id)); in on_stream_close()
883 struct Curl_easy *data_s = NULL; in on_begin_headers() local
886 data_s = nghttp2_session_get_stream_user_data(session, frame->hd.stream_id); in on_begin_headers()
887 if(!data_s) { in on_begin_headers()
891 H2BUGF(infof(data_s, "on_begin_headers() was called\n")); in on_begin_headers()
897 stream = data_s->req.protop; in on_begin_headers()
946 struct Curl_easy *data_s; in on_header() local
955 data_s = nghttp2_session_get_stream_user_data(session, stream_id); in on_header()
956 if(!data_s) in on_header()
961 stream = data_s->req.protop; in on_header()
963 failf(data_s, "Internal NULL stream! 5\n"); in on_header()
1025 H2BUGF(infof(data_s, "h2 trailer: %.*s: %.*s\n", namelen, name, valuelen, in on_header()
1066 if(conn->data != data_s) in on_header()
1067 Curl_expire(data_s, 0, EXPIRE_RUN_NOW); in on_header()
1069 H2BUGF(infof(data_s, "h2 status: HTTP/2 %03d (easy %p)\n", in on_header()
1070 stream->status_code, data_s)); in on_header()
1090 if(conn->data != data_s) in on_header()
1091 Curl_expire(data_s, 0, EXPIRE_RUN_NOW); in on_header()
1093 H2BUGF(infof(data_s, "h2 header: %.*s: %.*s\n", namelen, name, valuelen, in on_header()
1106 struct Curl_easy *data_s; in data_source_read_callback() local
1115 data_s = nghttp2_session_get_stream_user_data(session, stream_id); in data_source_read_callback()
1116 if(!data_s) in data_source_read_callback()
1121 stream = data_s->req.protop; in data_source_read_callback()
1133 if(data_s->state.infilesize != -1) in data_source_read_callback()
1142 H2BUGF(infof(data_s, "data_source_read_callback: " in data_source_read_callback()