melin-server 0.13.0

/// jemalloc: thread-local caches eliminate allocator lock contention,
/// giving more predictable latency than glibc malloc under high throughput.
#[global_allocator]
static GLOBAL: tikv_jemallocator::Jemalloc = tikv_jemallocator::Jemalloc;

/// jemalloc tuning, applied at allocator init via the well-known
/// `malloc_conf` symbol. Set for tail-latency stability:
///
/// - `background_thread:true` — spawn a dedicated thread to do page
///   purging asynchronously instead of synchronously on the allocating
///   thread. Default jemalloc does the purge work on whatever thread
///   happens to free memory, which on the matching/journal hot path
///   shows up as occasional multi-millisecond stalls in `process_event`.
/// - `dirty_decay_ms:53000` / `muzzy_decay_ms:57000` — hold dirty/muzzy
///   pages for ~53/57 s (vs the 10 s default) before reclaiming. Trades
///   marginally higher steady-state RSS for fewer purge events; with
///   the background thread this also bounds how often that thread runs.
///   Values are deliberately odd so purge-induced latency spikes are
///   immediately attributable to jemalloc rather than blending into
///   60 s monitoring/heartbeat boundaries.
///
/// The trailing NUL is required: jemalloc reads `malloc_conf` as a C
/// string. `non_upper_case_globals` is the documented spelling — the
/// symbol name has to match exactly.
#[allow(non_upper_case_globals)]
#[unsafe(export_name = "malloc_conf")]
pub static malloc_conf: &[u8] =
    b"background_thread:true,dirty_decay_ms:53000,muzzy_decay_ms:57000\0";

use clap::Parser;
use melin_server::app_factory::{Factory, FactoryConfig};
use melin_server::event_publisher;
use melin_server::request_decoder::RequestDecoder;
use melin_server::response_encoder::ResponseEncoder;
use melin_server_runtime::server::{self, ServerConfig};

fn main() -> Result<(), Box<dyn std::error::Error>> {
    tracing_subscriber::fmt()
        .with_env_filter(tracing_subscriber::EnvFilter::from_default_env())
        .with_target(true)
        .with_thread_names(true)
        .init();

    let config = ServerConfig::parse();

    let factory = Factory::new(FactoryConfig {
        accounts: config.accounts,
        instruments: config.instruments,
        max_orders_per_account: config.max_orders_per_account,
        max_orders_per_second: config.max_orders_per_second,
        max_orders_burst: config.max_orders_burst,
    });

    server::run(
        config,
        factory,
        RequestDecoder,
        ResponseEncoder,
        Some(event_publisher::run),
    )
}