mirror of
https://github.com/matrix-construct/construct
synced 2024-12-02 03:32:52 +01:00
114 lines
3.3 KiB
C++
114 lines
3.3 KiB
C++
// Matrix Construct
|
|
//
|
|
// Copyright (C) Matrix Construct Developers, Authors & Contributors
|
|
// Copyright (C) 2016-2018 Jason Volk <jason@zemos.net>
|
|
//
|
|
// Permission to use, copy, modify, and/or distribute this software for any
|
|
// purpose with or without fee is hereby granted, provided that the above
|
|
// copyright notice and this permission notice is present in all copies. The
|
|
// full license for this software is available in the LICENSE file.
|
|
|
|
#pragma once
|
|
#define HAVE_IRCD_CLIENT_H
|
|
|
|
namespace ircd
|
|
{
|
|
struct client;
|
|
|
|
//TODO: want to upgrade
|
|
char *read(client &, char *&start, char *const &stop);
|
|
parse::read_closure read_closure(client &);
|
|
|
|
std::shared_ptr<client> add_client(std::shared_ptr<socket>); // Creates a client.
|
|
}
|
|
|
|
/// Remote party connecting to our daemon to make requests.
|
|
struct ircd::client
|
|
:std::enable_shared_from_this<client>
|
|
,ircd::instance_list<client>
|
|
{
|
|
struct init;
|
|
struct conf;
|
|
struct settings;
|
|
struct request;
|
|
|
|
static struct settings settings;
|
|
static struct conf default_conf;
|
|
static ctx::pool context;
|
|
static uint64_t ctr; // monotonic
|
|
|
|
static void interrupt_all();
|
|
static void close_all();
|
|
static void wait_all();
|
|
|
|
struct conf *conf {&default_conf};
|
|
unique_buffer<mutable_buffer> head_buffer;
|
|
unique_buffer<mutable_buffer> content_buffer;
|
|
std::shared_ptr<socket> sock;
|
|
uint64_t id {++ctr};
|
|
ctx::ctx *reqctx {nullptr};
|
|
ircd::timer timer;
|
|
size_t head_length {0};
|
|
size_t content_consumed {0};
|
|
resource::request request;
|
|
|
|
size_t write_all(const const_buffer &);
|
|
void close(const net::close_opts &, net::close_callback);
|
|
ctx::future<void> close(const net::close_opts & = {});
|
|
|
|
void discard_unconsumed(const http::request::head &);
|
|
bool resource_request(const http::request::head &);
|
|
bool handle_request(parse::capstan &pc);
|
|
bool main() noexcept;
|
|
bool async();
|
|
|
|
public:
|
|
client(std::shared_ptr<socket>);
|
|
client();
|
|
client(client &&) = delete;
|
|
client(const client &) = delete;
|
|
client &operator=(client &&) = delete;
|
|
client &operator=(const client &) = delete;
|
|
~client() noexcept;
|
|
|
|
friend ipport remote(const client &);
|
|
friend ipport local(const client &);
|
|
};
|
|
|
|
/// Confs can be attached to individual clients to change their behavior
|
|
struct ircd::client::conf
|
|
{
|
|
static ircd::conf::item<seconds> async_timeout_default;
|
|
static ircd::conf::item<seconds> request_timeout_default;
|
|
static ircd::conf::item<size_t> header_max_size_default;
|
|
|
|
/// Default time limit for how long a client connection can be in "async mode"
|
|
/// (or idle mode) after which it is disconnected.
|
|
seconds async_timeout {async_timeout_default};
|
|
|
|
/// Time limit for how long a connected client can be sending its request.
|
|
/// This is meaningful before the resource being sought is known (while
|
|
/// receiving headers), after which its own specific timeout specified by
|
|
/// its options takes over.
|
|
seconds request_timeout {request_timeout_default};
|
|
|
|
/// Number of bytes allocated to receive HTTP request headers for client.
|
|
size_t header_max_size {header_max_size_default};
|
|
};
|
|
|
|
/// Settings apply to all clients and cannot be configured per-client
|
|
struct ircd::client::settings
|
|
{
|
|
static ircd::conf::item<size_t> stack_size;
|
|
static ircd::conf::item<size_t> pool_size;
|
|
};
|
|
|
|
struct ircd::client::init
|
|
{
|
|
void interrupt();
|
|
void close();
|
|
void wait();
|
|
|
|
init();
|
|
~init() noexcept;
|
|
};
|