45 return ctx.m_write_groups;
69 std::size_t{ 0 } ==
wg.status_line_size() )
216 "unable to insert context because "
217 "response_context_table is full" };
237 "unable to pop context because "
238 "response_context_table is empty" };
337 "unable to append response parts, "
338 "response coordinator is closed" };
348 "no context associated with request {}" ),
353 ctx->response_output_flags().m_response_parts )
357 "unable to append response, "
358 "it marked as complete" };
361 ctx->response_output_flags( response_output_flags );
363 ctx->enqueue_group( std::move(
wg ) );
373 std::optional< std::pair< write_group_t, request_id_t > >
378 "unable to prepare output buffers, "
379 "response coordinator is closed" };
381 std::optional< std::pair< write_group_t, request_id_t > >
result;
399 current_ctx.response_output_flags().m_response_parts )
401 current_ctx.response_output_flags().m_response_connection );
443 wg.invoke_after_write_notificator_if_exists(
ec );
Exception class for all exceptions thrown by RESTinio.
A context for a single response.
write_group_t dequeue_group() noexcept
Extract write group from data queue.
friend write_groups_container_t & utest_access(response_context_t &ctx)
Access write-groups container (used in unit tests)
request_id_t m_request_id
void reinit(request_id_t request_id) noexcept
Reinitialize context.
response_output_flags_t m_response_output_flags
Response flags.
auto response_output_flags() const noexcept
Get flags of corrent response data flow.
write_groups_container_t m_write_groups
Unsent responses parts.
auto request_id() const noexcept
Get id of associated request.
bool is_complete() const noexcept
Is response data of a given request is complete.
bool empty() const noexcept
Is context empty.
void enqueue_group(write_group_t wg)
Put write group to data queue.
void response_output_flags(response_output_flags_t flags) noexcept
Get flags of corrent response data flow.
Helper storage for responses' contexts.
response_context_t & back() noexcept
Get last context.
response_context_table_t(std::size_t max_elements_count)
response_context_t & front() noexcept
Get first context.
void pop_response_context()
Remove the first context from queue.
bool empty() const noexcept
If table is empty.
void pop_response_context_nonchecked() noexcept
Remove the first context from queue with the check for emptiness of the queue.
std::size_t get_real_index(request_id_t req_id) noexcept
std::size_t m_first_element_index
response_context_t * get_by_req_id(request_id_t req_id) noexcept
Get context of specified request.
std::size_t m_elements_exists
std::vector< response_context_t > m_contexts
void push_response_context(request_id_t req_id)
Insert new context into queue.
bool is_full() const noexcept
If table is full.
Coordinator for process of sending responses with respect to http pipeline technique and chunk transf...
void reset() noexcept
Remove all contexts.
request_id_t register_new_request()
Create a new request and reserve context for its response.
bool is_able_to_get_more_messages() const noexcept
Check if it is possible to accept more requests.
request_id_t m_request_id_counter
Counter for asigining id to new requests.
bool is_full() const noexcept
response_context_table_t m_context_table
A storage for resp-context items.
bool empty() const noexcept
bool m_connection_closed_response_occured
Indicate whether a response with connection close flag was emitted.
std::optional< std::pair< write_group_t, request_id_t > > pop_ready_buffers()
Extract a portion of data available for write.
bool closed() const noexcept
response_coordinator_t(std::size_t max_req_count)
void append_response(request_id_t req_id, response_output_flags_t response_output_flags, write_group_t wg)
Add outgoing data for specified request.
Group of writable items transported to the context of underlying connection as one solid piece.
#define RESTINIO_STATIC_ASSERT_NOEXCEPT(expr)
A wrapper around static_assert for checking that an expression is noexcept.
A special wrapper around fmtlib include files.
#define RESTINIO_FMT_FORMAT_STRING(s)
std::vector< write_group_t > write_groups_container_t
void suppress_exceptions_quietly(Lambda &&lambda) noexcept
Helper function for execution a block of code with suppression of any exceptions raised inside that b...
unsigned int request_id_t
Request id in scope of single connection.
run_on_this_thread_settings_t< Traits > on_this_thread()
A special marker for the case when http_server must be run on the context of the current thread.
@ write_was_not_executed
After write notificator error: data was not sent, connection closed (or aborted) before a given piece...
@ connection_close
This response says to close connection.
@ connection_keepalive
This response says to keep connection.
asio_ns::error_code make_asio_compaible_error(asio_convertible_error_t err) noexcept
Make restinio error_code compatible with asio_ns::error_code.
@ final_parts
Final parts (response ands with these parts).
@ not_final_parts
Intermediate parts (more parts of response to follow).
Response output flags for buffers commited to response-coordinator.
response_parts_attr_t m_response_parts
Utilities for suppressing exceptions from some code block.