| 443 | } |
| 444 | |
| 445 | void StartHTTPServer() { |
| 446 | LogPrint(BCLog::RPC, "Starting HTTP server\n"); |
| 447 | int32_t rpcThreads = std::max<int32_t>(SysCfg().GetArg("-rpcthreads", DEFAULT_HTTP_THREADS), 1L); |
| 448 | LogPrint(BCLog::RPC, "HTTP: starting %d worker threads\n", rpcThreads); |
| 449 | threadHTTP = std::thread(ThreadHTTP, eventBase); |
| 450 | |
| 451 | for (int i = 0; i < rpcThreads; i++) { |
| 452 | g_thread_http_workers.emplace_back(HTTPWorkQueueRun, workQueue); |
| 453 | } |
| 454 | } |
| 455 | |
| 456 | void InterruptHTTPServer() { |
| 457 | LogPrint(BCLog::RPC, "Interrupting HTTP server\n"); |
no test coverage detected