Function InitHTTPServer

src/rpc/core/httpserver.cpp:372–423

}

bool InitHTTPServer() {
    if (!InitHTTPAllowList()) {
        return false;
    }

    // Redirect libevent's logging to our own log
    event_set_log_callback(&libevent_log_cb);
    /*
        // Update libevent's log handling. Returns false if our version of
        // libevent doesn't support debug logging, in which case we should
        // clear the BCLog::LIBEVENT flag.
        if (!UpdateHTTPServerLogging(LogInstance().WillLogCategory(BCLog::LIBEVENT))) {
            LogInstance().DisableCategory(BCLog::LIBEVENT);
        }
    */

#ifdef WIN32
    evthread_use_windows_threads();
#else
    evthread_use_pthreads();
#endif

    raii_event_base base_ctr = obtain_event_base();

    /* Create a new evhttp object to handle requests. */
    raii_evhttp http_ctr = obtain_evhttp(base_ctr.get());
    struct evhttp* http  = http_ctr.get();
    if (!http) {
        LogPrint(BCLog::ERROR, "couldn't create evhttp. Exiting.\n");
        return false;
    }

    evhttp_set_timeout(http, SysCfg().GetArg("-rpcservertimeout", DEFAULT_HTTP_SERVER_TIMEOUT));
    evhttp_set_max_headers_size(http, MAX_HEADERS_SIZE);
    evhttp_set_max_body_size(http, MAX_SIZE);
    evhttp_set_gencb(http, http_request_cb, nullptr);

    if (!HTTPBindAddresses(http)) {
        LogPrint(BCLog::ERROR, "Unable to bind any endpoint for RPC server\n");
        return false;
    }

    LogPrint(BCLog::RPC, "Initialized HTTP server\n");
    int32_t workQueueDepth = std::max<int32_t>(SysCfg().GetArg("-rpcworkqueue", DEFAULT_HTTP_WORKQUEUE), 1L);
    LogPrint(BCLog::RPC, "HTTP: creating work queue of depth %d\n", workQueueDepth);

    workQueue = new WorkQueue<HTTPClosure>(workQueueDepth);
    // transfer ownership to eventBase/HTTP via .release()
    eventBase = base_ctr.release();
    eventHTTP = http_ctr.release();
    return true;
}

void FinalizeHTTPServer() {
#if LIBEVENT_VERSION_NUMBER >= 0x02010100