http.c File Reference

Go to the source code of this file.

Macros
#define	MCP_SERVER_HTTP_ORIGIN_BUFFER_SIZE   2048
#define	MCP_SERVER_HTTP_TYPE_BUFFER_SIZE   128
#define	MCP_SERVER_HTTP_ACCEPT_BUFFER_SIZE   512
#define	MCP_SERVER_HTTP_VERSION_BUFFER_SIZE   64

Functions
void	mcp_http_wake (mcp_server_t *s)
asciichat_error_t	mcp_http_run (mcp_server_t *s)

Macro Definition Documentation

MCP_SERVER_HTTP_ACCEPT_BUFFER_SIZE

#define MCP_SERVER_HTTP_ACCEPT_BUFFER_SIZE   512

Definition at line 5 of file http.c.

MCP_SERVER_HTTP_ORIGIN_BUFFER_SIZE

#define MCP_SERVER_HTTP_ORIGIN_BUFFER_SIZE   2048

Definition at line 3 of file http.c.

MCP_SERVER_HTTP_TYPE_BUFFER_SIZE

#define MCP_SERVER_HTTP_TYPE_BUFFER_SIZE   128

Definition at line 4 of file http.c.

MCP_SERVER_HTTP_VERSION_BUFFER_SIZE

#define MCP_SERVER_HTTP_VERSION_BUFFER_SIZE   64

Definition at line 6 of file http.c.

Function Documentation

mcp_http_run()

asciichat_error_t mcp_http_run

(

mcp_server_t *

s

)

Definition at line 233 of file http.c.

                                                {
  http_server_config_t config = {.bind_address = s->policy.address,
                                 .bind_address6 = s->policy.address6,
                                 .port = (uint16_t)s->policy.port,
                                 .enable_http1 = true,
                                 .enable_http2 = true,
                                 .tls_cert_path = s->policy.tls_cert,
                                 .tls_key_path = s->policy.tls_key,
                                 .tls_key_password = s->policy.tls_password,
                                 .max_connections = s->policy.max_jobs * 4U,
                                 .max_request_body_bytes = MCP_MAX_INPUT,
                                 .max_response_body_bytes = MCP_MAX_DOWNLOAD,
                                 .on_request = shared_http_request,
                                 .on_wakeup = shared_http_wakeup,
                                 .user_data = s};
  if (!config.max_connections)
    config.max_connections = 1;
  asciichat_error_t result = http_server_init(&s->shared_http, &config);
  if (result != ASCIICHAT_OK)
    return result;
  result = http_server_start(s->shared_http);
  if (result != ASCIICHAT_OK) {
    http_server_destroy(&s->shared_http);
    return result;
  }
  nat_upnp_context_t *mapping = NULL;
  if (GET_OPTION(enable_upnp)) {
    asciichat_error_t err = nat_upnp_open((uint16_t)s->policy.port, "ascii-chat MCP", &mapping);
    if (err != ASCIICHAT_OK)
      LOG_ERRNO_IF_SET("MCP port forwarding unavailable");
  }
  while (!atomic_load_bool(&s->stopping) && !APP_CALLBACK_BOOL(should_exit)) {
    uv_sleep(16);
    mcp_jobs_reap(s, false);
    if (mapping && time_get_ns() >= mapping->refresh_at_ns) {
      asciichat_error_t err = nat_upnp_refresh(mapping);
      if (err != ASCIICHAT_OK)
        LOG_ERRNO_IF_SET("MCP mapping renewal failed");
    }
  }
  for (unsigned i = 0; i < s->policy.max_jobs; ++i)
    if (s->jobs[i].renderer_job.started)
      http_renderer_job_cancel(&s->jobs[i].renderer_job);
  http_server_stop(s->shared_http);
  http_server_destroy(&s->shared_http);
  nat_upnp_close(&mapping);
  mcp_jobs_reap(s, true);
  return ASCIICHAT_OK;
}

References mcp_policy_t::address, mcp_policy_t::address6, APP_CALLBACK_BOOL, ASCIICHAT_OK, GET_OPTION, http_renderer_job_cancel(), http_server_destroy(), http_server_init(), http_server_start(), http_server_stop(), mcp_server::jobs, LOG_ERRNO_IF_SET, http_server_config_t::max_connections, mcp_policy_t::max_jobs, mcp_jobs_reap(), MCP_MAX_DOWNLOAD, MCP_MAX_INPUT, nat_upnp_close(), nat_upnp_open(), nat_upnp_refresh(), mcp_server::policy, mcp_policy_t::port, nat_upnp_context::refresh_at_ns, mcp_job::renderer_job, mcp_server::shared_http, should_exit(), http_renderer_job::started, mcp_server::stopping, mcp_policy_t::tls_cert, mcp_policy_t::tls_key, and mcp_policy_t::tls_password.

Referenced by mcp_server_main().

mcp_http_wake()

void mcp_http_wake

(

mcp_server_t *

s

)

Definition at line 30 of file http.c.

                                    {
  if (s && s->shared_http)
    (void)http_server_wakeup(s->shared_http);
}

References http_server_wakeup(), and mcp_server::shared_http.