Lines Matching refs:stream_data

208                        http2_stream_data *stream_data) {
209 stream_data->next = session_data->root.next;
210 session_data->root.next = stream_data;
211 stream_data->prev = &session_data->root;
212 if (stream_data->next) {
213 stream_data->next->prev = stream_data;
218 http2_stream_data *stream_data) {
221 stream_data->prev->next = stream_data->next;
222 if (stream_data->next) {
223 stream_data->next->prev = stream_data->prev;
229 http2_stream_data *stream_data;
230 stream_data = malloc(sizeof(http2_stream_data));
231 memset(stream_data, 0, sizeof(http2_stream_data));
232 stream_data->stream_id = stream_id;
233 stream_data->fd = -1;
235 add_stream(session_data, stream_data);
236 return stream_data;
239 static void delete_http2_stream_data(http2_stream_data *stream_data) {
240 if (stream_data->fd != -1) {
241 close(stream_data->fd);
243 free(stream_data->request_path);
244 free(stream_data);
278 http2_stream_data *stream_data;
286 for (stream_data = session_data->root.next; stream_data;) {
287 http2_stream_data *next = stream_data->next;
288 delete_http2_stream_data(stream_data);
289 stream_data = next;
442 http2_stream_data *stream_data) {
452 stream_data->stream_id,
469 stream_data->fd = pipefd[0];
471 if (send_response(session, stream_data->stream_id, hdrs, ARRLEN(hdrs),
485 http2_stream_data *stream_data;
495 stream_data =
497 if (!stream_data || stream_data->request_path) {
504 stream_data->request_path = percent_decode(value, j);
515 http2_stream_data *stream_data;
521 stream_data = create_http2_stream_data(session_data, frame->hd.stream_id);
523 stream_data);
538 http2_stream_data *stream_data) {
543 if (!stream_data->request_path) {
544 if (error_reply(session, stream_data) != 0) {
550 stream_data->request_path);
551 if (!check_path(stream_data->request_path)) {
552 if (error_reply(session, stream_data) != 0) {
557 for (rel_path = stream_data->request_path; *rel_path == '/'; ++rel_path)
561 if (error_reply(session, stream_data) != 0) {
566 stream_data->fd = fd;
568 if (send_response(session, stream_data->stream_id, hdrs, ARRLEN(hdrs), fd) !=
579 http2_stream_data *stream_data;
585 stream_data =
589 if (!stream_data) {
592 return on_request_recv(session, session_data, stream_data);
604 http2_stream_data *stream_data;
607 stream_data = nghttp2_session_get_stream_user_data(session, stream_id);
608 if (!stream_data) {
611 remove_stream(session_data, stream_data);
612 delete_http2_stream_data(stream_data);