mirror of
https://github.com/clearlinux/uwsgi.git
synced 2026-08-28 17:55:39 +00:00
Unbit
d4130dbc4b
preliminary api for language-independent body read another step completed body read language independent implementation ported gevent to the new read/write api ported websockets to the new read/write api removed channels subsystem removed channels subsystem ported lua to the new read/write api fixed post-buffering readline is still broken improved request body readline very difficult test for readline()/read() combo passed other improvements in postbuffering/read/readline ported --http-socket to the new api added X-Forwarded-SSL management removed old api more refactoring ported the RACK plugin to the new api ported psgi plugin to the new api defintely removed clustering simpified ifdel hell simpified ifdef hell removed useless configuration options
68 lines
2.2 KiB
C
68 lines
2.2 KiB
C
#include "../../uwsgi.h"
|
|
|
|
extern struct uwsgi_server uwsgi;
|
|
|
|
// global variables for configuration
|
|
static uint8_t dumbloop_modifier1 = 0;
|
|
static char *dumbloop_code = "";
|
|
static char *dumbloop_function = "dumbloop";
|
|
|
|
struct uwsgi_option dumbloop_options[] = {
|
|
{"dumbloop-modifier1", required_argument, 0, "set the modifier1 for the code_string", uwsgi_opt_set_int, &dumbloop_modifier1, 0},
|
|
{"dumbloop-code", required_argument, 0, "set the script to load for the code_string", uwsgi_opt_set_str, &dumbloop_code, 0},
|
|
{"dumbloop-function", required_argument, 0, "set the function to run for the code_string", uwsgi_opt_set_str, &dumbloop_function, 0},
|
|
{0, 0, 0, 0, 0, 0, 0},
|
|
|
|
};
|
|
|
|
|
|
// this function is executed for each thread
|
|
static void *dumb_loop_run(void *arg1) {
|
|
|
|
// get the core id (pthreads take a void pointer as argument, so we need this ugly trick)
|
|
long core_id = (long) arg1;
|
|
|
|
// complete threads setup (this is required for fixing things like UNIX signal handling)
|
|
if (uwsgi.threads > 1) {
|
|
// wsgi_request mapped to the core
|
|
struct wsgi_request *wsgi_req = &uwsgi.workers[uwsgi.mywid].cores[core_id].req;
|
|
// fix it
|
|
uwsgi_setup_thread_req(core_id, wsgi_req);
|
|
}
|
|
|
|
// this strign will be passed to the code_string function
|
|
char *str_core = uwsgi_num2str(core_id);
|
|
// ok we are ready, let's run custom code
|
|
while (uwsgi.workers[uwsgi.mywid].manage_next_request) {
|
|
if (uwsgi.p[dumbloop_modifier1]->code_string) {
|
|
// "uwsgi_dumbloop" is the name of the module (will be used while importing the file, if needed)
|
|
uwsgi.p[dumbloop_modifier1]->code_string("uwsgi_dumbloop", dumbloop_code, dumbloop_function, str_core, strlen(str_core));
|
|
}
|
|
else {
|
|
uwsgi_log("the requested plugin does not support code_string hook\n");
|
|
exit(1);
|
|
}
|
|
}
|
|
|
|
return NULL;
|
|
}
|
|
|
|
static void dumb_loop() {
|
|
// this run the dumb_loop_run in each thread (core)
|
|
uwsgi_loop_cores_run(dumb_loop_run);
|
|
}
|
|
|
|
|
|
|
|
// register the new loop engine
|
|
static void dumbloop_register() {
|
|
uwsgi_register_loop( (char *) "dumb", dumb_loop);
|
|
}
|
|
|
|
|
|
struct uwsgi_plugin dumbloop_plugin = {
|
|
.name = "dumbloop",
|
|
.on_load = dumbloop_register,
|
|
.options = dumbloop_options,
|
|
};
|