37 std::array< char, 64 > buf;
42 "%a, %d %b %Y %H:%M:%S GMT",
45 return std::string{ buf.data() };
58 template <
typename Response_Builder >
74 bool should_keep_alive )
84 http_response_header_t &
100 std::string field_name,
101 std::string field_value ) &
112 std::string field_name,
113 std::string field_value ) &&
140 std::string field_value ) &
152 std::string field_value ) &&
163 std::chrono::system_clock::time_point tp =
164 std::chrono::system_clock::now() ) &
173 std::chrono::system_clock::time_point tp =
174 std::chrono::system_clock::now() ) &&
225 throw exception_t{
"done() cannot be called twice" };
232 return static_cast< Response_Builder &
>( *this );
241 template <
typename Response_Output_Strategy >
270 using base_type_t::base_type_t;
276 auto size = body.size();
277 return set_body_impl( body, size );
291 auto size = body_part.size();
292 return append_body_impl( body_part, size );
309 response_output_flags{
313 m_header.content_length( m_body_size );
315 if_neccessary_reserve_first_element_for_header();
317 m_response_parts[ 0 ] =
320 write_group_t wg{
std::move( m_response_parts ) };
321 wg.status_line_size( calculate_status_line_size() );
325 wg.after_write_notificator(
std::move( wscb ) );
330 conn->write_response_parts(
332 response_output_flags,
337 throw_done_must_be_called_once();
347 if_neccessary_reserve_first_element_for_header();
351 m_response_parts.resize( 1 );
355 m_response_parts.emplace_back(
std::move( body ) );
358 m_body_size = body_size;
366 if_neccessary_reserve_first_element_for_header();
368 if( 0 < append_size )
370 m_response_parts.emplace_back(
std::move( body_part ) );
371 m_body_size += append_size;
380 if( m_response_parts.empty() )
382 m_response_parts.reserve( 2 );
383 m_response_parts.emplace_back();
387 std::size_t m_body_size{ 0 };
414 using base_type_t::base_type_t;
420 m_header.content_length( content_length );
428 return std::move( this->set_content_length( content_length ) );
435 auto size = body.size();
436 return set_body_impl( body, size );
450 auto size = body_part.size();
455 return append_body_impl( body_part );
476 response_parts_attr_t::not_final_parts,
507 throw_done_must_be_called_once();
520 std::size_t status_line_size{ 0 };
522 if( !m_header_was_sent )
524 m_should_keep_alive_when_header_was_sent =
525 m_header.should_keep_alive();
527 if_neccessary_reserve_first_element_for_header();
529 m_response_parts[ 0 ] =
532 m_header_was_sent =
true;
533 status_line_size = calculate_status_line_size();
536 if( !m_response_parts.empty() ||
541 response_output_flags{
546 wg.status_line_size( status_line_size );
550 wg.after_write_notificator(
std::move( wscb ) );
553 conn->write_response_parts(
555 response_output_flags,
563 if_neccessary_reserve_first_element_for_header();
567 if( !m_header_was_sent )
568 m_response_parts.resize( 1 );
570 m_response_parts.resize( 0 );
575 m_response_parts.emplace_back(
std::move( body ) );
584 if_neccessary_reserve_first_element_for_header();
586 m_response_parts.emplace_back(
std::move( body_part ) );
593 if( !m_header_was_sent && m_response_parts.empty() )
595 m_response_parts.reserve( 2 );
596 m_response_parts.emplace_back();
602 bool m_header_was_sent{
false };
611 bool m_should_keep_alive_when_header_was_sent{
true };
643 bool should_keep_alive )
650 m_chunks.reserve( 4 );
659 auto size = chunk.size();
662 m_chunks.emplace_back(
std::move( chunk ) );
685 response_parts_attr_t::not_final_parts,
716 throw_done_must_be_called_once();
729 std::size_t status_line_size{ 0 };
730 if( !m_header_was_sent )
732 status_line_size = calculate_status_line_size();
733 prepare_header_for_sending();
737 m_header_was_sent =
true;
740 response_output_flags{
745 if( !bufs.empty() || wscb )
748 wg.status_line_size( status_line_size );
752 wg.after_write_notificator(
std::move( wscb ) );
755 conn->write_response_parts(
757 response_output_flags,
765 m_should_keep_alive_when_header_was_sent =
766 m_header.should_keep_alive();
768 constexpr
const char value[] =
"chunked";
769 if( !m_header.has_field( restinio::http_field::transfer_encoding ) )
772 restinio::http_field::transfer_encoding,
777 auto & current_value =
778 m_header.get_field( restinio::http_field::transfer_encoding );
779 if( std::string::npos == current_value.find( value ) )
781 constexpr
const char comma_value[] =
",chunked";
782 m_header.append_field(
783 restinio::http_field::transfer_encoding,
796 std::size_t reserve_size = 2 * m_chunks.size() + 1;
798 if( !m_header_was_sent )
807 bufs.reserve( reserve_size );
809 if( !m_header_was_sent )
817 const char * format_string =
"{:X}\r\n";
818 for(
auto & chunk : m_chunks )
823 asio_ns::buffer_size( chunk.buf() ) ) );
826 format_string =
"\r\n{:X}\r\n";
832 const char *
const ending_representation =
"\r\n" "0\r\n\r\n";
833 const char * appendix_begin = ending_representation + 2;
834 const char * appendix_end = appendix_begin;
836 if( !m_chunks.empty() )
849 if( appendix_begin != appendix_end )
853 static_cast<std::size_t
>(appendix_end - appendix_begin)
863 bool m_header_was_sent{
false };
872 bool m_should_keep_alive_when_header_was_sent{
true };