@@ -94,6 +94,16 @@ void mk_http_request_init(struct mk_http_session *session,
9494 session -> channel ,
9595 NULL ,
9696 NULL , NULL , NULL );
97+
98+ /* Initialize headers input stream */
99+ request -> in_headers .type = MK_STREAM_IOV ;
100+ request -> in_headers .dynamic = MK_FALSE ;
101+ request -> in_headers .cb_consumed = NULL ;
102+ request -> in_headers .cb_finished = NULL ;
103+ request -> in_headers .buffer = NULL ;
104+ request -> in_headers .bytes_total = 0 ;
105+ request -> in_headers .stream = & request -> stream ;
106+ mk_list_add (& request -> in_headers ._head , & request -> stream .inputs );
97107}
98108
99109static inline int mk_http_point_header (mk_ptr_t * h ,
@@ -722,14 +732,6 @@ int mk_http_init(struct mk_http_session *cs, struct mk_http_request *sr,
722732
723733 ret_file = mk_file_get_info (sr -> real_path .data , & sr -> file_info , MK_FILE_READ );
724734
725- /* Manually set the headers input streams */
726- sr -> in_headers .type = MK_STREAM_IOV ;
727- sr -> in_headers .dynamic = MK_FALSE ;
728- sr -> in_headers .cb_consumed = NULL ;
729- sr -> in_headers .cb_finished = NULL ;
730- sr -> in_headers .stream = & sr -> stream ;
731- mk_list_add (& sr -> in_headers ._head , & sr -> stream .inputs );
732-
733735 /* Plugin Stage 30: look for handlers for this request */
734736 if (sr -> stage30_blocked == MK_FALSE ) {
735737 sr -> uri_processed .data [sr -> uri_processed .len ] = '\0' ;
0 commit comments