From 319ad13af2137d7d71e1a98b2b00a39013c3f6a1 Mon Sep 17 00:00:00 2001 From: "roberto@precise64" Date: Thu, 15 Mar 2012 08:58:41 +0100 Subject: [PATCH] allows plugin 255 to be used --- loop.c | 4 ++-- master.c | 4 ++-- master_utils.c | 2 +- mule.c | 8 ++++---- plugins.c | 2 +- spooler.c | 6 +++--- uwsgi.c | 32 ++++++++++++++++---------------- uwsgi.h | 2 +- 8 files changed, 30 insertions(+), 30 deletions(-) diff --git a/loop.c b/loop.c index 25b0dcaf..9cc00d73 100644 --- a/loop.c +++ b/loop.c @@ -59,7 +59,7 @@ void *simple_loop(void *arg1) { sigdelset(&smask, SIGSEGV); #endif pthread_sigmask(SIG_BLOCK, &smask, NULL); - for (i = 0; i < 0xFF; i++) { + for (i = 0; i < 256; i++) { if (uwsgi.p[i]->init_thread) { uwsgi.p[i]->init_thread(core_id); } @@ -135,7 +135,7 @@ void *zeromq_loop(void *arg1) { sigdelset(&smask, SIGSEGV); #endif pthread_sigmask(SIG_BLOCK, &smask, NULL); - for (i = 0; i < 0xFF; i++) { + for (i = 0; i < 256; i++) { if (uwsgi.p[i]->init_thread) { uwsgi.p[i]->init_thread(core_id); } diff --git a/master.c b/master.c index f447d55f..aee6f08a 100644 --- a/master.c +++ b/master.c @@ -579,7 +579,7 @@ int master_loop(char **argv, char **environ) { uwsgi.gp[i]->master_cycle(); } } - for (i = 0; i < 0xFF; i++) { + for (i = 0; i < 256; i++) { if (uwsgi.p[i]->master_cycle) { uwsgi.p[i]->master_cycle(); } @@ -918,7 +918,7 @@ int master_loop(char **argv, char **environ) { // loop the various udp manager until one returns true udp_managed = 0; - for (i = 0; i < 0xFF; i++) { + for (i = 0; i < 256; i++) { if (uwsgi.p[i]->manage_udp) { if (uwsgi.p[i]->manage_udp(udp_client_addr, udp_client.sin_port, uwsgi.wsgi_req->buffer, rlen)) { udp_managed = 1; diff --git a/master_utils.c b/master_utils.c index 248c5baf..c1eda885 100644 --- a/master_utils.c +++ b/master_utils.c @@ -478,7 +478,7 @@ int uwsgi_respawn_worker(int wid) { if (uwsgi.master_process) { if ((uwsgi.workers[uwsgi.mywid].respawn_count || uwsgi.cheap)) { - for (i = 0; i < 0xFF; i++) { + for (i = 0; i < 256; i++) { if (uwsgi.p[i]->master_fixup) { uwsgi.p[i]->master_fixup(1); } diff --git a/mule.c b/mule.c index 1911f13a..5fb3efc1 100644 --- a/mule.c +++ b/mule.c @@ -48,13 +48,13 @@ void uwsgi_mule(int id) { uwsgi_close_all_sockets(); - for (i = 0; i < 0xFF; i++) { + for (i = 0; i < 256; i++) { if (uwsgi.p[i]->master_fixup) { uwsgi.p[i]->master_fixup(1); } } - for (i = 0; i < 0xFF; i++) { + for (i = 0; i < 256; i++) { if (uwsgi.p[i]->post_fork) { uwsgi.p[i]->post_fork(); } @@ -62,7 +62,7 @@ void uwsgi_mule(int id) { if (uwsgi.mules[id-1].patch) { - for (i = 0; i < 0xFF; i++) { + for (i = 0; i < 256; i++) { if (uwsgi.p[i]->mule) { if (uwsgi.p[i]->mule(uwsgi.mules[id-1].patch) == 1) { // never here @@ -184,7 +184,7 @@ void uwsgi_mule_handler() { } else { int i,found = 0; - for(i=0;i<0xff;i++) { + for(i=0;i<256;i++) { if (uwsgi.p[i]->mule_msg) { if (uwsgi.p[i]->mule_msg(message, len)) { found = 1; diff --git a/plugins.c b/plugins.c index e6d11bb2..a3a85510 100644 --- a/plugins.c +++ b/plugins.c @@ -5,7 +5,7 @@ extern struct uwsgi_server uwsgi; static int plugin_already_loaded(const char *plugin) { int i; - for (i = 0; i < 0xFF; i++) { + for (i = 0; i < 256; i++) { if (uwsgi.p[i]->name) { if (!strcmp(plugin, uwsgi.p[i]->name)) { #ifdef UWSGI_DEBUG diff --git a/spooler.c b/spooler.c index 755d67ce..94ce5b1d 100644 --- a/spooler.c +++ b/spooler.c @@ -101,7 +101,7 @@ pid_t spooler_start(struct uwsgi_spooler *uspool) { uwsgi_fixup_fds(0, 0, NULL); uwsgi_close_all_sockets(); - for (i = 0; i < 0xFF; i++) { + for (i = 0; i < 256; i++) { if (uwsgi.p[i]->post_fork) { uwsgi.p[i]->post_fork(); } @@ -109,7 +109,7 @@ pid_t spooler_start(struct uwsgi_spooler *uspool) { uwsgi.signal_socket = uwsgi.shared->spooler_signal_pipe[1]; - for (i = 0; i < 0xFF; i++) { + for (i = 0; i < 256; i++) { if (uwsgi.p[i]->spooler_init) { uwsgi.p[i]->spooler_init(); } @@ -508,7 +508,7 @@ void spooler_manage_task(struct uwsgi_spooler *uspool, char *dir, char *task) { } int callable_found = 0; - for(i=0;i<0xff;i++) { + for(i=0;i<256;i++) { if (uwsgi.p[i]->spooler) { time_t now = time(NULL); if(uwsgi.shared->options[UWSGI_OPTION_SPOOLER_HARAKIRI] > 0) { diff --git a/uwsgi.c b/uwsgi.c index 51d0a601..d68a3715 100644 --- a/uwsgi.c +++ b/uwsgi.c @@ -1083,7 +1083,7 @@ void uwsgi_plugins_atexit(void) { } } - for (j = 0; j<0xFF; j++) { + for (j = 0; j<256; j++) { if (uwsgi.p[j]->atexit) { uwsgi.p[j]->atexit(); } @@ -1257,7 +1257,7 @@ int main(int argc, char *argv[], char *envp[]) { uwsgi.shared->spooler_frequency = 30; #endif - for (i = 0; i < 0xFF; i++) { + for (i = 0; i < 256; i++) { uwsgi.p[i] = &unconfigured_plugin; } @@ -1494,7 +1494,7 @@ int main(int argc, char *argv[], char *envp[]) { } } if (!magic) { - for (j = 0; j < 0xFF; j++) { + for (j = 0; j < 256; j++) { if (uwsgi.p[j]->magic) { if (uwsgi.p[j]->magic(NULL, lazy)) { magic = 1; @@ -2357,7 +2357,7 @@ skipzero: // initialize request plugin only if workers or master are available if (uwsgi.sockets || uwsgi.master_process || uwsgi.no_server || uwsgi.command_mode) { - for (i = 0; i < 0xFF; i++) { + for (i = 0; i < 256; i++) { if (uwsgi.p[i]->init) { uwsgi.p[i]->init(); } @@ -2373,7 +2373,7 @@ skipzero: // again check for workers/sockets... if (uwsgi.sockets || uwsgi.master_process || uwsgi.no_server || uwsgi.command_mode) { - for (i = 0; i < 0xff; i++) { + for (i = 0; i < 256; i++) { if (uwsgi.p[i]->post_init) { uwsgi.p[i]->post_init(); } @@ -2401,7 +2401,7 @@ skipzero: // again check for workers/sockets... if (uwsgi.sockets || uwsgi.master_process || uwsgi.no_server || uwsgi.command_mode) { - for (i = 0; i < 0xFF; i++) { + for (i = 0; i < 256; i++) { if (uwsgi.p[i]->enable_threads) uwsgi.p[i]->enable_threads(); } @@ -2606,7 +2606,7 @@ skipzero: } // preinit apps (create the language environment) - for (i = 0; i < 0xFF; i++) { + for (i = 0; i < 256; i++) { if (uwsgi.p[i]->preinit_apps) { uwsgi.p[i]->preinit_apps(); } @@ -2681,7 +2681,7 @@ skipzero: // security in multiuser environment: allow only a subset of modifiers if (uwsgi.allowed_modifiers) { - for (i = 0; i < 0xFF; i++) { + for (i = 0; i < 256; i++) { if (!uwsgi_list_has_num(uwsgi.allowed_modifiers, i)) { uwsgi.p[i]->request = unconfigured_hook; uwsgi.p[i]->after_request = unconfigured_after_hook; @@ -2690,7 +2690,7 @@ skipzero: } // master fixup - for (i = 0; i < 0xFF; i++) { + for (i = 0; i < 256; i++) { if (uwsgi.p[i]->master_fixup) { uwsgi.p[i]->master_fixup(0); } @@ -2891,7 +2891,7 @@ skipzero: uwsgi_init_all_apps(); } - for (i = 0; i < 0xFF; i++) { + for (i = 0; i < 256; i++) { if (uwsgi.p[i]->post_fork) { uwsgi.p[i]->post_fork(); } @@ -3025,7 +3025,7 @@ skipzero: //initialization done // run fixup handler - for (i = 0; i < 0xFF; i++) { + for (i = 0; i < 256; i++) { if (uwsgi.p[i]->fixup) { uwsgi.p[i]->fixup(); } @@ -3091,7 +3091,7 @@ void uwsgi_ignition() { uwsgi_log("[snapshot] process %d is the new worker %d\n", (int) getpid(), uwsgi.mywid); } - for (i = 0; i < 0xFF; i++) { + for (i = 0; i < 256; i++) { if (uwsgi.p[i]->hijack_worker) { uwsgi.p[i]->hijack_worker(); } @@ -3197,7 +3197,7 @@ void build_options() { op++; } - for(i=0;i<0xFF;i++) { + for(i=0;i<256;i++) { if (uwsgi.p[i]->options) { options_count += uwsgi_count_options(uwsgi.p[i]->options); } @@ -3220,7 +3220,7 @@ void build_options() { op++; } - for(i=0;i<0xFF;i++) { + for(i=0;i<256;i++) { if (uwsgi.p[i]->options) { int c = uwsgi_count_options(uwsgi.p[i]->options); memcpy(&uwsgi.options[pos], uwsgi.p[i]->options, sizeof(struct uwsgi_option) * c); @@ -3353,7 +3353,7 @@ void uwsgi_init_all_apps() { } - for (i = 0; i < 0xFF; i++) { + for (i = 0; i < 256; i++) { if (uwsgi.p[i]->init_apps) { uwsgi.p[i]->init_apps(); } @@ -3371,7 +3371,7 @@ void uwsgi_init_all_apps() { what[0] = 0; what++; uwsgi_log("mounting %s on %s\n", what, uwsgi.mounts[i]); - for (j = 0; j < 0xFF; j++) { + for (j = 0; j < 256; j++) { if (uwsgi.p[j]->mount_app) { if (!uwsgi_startswith(uwsgi.mounts[i], "regexp://", 9)) { if (uwsgi.p[j]->mount_app(uwsgi.mounts[i]+9, what, 1) != -1) diff --git a/uwsgi.h b/uwsgi.h index 6dfd44c6..d4fbea8c 100644 --- a/uwsgi.h +++ b/uwsgi.h @@ -1529,7 +1529,7 @@ struct uwsgi_server { struct uwsgi_loop loops[MAX_LOOPS]; int loops_cnt; - struct uwsgi_plugin *p[0xFF]; + struct uwsgi_plugin *p[256]; struct uwsgi_plugin *gp[MAX_GENERIC_PLUGINS]; int gp_cnt;