source: benchmark/io/http/options.cfa@ 7d01186d

#include "options.hfa"

#define _GNU_SOURCE
#define __USE_GNU
extern "C" {
        #include <sys/types.h>
        #include <sys/stat.h>
        #include <fcntl.h>
}

#include <bitmanip.hfa>
#include <fstream.hfa>
#include <kernel.hfa>
#include <parseargs.hfa>

#include <stdlib.h>
#include <string.h>

Options options @= {
        false, // log

        { // file_cache
                0,     // path
                0,     // open_flags;
                42u,   // hash_seed;
                0,     // size;
                false, // list;
                false  // fixed_fds
        },

        { // socket
                8080, // port
                10,   // backlog
                1024  // buflen
        },

        { // cluster
                1,     // nprocs;
                1,     // nworkers;
                {},     // params;
                false, // procstats
                false, // viewhalts
                0,     // instance;
        }
};

void parse_options( int argc, char * argv[] ) {
        bool subthrd = false;
        bool eagrsub = false;
        bool fixedfd = false;
        bool sqkpoll = false;
        bool iokpoll = false;
        unsigned sublen = 16;
        unsigned nentries = 16;


        static cfa_option opt[] = {
                { 'p', "port",           "Port the server will listen on", options.socket.port},
                { 'c', "cpus",           "Number of processors to use", options.clopts.nprocs},
                { 't', "threads",        "Number of worker threads to use", options.clopts.nworkers},
                {'\0', "log",            "Enable logs", options.log, parse_settrue},
                {'\0', "accept-backlog", "Maximum number of pending accepts", options.socket.backlog},
                {'\0', "request_len",    "Maximum number of bytes in the http request, requests with more data will be answered with Http Code 414", options.socket.buflen},
                {'\0', "seed",           "seed to use for hashing", options.file_cache.hash_seed },
                {'\0', "cache-size",     "Size of the cache to use, if set to small, will uses closes power of 2", options.file_cache.size },
                {'\0', "list-files",     "List the files in the specified path and exit", options.file_cache.list, parse_settrue },
                { 's', "submitthread",   "If set, cluster uses polling thread to submit I/O", subthrd, parse_settrue },
                { 'e', "eagersubmit",    "If set, cluster submits I/O eagerly but still aggregates submits", eagrsub, parse_settrue},
                { 'f', "fixed-fds",      "If set, files are open eagerly and pre-registered with the cluster", fixedfd, parse_settrue},
                { 'k', "kpollsubmit",    "If set, cluster uses IORING_SETUP_SQPOLL, implies -f", sqkpoll, parse_settrue },
                { 'i', "kpollcomplete",  "If set, cluster uses IORING_SETUP_IOPOLL", iokpoll, parse_settrue },
                {'\0', "submitlength",   "Max number of submitions that can be submitted together", sublen },
                {'\0', "numentries",     "Number of I/O entries", nentries },

        };
        int opt_cnt = sizeof(opt) / sizeof(cfa_option);

        char **left;
        parse_args( argc, argv, opt, opt_cnt, "[OPTIONS]... [PATH]\ncforall http server", left );

        if( !is_pow2(nentries) ) {
                unsigned v = nentries;
                v--;
                v |= v >> 1;
                v |= v >> 2;
                v |= v >> 4;
                v |= v >> 8;
                v |= v >> 16;
                v++;
                serr | "Warning: num_entries not a power of 2" | '(' | nentries | ')' | "raising to " | v;
                nentries = v;
        }
        options.clopts.params.num_entries = nentries;

        options.clopts.params.poller_submits = subthrd;
        options.clopts.params.eager_submits  = eagrsub;

        if( fixedfd ) {
                options.file_cache.fixed_fds = true;
        }

        if( sqkpoll ) {
                options.clopts.params.poll_submit = true;
                options.file_cache.fixed_fds = true;
        }

        if( iokpoll ) {
                options.clopts.params.poll_complete = true;
                options.file_cache.open_flags |= O_DIRECT;
        }

        options.clopts.params.num_ready = sublen;

        if( left[0] == 0p ) { return; }

        const char * path = left[0];
        left++;

        if( left[0] != 0p ) {
                serr | "Too many trailing arguments!" | '\'' | path | '\'';
                while(left[0] != 0p) {
                        serr | " - " | left[0];
                        left++;
                }
                exit(EXIT_FAILURE);
        }

        options.file_cache.path = path;
}