server_internal.h File Reference

Go to the source code of this file.

Typedefs
typedef asciichat_error_t(*	http3_submit_response_fn) (void *context, unsigned status, const http_header_t *headers, size_t header_count, const void *body, size_t body_length)

Functions
size_t	http_server_max_request_body (const http_server_t *server)
size_t	http_server_max_response_body (const http_server_t *server)
void	http_server_invalidate_http3_context (http_server_t *server, void *context)
asciichat_error_t	http_server_dispatch_http3 (http_server_t *server, const char *method, const char *path, const http_header_t *headers, size_t header_count, const void *body, size_t body_length, const char *peer_address, http3_submit_response_fn submit, void *submit_context)

Typedef Documentation

http3_submit_response_fn

typedef asciichat_error_t(* http3_submit_response_fn) (void *context, unsigned status, const http_header_t *headers, size_t header_count, const void *body, size_t body_length)

Definition at line 5 of file server_internal.h.

Function Documentation

http_server_dispatch_http3()

asciichat_error_t http_server_dispatch_http3	(	http_server_t *	server,
		const char *	method,
		const char *	path,
		const http_header_t *	headers,
		size_t	header_count,
		const void *	body,
		size_t	body_length,
		const char *	peer_address,
		http3_submit_response_fn	submit,
		void *	submit_context )

Definition at line 793 of file lib/network/http/server/server.c.

                                                                                                    {
  if (!server || !method || !path || (header_count && !headers) || (!body && body_length) || !submit ||
      body_length > server->config.max_request_body_bytes)
    return SET_ERRNO(ERROR_INVALID_PARAM, "Invalid HTTP/3 request");
  char path_copy[2048];
  if (strlen(path) >= sizeof(path_copy))
    return SET_ERRNO(ERROR_NETWORK_SIZE, "HTTP/3 request path is too long");
  platform_strncpy(path_copy, sizeof(path_copy), path, sizeof(path_copy) - 1);
  char *query = strchr(path_copy, '?');
  if (query)
    *query++ = 0;
  http_request_t request = {0};
  request.info = (http_request_info_t){.method = method,
                                       .path = path_copy,
                                       .query = query,
                                       .protocol = HTTP_PROTOCOL_3,
                                       .headers = headers,
                                       .header_count = header_count,
                                       .peer_address = peer_address,
                                       .user_data = server->config.user_data};
  request.storage = (char *)body;
  request.body_length = body_length;
  stats_counter_add(stats_runtime_scope(), STATS_COUNTER_HTTP_BYTES_RECEIVED, body_length);
  const char *peer = peer_address ? peer_address : "unknown";
  bool allowed = false;
  if (rate_limiter_check(server->rate_limiter, peer, RATE_EVENT_HTTP_REQUEST, &server->request_rate_limit, &allowed) !=
          ASCIICHAT_OK ||
      !allowed) {
    stats_counter_add(stats_runtime_scope(), STATS_COUNTER_HTTP_REJECTED, 1);
    http_response_t limited = {.server = server,
                               .protocol = HTTP_PROTOCOL_3,
                               .status = 429,
                               .max_body_length = http_max_response_body(server),
                               .http3_submit = submit,
                               .http3_context = submit_context};
    return http_response_finish(&limited);
  }
  rate_limiter_record(server->rate_limiter, peer, RATE_EVENT_HTTP_REQUEST);
  stats_counter_add(stats_runtime_scope(), STATS_COUNTER_HTTP_REQUESTS, 1);
  stats_gauge_set(stats_runtime_scope(), STATS_GAUGE_HTTP_STREAMS_ACTIVE, 1);
  uint64_t request_start = time_get_ns();
  if (!http_request_admit(server)) {
    http_response_t limited = {.server = server,
                               .protocol = HTTP_PROTOCOL_3,
                               .status = 429,
                               .max_body_length = http_max_response_body(server),
                               .http3_submit = submit,
                               .http3_context = submit_context};
    return http_response_finish(&limited);
  }
  http_response_t response = {.server = server,
                              .protocol = HTTP_PROTOCOL_3,
                              .status = 200,
                              .max_body_length = http_max_response_body(server),
                              .inflight_accounted = true,
                              .http3_submit = submit,
                              .http3_context = submit_context};
  ASCII_OTEL_SCOPE(HTTP);
  ASCII_OTEL_ATTR_STRING("http.method", method);
  ASCII_OTEL_ATTR_STRING("http.route", request.info.path);
  ASCII_OTEL_ATTR_STRING("http.protocol", "3");
  ASCII_OTEL_ATTR_STRING("http.backend", "quic-ngtcp2-nghttp3");
  if (http_server_authorize(&server->config.basic_auth, &request.info, &response))
    server->config.on_request(&request, &response, server->config.user_data);
  if (!response.finished && !response.deferred) {
    asciichat_error_t result = http_response_finish(&response);
    ASCII_OTEL_ATTR_INT("http.status", response.status);
    ASCII_OTEL_ATTR_INT("http.response_bytes", (int64_t)response.body_length);
    stats_duration_record(stats_runtime_scope(), STATS_DURATION_HTTP_REQUEST, time_get_ns() - request_start);
    stats_gauge_set(stats_runtime_scope(), STATS_GAUGE_HTTP_STREAMS_ACTIVE, 0);
    if (result == ASCIICHAT_OK && response.protocol == HTTP_PROTOCOL_3)
      stats_counter_add(stats_runtime_scope(), STATS_COUNTER_HTTP_BYTES_SENT, response.body_length);
    SAFE_FREE(response.body);
    return result;
  }
  stats_duration_record(stats_runtime_scope(), STATS_DURATION_HTTP_REQUEST, time_get_ns() - request_start);
  stats_gauge_set(stats_runtime_scope(), STATS_GAUGE_HTTP_STREAMS_ACTIVE, 0);
  SAFE_FREE(response.body);
  return ASCIICHAT_OK;
}

