Relintai/pandemonium_engine
1
0
Fork 0
mirror of https://github.com/Relintai/pandemonium_engine.git synced 2025-02-03 14:45:57 +01:00
Code Issues Packages Projects Releases Wiki Activity

Added threading settings binds to the SimpleWebServer.

Browse Source
This commit is contained in:
Relintai 2022-07-24 13:40:58 +02:00
parent aa8c6b35d1
commit 3956c88859
2 changed files with 73 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

61
modules/web/http_server_simple/web_server_simple.cpp
View File

@ -30,11 +30,49 @@
#include "web_server_simple.h" #include "web_server_simple.h"
#include "core/os/os.h"
#include "http_server_simple.h" #include "http_server_simple.h"
bool WebServerSimple::get_use_poll_thread() {
return _use_poll_thread;
}
void WebServerSimple::set_use_poll_thread(const bool val) {
_use_poll_thread = val;
}
int WebServerSimple::get_poll_thread_count() {
return _poll_thread_count;
}
void WebServerSimple::set_poll_thread_count(const int val) {
_poll_thread_count = val;
}
bool WebServerSimple::get_use_worker_threads() {
return _use_worker_threads;
}
void WebServerSimple::set_use_worker_threads(const bool val) {
_use_worker_threads = val;
}
int WebServerSimple::get_worker_thread_count() {
return _worker_thread_count;
}
void WebServerSimple::set_worker_thread_count(const int val) {
_worker_thread_count = val;
}
void WebServerSimple::_start() { void WebServerSimple::_start() {
server->_use_worker_threads = _use_worker_threads; if (!OS::get_singleton()->can_use_threads()) {
server->_thread_count = _thread_count; server->_use_worker_threads = false;
} else {
server->_use_worker_threads = _use_worker_threads;
}
if (_worker_thread_count < 0) {
server->_thread_count = OS::get_singleton()->get_processor_count();
} else {
server->_thread_count = _worker_thread_count;
}
WebServer::_start(); WebServer::_start();
@ -76,9 +114,11 @@ void WebServerSimple::_stop() {
} }
WebServerSimple::WebServerSimple() { WebServerSimple::WebServerSimple() {
server_quit = false;
_use_worker_threads = true; _use_worker_threads = true;
_use_poll_thread = true; _use_poll_thread = true;
_thread_count = 4; _poll_thread_count = 1;
_worker_thread_count = 4;
server.instance(); server.instance();
server->_web_server = this; server->_web_server = this;
@ -92,6 +132,21 @@ WebServerSimple::~WebServerSimple() {
} }
void WebServerSimple::_bind_methods() { void WebServerSimple::_bind_methods() {
ClassDB::bind_method(D_METHOD("get_use_poll_thread"), &WebServerSimple::get_use_poll_thread);
ClassDB::bind_method(D_METHOD("set_use_poll_thread", "val"), &WebServerSimple::set_use_poll_thread);
ADD_PROPERTY(PropertyInfo(Variant::BOOL, "use_poll_thread"), "set_use_poll_thread", "get_use_poll_thread");
ClassDB::bind_method(D_METHOD("get_poll_thread_count"), &WebServerSimple::get_poll_thread_count);
ClassDB::bind_method(D_METHOD("set_poll_thread_count", "val"), &WebServerSimple::set_poll_thread_count);
ADD_PROPERTY(PropertyInfo(Variant::INT, "poll_thread_count"), "set_poll_thread_count", "get_poll_thread_count");
ClassDB::bind_method(D_METHOD("get_use_worker_threads"), &WebServerSimple::get_use_worker_threads);
ClassDB::bind_method(D_METHOD("set_use_worker_threads", "val"), &WebServerSimple::set_use_worker_threads);
ADD_PROPERTY(PropertyInfo(Variant::BOOL, "use_worker_threads"), "set_use_worker_threads", "get_use_worker_threads");
ClassDB::bind_method(D_METHOD("get_worker_thread_count"), &WebServerSimple::get_worker_thread_count);
ClassDB::bind_method(D_METHOD("set_worker_thread_count", "val"), &WebServerSimple::set_worker_thread_count);
ADD_PROPERTY(PropertyInfo(Variant::INT, "worker_thread_count"), "set_worker_thread_count", "get_worker_thread_count");
} }
void WebServerSimple::_server_thread_poll(void *data) { void WebServerSimple::_server_thread_poll(void *data) {

17
modules/web/http_server_simple/web_server_simple.h
View File

@ -46,6 +46,18 @@ class WebServerSimple : public WebServer {
GDCLASS(WebServerSimple, WebServer); GDCLASS(WebServerSimple, WebServer);
public: public:
bool get_use_poll_thread();
void set_use_poll_thread(const bool val);
int get_poll_thread_count();
void set_poll_thread_count(const int val);
bool get_use_worker_threads();
void set_use_worker_threads(const bool val);
int get_worker_thread_count();
void set_worker_thread_count(const int val);
void _start(); void _start();
void _stop(); void _stop();
@ -56,13 +68,14 @@ protected:
static void _bind_methods(); static void _bind_methods();
Ref<HTTPServerSimple> server; Ref<HTTPServerSimple> server;
bool server_quit = false; bool server_quit;
Mutex server_lock; Mutex server_lock;
Thread server_thread; Thread server_thread;
bool _use_poll_thread; bool _use_poll_thread;
int _poll_thread_count;
bool _use_worker_threads; bool _use_worker_threads;
int _thread_count; int _worker_thread_count;
static void _server_thread_poll(void *data); static void _server_thread_poll(void *data);
}; };