mirror of
https://github.com/DarkflameUniverse/DarkflameServer.git
synced 2026-10-02 10:53:44 +00:00
17689cd663
Opening a zone the first time built its terrain, scene objects and manifests and ran ImageMagick on the web thread, stalling the dashboard for seconds. - Workers: the shared pool plus Workers::Reply (answer at once when built, else from a worker via Web::Defer). - terrain_chunks/terrain_layers/scene/paths/scenery/flairs (world3d, property and showcase routes) and terrain textures go through it; results are built once in OnceCaches, the .raw is read once per zone for chunks, layers and flairs, deflated bodies are cached thread-safely. - ImageMagick conversions are deduplicated and written under a temporary name. - Workers don't query the CDClient, read settings or call mongoose: ZoneTable, render components, flairs, object names, LOT kinds and terrain texture names are read at startup; client_location is read once; base64 is plain C++. - Logger writes one line at a time (mutex; localtime's buffer is shared). Co-Authored-By: Claude Opus 5.5 <noreply@anthropic.com>
54 lines
1.5 KiB
C++
54 lines
1.5 KiB
C++
#include "Workers.h"
|
|
|
|
#include <algorithm>
|
|
#include <exception>
|
|
#include <thread>
|
|
|
|
#include "RouteUtils.h"
|
|
#include "Web.h"
|
|
|
|
#include "Game.h"
|
|
#include "Logger.h"
|
|
#include "dConfig.h"
|
|
|
|
namespace {
|
|
WorkerPool g_Pool;
|
|
}
|
|
|
|
namespace Workers {
|
|
void Start() {
|
|
auto threads = Game::config ? Game::config->GetValue<uint32_t>("scenery_workers", 0) : 0;
|
|
if (threads == 0) threads = static_cast<uint32_t>(WorkerPool::DefaultThreads(std::thread::hardware_concurrency()));
|
|
threads = std::clamp<uint32_t>(threads, 2, 16);
|
|
// Work ahead of time (converting a zone's models) never takes more than half of the threads besides the fast lane
|
|
g_Pool.Start(threads, std::max<size_t>(1, (threads - 1) / 2));
|
|
LOG("Dashboard worker threads: %u", threads);
|
|
}
|
|
|
|
void Stop() {
|
|
g_Pool.Stop();
|
|
}
|
|
|
|
WorkerPool& Pool() {
|
|
return g_Pool;
|
|
}
|
|
|
|
void Reply(HTTPReply& reply, const HTTPContext& context, bool ready, std::function<void(HTTPReply&)> fill, WorkerPool::ePriority priority) {
|
|
if (ready || !g_Pool.Running()) return fill(reply);
|
|
const auto deferred = Web::Defer(reply, context);
|
|
const auto path = context.path;
|
|
g_Pool.Submit(priority, [deferred, path, fill = std::move(fill)] {
|
|
if (deferred.Cancelled()) return;
|
|
HTTPReply out;
|
|
try {
|
|
fill(out);
|
|
} catch (const std::exception& ex) {
|
|
LOG("Error handling GET %s: %s", path.c_str(), ex.what());
|
|
out = HTTPReply{};
|
|
RouteUtils::JsonError(out, eHTTPStatusCode::INTERNAL_SERVER_ERROR, "Internal server error");
|
|
}
|
|
deferred.Send(std::move(out));
|
|
});
|
|
}
|
|
}
|