References ASCII_OTEL_ATTR_INT, ASCII_OTEL_ATTR_STRING, ASCII_OTEL_SCOPE, ASCIICHAT_OK, http_server_config_t::basic_auth, http_response::body, http_request::body_length, http_response::body_length, http_server::config, http_response::deferred, ERROR_INVALID_PARAM, ERROR_NETWORK_SIZE, http_response::finished, HTTP_PROTOCOL_3, http_response_finish(), http_server_authorize(), http_request::info, http_server_config_t::max_request_body_bytes, http_server_config_t::on_request, http_request_info::path, http_response::protocol, RATE_EVENT_HTTP_REQUEST, http_server::rate_limiter, rate_limiter_check(), rate_limiter_record(), http_server::request_rate_limit, SAFE_FREE, SET_ERRNO, stats_counter_add(), STATS_COUNTER_HTTP_BYTES_RECEIVED, STATS_COUNTER_HTTP_BYTES_SENT, STATS_COUNTER_HTTP_REJECTED, STATS_COUNTER_HTTP_REQUESTS, STATS_DURATION_HTTP_REQUEST, stats_duration_record(), STATS_GAUGE_HTTP_STREAMS_ACTIVE, stats_gauge_set(), stats_runtime_scope(), http_response::status, http_request::storage, and http_server_config_t::user_data.

http_server_invalidate_http3_context()

void http_server_invalidate_http3_context	(	http_server_t *	server,
		void *	context )

Definition at line 138 of file lib/network/http/server/server.c.

                                                                                {
  if (!server || !context)
    return;
  mutex_lock(&server->response_mutex);
  for (http_response_t *response = server->retained_responses; response; response = response->next_retained) {
    if (response->http3_context == context) {
      response->http3_submit = NULL;
      response->http3_context = NULL;
      response->cancelled = true;
    }
  }
  mutex_unlock(&server->response_mutex);
}

References http_response::next_retained, http_server::response_mutex, and http_server::retained_responses.

Referenced by http_server_http3_destroy().

http_server_max_request_body()

size_t http_server_max_request_body

(

const http_server_t *

server

)

Definition at line 885 of file lib/network/http/server/server.c.

                                                                 {
  return server ? server->config.max_request_body_bytes : 0;
}

References http_server::config, and http_server_config_t::max_request_body_bytes.

http_server_max_response_body()

size_t http_server_max_response_body

(

const http_server_t *

server

)

Definition at line 135 of file lib/network/http/server/server.c.

                                                                  {
  return server ? http_max_response_body(server) : 0;
}