bcb4e51a409d94ae670de96afb8483a4f7855294Stephan Bosch/* Copyright (c) 2013-2018 Dovecot authors, see the included COPYING file */
3fcb3d2d1f3583025ff62bae95ec706920f398b1Stephan Bosch
3fcb3d2d1f3583025ff62bae95ec706920f398b1Stephan Bosch#include "lib.h"
3fcb3d2d1f3583025ff62bae95ec706920f398b1Stephan Bosch#include "net.h"
3fcb3d2d1f3583025ff62bae95ec706920f398b1Stephan Bosch#include "str.h"
3fcb3d2d1f3583025ff62bae95ec706920f398b1Stephan Bosch#include "hash.h"
3fcb3d2d1f3583025ff62bae95ec706920f398b1Stephan Bosch#include "array.h"
3fcb3d2d1f3583025ff62bae95ec706920f398b1Stephan Bosch#include "ioloop.h"
3fcb3d2d1f3583025ff62bae95ec706920f398b1Stephan Bosch#include "istream.h"
3fcb3d2d1f3583025ff62bae95ec706920f398b1Stephan Bosch#include "ostream.h"
3fcb3d2d1f3583025ff62bae95ec706920f398b1Stephan Bosch#include "connection.h"
3fcb3d2d1f3583025ff62bae95ec706920f398b1Stephan Bosch#include "dns-lookup.h"
3fcb3d2d1f3583025ff62bae95ec706920f398b1Stephan Bosch#include "iostream-rawlog.h"
3fcb3d2d1f3583025ff62bae95ec706920f398b1Stephan Bosch#include "iostream-ssl.h"
3fcb3d2d1f3583025ff62bae95ec706920f398b1Stephan Bosch#include "http-url.h"
3fcb3d2d1f3583025ff62bae95ec706920f398b1Stephan Bosch
3fcb3d2d1f3583025ff62bae95ec706920f398b1Stephan Bosch#include "http-server-private.h"
3fcb3d2d1f3583025ff62bae95ec706920f398b1Stephan Bosch
3fcb3d2d1f3583025ff62bae95ec706920f398b1Stephan Bosch/*
3fcb3d2d1f3583025ff62bae95ec706920f398b1Stephan Bosch * Server
3fcb3d2d1f3583025ff62bae95ec706920f398b1Stephan Bosch */
3fcb3d2d1f3583025ff62bae95ec706920f398b1Stephan Bosch
3fcb3d2d1f3583025ff62bae95ec706920f398b1Stephan Boschstruct http_server *http_server_init(const struct http_server_settings *set)
3fcb3d2d1f3583025ff62bae95ec706920f398b1Stephan Bosch{
3fcb3d2d1f3583025ff62bae95ec706920f398b1Stephan Bosch struct http_server *server;
3fcb3d2d1f3583025ff62bae95ec706920f398b1Stephan Bosch pool_t pool;
3fcb3d2d1f3583025ff62bae95ec706920f398b1Stephan Bosch
3fcb3d2d1f3583025ff62bae95ec706920f398b1Stephan Bosch pool = pool_alloconly_create("http server", 1024);
3fcb3d2d1f3583025ff62bae95ec706920f398b1Stephan Bosch server = p_new(pool, struct http_server, 1);
3fcb3d2d1f3583025ff62bae95ec706920f398b1Stephan Bosch server->pool = pool;
3fcb3d2d1f3583025ff62bae95ec706920f398b1Stephan Bosch if (set->rawlog_dir != NULL && *set->rawlog_dir != '\0')
3fcb3d2d1f3583025ff62bae95ec706920f398b1Stephan Bosch server->set.rawlog_dir = p_strdup(pool, set->rawlog_dir);
3fcb3d2d1f3583025ff62bae95ec706920f398b1Stephan Bosch server->set.max_client_idle_time_msecs = set->max_client_idle_time_msecs;
3fcb3d2d1f3583025ff62bae95ec706920f398b1Stephan Bosch server->set.max_pipelined_requests =
3fcb3d2d1f3583025ff62bae95ec706920f398b1Stephan Bosch (set->max_pipelined_requests > 0 ? set->max_pipelined_requests : 1);
3fcb3d2d1f3583025ff62bae95ec706920f398b1Stephan Bosch server->set.request_limits = set->request_limits;
47fee1a942e4797548b1232354f6676b8ff809f4Stephan Bosch server->set.socket_send_buffer_size = set->socket_send_buffer_size;
47fee1a942e4797548b1232354f6676b8ff809f4Stephan Bosch server->set.socket_recv_buffer_size = set->socket_recv_buffer_size;
3fcb3d2d1f3583025ff62bae95ec706920f398b1Stephan Bosch server->set.debug = set->debug;
3fcb3d2d1f3583025ff62bae95ec706920f398b1Stephan Bosch
3fcb3d2d1f3583025ff62bae95ec706920f398b1Stephan Bosch server->conn_list = http_server_connection_list_init();
3fcb3d2d1f3583025ff62bae95ec706920f398b1Stephan Bosch
3fcb3d2d1f3583025ff62bae95ec706920f398b1Stephan Bosch return server;
3fcb3d2d1f3583025ff62bae95ec706920f398b1Stephan Bosch}
3fcb3d2d1f3583025ff62bae95ec706920f398b1Stephan Bosch
3fcb3d2d1f3583025ff62bae95ec706920f398b1Stephan Boschvoid http_server_deinit(struct http_server **_server)
3fcb3d2d1f3583025ff62bae95ec706920f398b1Stephan Bosch{
3fcb3d2d1f3583025ff62bae95ec706920f398b1Stephan Bosch struct http_server *server = *_server;
3fcb3d2d1f3583025ff62bae95ec706920f398b1Stephan Bosch
f9d2a1f21ad65262bc630f0834d7eead06a1bac3Timo Sirainen *_server = NULL;
f9d2a1f21ad65262bc630f0834d7eead06a1bac3Timo Sirainen
3fcb3d2d1f3583025ff62bae95ec706920f398b1Stephan Bosch connection_list_deinit(&server->conn_list);
3fcb3d2d1f3583025ff62bae95ec706920f398b1Stephan Bosch
3fcb3d2d1f3583025ff62bae95ec706920f398b1Stephan Bosch if (server->ssl_ctx != NULL)
15d19d6e4daf460d8d2c82b981e23996dbdf7ba5Timo Sirainen ssl_iostream_context_unref(&server->ssl_ctx);
3fcb3d2d1f3583025ff62bae95ec706920f398b1Stephan Bosch pool_unref(&server->pool);
3fcb3d2d1f3583025ff62bae95ec706920f398b1Stephan Bosch}
3fcb3d2d1f3583025ff62bae95ec706920f398b1Stephan Bosch
3fcb3d2d1f3583025ff62bae95ec706920f398b1Stephan Boschvoid http_server_switch_ioloop(struct http_server *server)
3fcb3d2d1f3583025ff62bae95ec706920f398b1Stephan Bosch{
3fcb3d2d1f3583025ff62bae95ec706920f398b1Stephan Bosch struct connection *_conn = server->conn_list->connections;
3fcb3d2d1f3583025ff62bae95ec706920f398b1Stephan Bosch
3fcb3d2d1f3583025ff62bae95ec706920f398b1Stephan Bosch /* move connections */
3fcb3d2d1f3583025ff62bae95ec706920f398b1Stephan Bosch /* FIXME: we wouldn't necessarily need to switch all of them
3fcb3d2d1f3583025ff62bae95ec706920f398b1Stephan Bosch immediately, only those that have requests now. but also connections
3fcb3d2d1f3583025ff62bae95ec706920f398b1Stephan Bosch that get new requests before ioloop is switched again.. */
3fcb3d2d1f3583025ff62bae95ec706920f398b1Stephan Bosch for (; _conn != NULL; _conn = _conn->next) {
3fcb3d2d1f3583025ff62bae95ec706920f398b1Stephan Bosch struct http_server_connection *conn =
3fcb3d2d1f3583025ff62bae95ec706920f398b1Stephan Bosch (struct http_server_connection *)_conn;
3fcb3d2d1f3583025ff62bae95ec706920f398b1Stephan Bosch
3fcb3d2d1f3583025ff62bae95ec706920f398b1Stephan Bosch http_server_connection_switch_ioloop(conn);
3fcb3d2d1f3583025ff62bae95ec706920f398b1Stephan Bosch }
3fcb3d2d1f3583025ff62bae95ec706920f398b1Stephan Bosch}
e1a4ea6ad3e799ef8df7395e765c0ae9218e6c5dStephan Bosch
e1a4ea6ad3e799ef8df7395e765c0ae9218e6c5dStephan Boschvoid http_server_shut_down(struct http_server *server)
e1a4ea6ad3e799ef8df7395e765c0ae9218e6c5dStephan Bosch{
e1a4ea6ad3e799ef8df7395e765c0ae9218e6c5dStephan Bosch struct connection *_conn, *_next;
e1a4ea6ad3e799ef8df7395e765c0ae9218e6c5dStephan Bosch
e1a4ea6ad3e799ef8df7395e765c0ae9218e6c5dStephan Bosch server->shutting_down = TRUE;
e1a4ea6ad3e799ef8df7395e765c0ae9218e6c5dStephan Bosch
e1a4ea6ad3e799ef8df7395e765c0ae9218e6c5dStephan Bosch for (_conn = server->conn_list->connections;
e1a4ea6ad3e799ef8df7395e765c0ae9218e6c5dStephan Bosch _conn != NULL; _conn = _next) {
e1a4ea6ad3e799ef8df7395e765c0ae9218e6c5dStephan Bosch struct http_server_connection *conn =
e1a4ea6ad3e799ef8df7395e765c0ae9218e6c5dStephan Bosch (struct http_server_connection *)_conn;
e1a4ea6ad3e799ef8df7395e765c0ae9218e6c5dStephan Bosch
e1a4ea6ad3e799ef8df7395e765c0ae9218e6c5dStephan Bosch _next = _conn->next;
e1a4ea6ad3e799ef8df7395e765c0ae9218e6c5dStephan Bosch (void)http_server_connection_shut_down(conn);
e1a4ea6ad3e799ef8df7395e765c0ae9218e6c5dStephan Bosch }
e1a4ea6ad3e799ef8df7395e765c0ae9218e6c5dStephan Bosch}