diff options
Diffstat (limited to 'src/nxt_application.c')
| -rw-r--r-- | src/nxt_application.c | 47 |
1 files changed, 47 insertions, 0 deletions
diff --git a/src/nxt_application.c b/src/nxt_application.c index ef15ab2b..186614a0 100644 --- a/src/nxt_application.c +++ b/src/nxt_application.c @@ -32,6 +32,7 @@ static void nxt_discovery_quit(nxt_task_t *task, nxt_port_recv_msg_t *msg, void *data); static nxt_app_module_t *nxt_app_module_load(nxt_task_t *task, const char *name); +static nxt_int_t nxt_app_set_environment(nxt_conf_value_t *environment); static void nxt_app_http_release(nxt_task_t *task, void *obj, void *data); @@ -344,6 +345,13 @@ nxt_app_start(nxt_task_t *task, void *data) } } + if (nxt_slow_path(nxt_app_set_environment(app_conf->environment) + != NXT_OK)) + { + nxt_alert(task, "failed to set environment"); + return NXT_ERROR; + } + if (nxt_slow_path(nxt_thread_mutex_create(&nxt_app_mutex) != NXT_OK)) { return NXT_ERROR; } @@ -382,6 +390,45 @@ nxt_app_module_load(nxt_task_t *task, const char *name) } +static nxt_int_t +nxt_app_set_environment(nxt_conf_value_t *environment) +{ + char *env, *p; + uint32_t next; + nxt_str_t name, value; + nxt_conf_value_t *value_obj; + + if (environment != NULL) { + next = 0; + + for ( ;; ) { + value_obj = nxt_conf_next_object_member(environment, &name, &next); + if (value_obj == NULL) { + break; + } + + nxt_conf_get_string(value_obj, &value); + + env = nxt_malloc(name.length + value.length + 2); + if (nxt_slow_path(env == NULL)) { + return NXT_ERROR; + } + + p = nxt_cpymem(env, name.start, name.length); + *p++ = '='; + p = nxt_cpymem(p, value.start, value.length); + *p = '\0'; + + if (nxt_slow_path(putenv(env) != 0)) { + return NXT_ERROR; + } + } + } + + return NXT_OK; +} + + void nxt_app_quit_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) { |