From 728bfe9470e150ae49a86c24cc7f068289661134 Mon Sep 17 00:00:00 2001
From: Thibault Charbonnier <thibaultcha@me.com>
Date: Thu, 8 Feb 2018 13:26:47 -0800
Subject: [PATCH] feature: added the ngx.configure module and APIs.
---
.travis.yml | 2 +-
lib/ngx/configure.lua | 159 ++++++++
lib/resty/core/phase.lua | 8 +-
lib/resty/core/shdict.lua | 5 +
t/configure.t | 837 ++++++++++++++++++++++++++++++++++++++
5 files changed, 1009 insertions(+), 2 deletions(-)
create mode 100644 lib/ngx/configure.lua
create mode 100644 t/configure.t
diff --git a/.travis.yml b/.travis.yml
index a7b544881..8306e872b 100644
--- a/.travis.yml
+++ b/.travis.yml
@@ -61,7 +61,7 @@ install:
- git clone https://github.com/openresty/openresty.git ../openresty
- git clone https://github.com/openresty/openresty-devel-utils.git
- git clone https://github.com/simpl/ngx_devel_kit.git ../ndk-nginx-module
- - git clone https://github.com/openresty/lua-nginx-module.git ../lua-nginx-module
+ - git clone -b feat/configure-by-lua https://github.com/thibaultcha/lua-nginx-module.git ../lua-nginx-module
- git clone https://github.com/openresty/no-pool-nginx.git ../no-pool-nginx
- git clone https://github.com/openresty/echo-nginx-module.git ../echo-nginx-module
- git clone https://github.com/openresty/lua-resty-lrucache.git
diff --git a/lib/ngx/configure.lua b/lib/ngx/configure.lua
new file mode 100644
index 000000000..1da390900
--- /dev/null
+++ b/lib/ngx/configure.lua
@@ -0,0 +1,159 @@
+-- Copyright (C) Yichun Zhang (agentzh)
+--
+-- Author: Thibault Charbonnier (thibaultcha)
+
+
+local base = require "resty.core.base"
+base.allows_subsystem("http")
+
+
+local ffi = require "ffi"
+local C = ffi.C
+--local FFI_OK = base.FFI_OK
+local FFI_ERROR = base.FFI_ERROR
+local FFI_DECLINED = base.FFI_DECLINED
+local ffi_str = ffi.string
+local get_string_buf = base.get_string_buf
+local get_size_ptr = base.get_size_ptr
+local find = string.find
+local type = type
+
+
+local ERR_BUF_SIZE = 128
+
+
+ffi.cdef [[
+ unsigned int ngx_http_lua_ffi_is_configure_phase();
+
+ int ngx_http_lua_ffi_configure_shared_dict(ngx_str_t *name,
+ ngx_str_t *size, unsigned char *errstr, size_t *errlen);
+
+ void ngx_http_lua_ffi_configure_max_pending_timers(int n_timers);
+
+ void ngx_http_lua_ffi_configure_max_running_timers(int n_timers);
+
+ int ngx_http_lua_ffi_configure_env(const unsigned char *value,
+ size_t name_len, size_t len);
+]]
+
+
+local _M = { version = base.version }
+
+
+function _M.is_configure_phase()
+ return C.ngx_http_lua_ffi_is_configure_phase() == 1
+end
+
+
+do
+ local name_str_t = ffi.new("ngx_str_t[1]")
+ local size_str_t = ffi.new("ngx_str_t[1]")
+
+
+ function _M.shared_dict(name, size)
+ if not _M.is_configure_phase() then
+ error("API disabled in the current context", 2)
+ end
+
+ if type(name) ~= "string" then
+ error("name must be a string", 2)
+ end
+
+ if type(size) ~= "string" then
+ error("size must be a string", 2)
+ end
+
+ local name_len = #name
+ if name_len == 0 then
+ error("invalid lua shared dict name", 2)
+ end
+
+ local size_len = #size
+ if size_len == 0 then
+ error("invalid lua shared dict size", 2)
+ end
+
+ local name_t = name_str_t[0]
+ local size_t = size_str_t[0]
+
+ name_t.data = name
+ name_t.len = name_len
+
+ size_t.data = size
+ size_t.len = size_len
+
+ local err = get_string_buf(ERR_BUF_SIZE)
+ local errlen = get_size_ptr()
+ errlen[0] = ERR_BUF_SIZE
+
+ local rc = C.ngx_http_lua_ffi_configure_shared_dict(name_str_t,
+ size_str_t, err,
+ errlen)
+ if rc == FFI_DECLINED then
+ error(ffi_str(err, errlen[0]), 2)
+ end
+
+ if rc == FFI_ERROR then
+ error("no memory")
+ end
+
+ -- NGINX_OK/FFI_OK
+ end
+end
+
+
+function _M.max_pending_timers(n_timers)
+ if not _M.is_configure_phase() then
+ error("API disabled in the current context", 2)
+ end
+
+ if type(n_timers) ~= "number" then
+ error("n_timers must be a number", 2)
+ end
+
+ if n_timers < 0 then
+ error("n_timers must be positive", 2)
+ end
+
+ C.ngx_http_lua_ffi_configure_max_pending_timers(n_timers)
+end
+
+
+function _M.max_running_timers(n_timers)
+ if not _M.is_configure_phase() then
+ error("API disabled in the current context", 2)
+ end
+
+ if type(n_timers) ~= "number" then
+ error("n_timers must be a number", 2)
+ end
+
+ if n_timers < 0 then
+ error("n_timers must be positive", 2)
+ end
+
+ C.ngx_http_lua_ffi_configure_max_running_timers(n_timers)
+end
+
+
+function _M.env(value)
+ if not _M.is_configure_phase() then
+ error("API disabled in the current context", 2)
+ end
+
+ if type(value) ~= "string" then
+ error("value must be a string", 2)
+ end
+
+ local len = #value
+ local idx = find(value, "=")
+
+ local rc = C.ngx_http_lua_ffi_configure_env(value, idx and idx - 1 or len,
+ len)
+ if rc == FFI_ERROR then
+ error("no memory")
+ end
+end
+
+
+return _M
diff --git a/lib/resty/core/phase.lua b/lib/resty/core/phase.lua
index d83d0f3ea..569e48b7f 100644
--- a/lib/resty/core/phase.lua
+++ b/lib/resty/core/phase.lua
@@ -1,5 +1,6 @@
local ffi = require 'ffi'
local base = require "resty.core.base"
+local ngx_configure = require "ngx.configure"
local C = ffi.C
local FFI_ERROR = base.FFI_ERROR
@@ -33,8 +34,13 @@ local context_names = {
function ngx.get_phase()
local r = getfenv(0).__ngx_req
- -- if we have no request object, assume we are called from the "init" phase
+ -- if we have no request object, assume we are called from the "init"
+ -- or "configure" phase
if not r then
+ if ngx_configure.is_configure_phase() then
+ return "configure"
+ end
+
return "init"
end
diff --git a/lib/resty/core/shdict.lua b/lib/resty/core/shdict.lua
index 55f2a88a9..27a2381ab 100644
--- a/lib/resty/core/shdict.lua
+++ b/lib/resty/core/shdict.lua
@@ -3,6 +3,7 @@
local ffi = require 'ffi'
local base = require "resty.core.base"
+local ngx_configure = require "ngx.configure"
local ffi_new = ffi.new
local ffi_str = ffi.string
@@ -71,6 +72,10 @@ local errmsg = base.get_errmsg_ptr()
local function check_zone(zone)
+ if ngx_configure.is_configure_phase() then
+ error("API disabled in the context of configure_by_lua", 3)
+ end
+
if not zone or type(zone) ~= "table" then
return error("bad \"zone\" argument")
end
diff --git a/t/configure.t b/t/configure.t
new file mode 100644
index 000000000..0d9fa6d73
--- /dev/null
+++ b/t/configure.t
@@ -0,0 +1,837 @@
+# vim:set ft= ts=4 sw=4 et fdm=marker:
+
+use Test::Nginx::Socket::Lua;
+use Cwd qw(cwd);
+
+repeat_each(2);
+
+plan tests => repeat_each() * (blocks() * 5);
+
+my $pwd = cwd();
+
+our $HttpConfig = <<_EOC_;
+ lua_package_path "$pwd/lib/?.lua;../lua-resty-lrucache/lib/?.lua;;";
+_EOC_
+
+env_to_nginx("TEST_NGINX_ENV=hello");
+
+check_accum_error_log();
+run_tests();
+
+__DATA__
+
+=== TEST 1: ngx_configure.is_configure_phase()
+--- http_config eval
+qq{
+ configure_by_lua_block {
+ local ngx_configure = require "ngx.configure"
+
+ print("is configure: ", ngx_configure.is_configure_phase())
+ }
+
+ $::HttpConfig
+}
+--- config
+ location = /t {
+ content_by_lua_block {
+ local ngx_configure = require "ngx.configure"
+
+ ngx.say("is configure: ", ngx_configure.is_configure_phase())
+ }
+ }
+--- request
+GET /t
+--- response_body
+is configure: false
+--- error_log
+is configure: true
+--- no_error_log
+[error]
+[alert]
+
+
+
+=== TEST 2: configure_by_lua resty.core ngx.get_phase()
+--- http_config eval
+qq{
+ configure_by_lua_block {
+ require "resty.core.phase"
+
+ print("phase: ", ngx.get_phase())
+ }
+
+ $::HttpConfig
+}
+--- config
+ location = /t {
+ return 200;
+ }
+--- request
+GET /t
+--- ignore_response_body
+--- error_log
+phase: configure
+--- no_error_log
+[error]
+[alert]
+[crit]
+
+
+
+=== TEST 3: ngx_configure.shared_dict (invalid context)
+--- http_config eval: $::HttpConfig
+--- config
+ location /t {
+ content_by_lua_block {
+ local ngx_configure = require "ngx.configure"
+
+ ngx_configure.shared_dict("dogs", "12k")
+ }
+ }
+--- request
+GET /t
+--- error_code: 500
+--- error_log eval
+qr/\[error\] .*? content_by_lua\(nginx.conf:\d+\):\d+: API disabled in the current context/
+--- no_error_log
+[crit]
+[alert]
+[emerg]
+
+
+
+=== TEST 4: ngx_configure.shared_dict (invalid arguments)
+--- http_config eval
+qq{
+ configure_by_lua_block {
+ local ngx_configure = require "ngx.configure"
+
+ local pok, err = pcall(ngx_configure.shared_dict)
+ if not pok then
+ print(err)
+ end
+ }
+
+ $::HttpConfig
+}
+--- config
+ location /t {
+ return 200;
+ }
+--- request
+GET /t
+--- error_log eval
+qr/\[notice\] .*? configure_by_lua:\d+: name must be a string/
+--- no_error_log
+[crit]
+[alert]
+[emerg]
+
+
+
+=== TEST 5: ngx_configure.shared_dict (invalid name)
+--- http_config eval
+qq{
+ configure_by_lua_block {
+ local ngx_configure = require "ngx.configure"
+
+ ngx_configure.shared_dict("", "12k")
+ }
+
+ $::HttpConfig
+}
+--- config
+ location /t {
+ return 200;
+ }
+--- must_die
+--- error_log eval
+qr/\[error\] .*? configure_by_lua:\d+: invalid lua shared dict name/
+--- no_error_log
+[crit]
+[alert]
+[emerg]
+
+
+
+=== TEST 6: ngx_configure.shared_dict (invalid size)
+--- http_config eval
+qq{
+ configure_by_lua_block {
+ local ngx_configure = require "ngx.configure"
+
+ local pok, perr = pcall(ngx_configure.shared_dict, "dogs", "")
+ if not pok then
+ print("1: ", perr)
+ end
+
+ local pok, perr = pcall(ngx_configure.shared_dict, "dogs", "foo")
+ if not pok then
+ print("2: ", perr)
+ end
+
+ local pok, perr = pcall(ngx_configure.shared_dict, "dogs", "128")
+ if not pok then
+ print("3: ", perr)
+ end
+ }
+
+ $::HttpConfig
+}
+--- config
+ location /t {
+ return 200;
+ }
+--- request
+GET /t
+--- error_log eval
+[qr/\[notice\] .*? configure_by_lua:\d+: 1: invalid lua shared dict size/,
+qr/\[notice\] .*? configure_by_lua:\d+: 2: invalid lua shared dict size "foo"/,
+qr/\[notice\] .*? configure_by_lua:\d+: 3: invalid lua shared dict size "128"/]
+--- no_error_log
+[emerg]
+
+
+
+=== TEST 7: ngx_configure.shared_dict (already defined)
+--- http_config eval
+qq{
+ lua_shared_dict dogs 12k;
+
+ configure_by_lua_block {
+ local ngx_configure = require "ngx.configure"
+
+ ngx_configure.shared_dict("dogs", "12k")
+ }
+
+ $::HttpConfig
+}
+--- config
+ location /t {
+ return 200;
+ }
+--- request
+GET /t
+--- must_die
+--- error_log eval
+qr/\[error\] .*? configure_by_lua:\d+: lua_shared_dict "dogs" is already defined as "dogs"/
+--- no_error_log
+[crit]
+[alert]
+[emerg]
+
+
+
+=== TEST 8: ngx_configure.shared_dict (creates working shm)
+--- http_config eval
+qq{
+ configure_by_lua_block {
+ local ngx_configure = require "ngx.configure"
+
+ ngx_configure.shared_dict("dogs", "12k")
+ }
+
+ $::HttpConfig
+}
+--- config
+ location /t {
+ content_by_lua_block {
+ local dogs = ngx.shared.dogs
+
+ dogs:set("foo", true)
+
+ ngx.say("foo = ", dogs:get("foo"))
+ }
+ }
+--- request
+GET /t
+--- response_body
+foo = true
+--- no_error_log
+[crit]
+[alert]
+[emerg]
+
+
+
+=== TEST 9: ngx_configure.shared_dict (delays init phase until shms are init)
+--- http_config eval
+qq{
+ configure_by_lua_block {
+ local ngx_configure = require "ngx.configure"
+
+ ngx_configure.shared_dict("dogs_init", "12k")
+ }
+
+ init_by_lua_block {
+ local dogs = ngx.shared.dogs_init
+
+ dogs:set("foo", true)
+
+ ngx.log(ngx.NOTICE, "foo = ", dogs:get("foo"))
+ }
+
+ $::HttpConfig
+}
+--- config
+ location /t {
+ return 200;
+ }
+--- request
+GET /t
+--- error_log eval
+qr/\[notice\] .*? init_by_lua:\d+: foo = true/
+--- no_error_log
+[crit]
+[alert]
+[emerg]
+
+
+
+=== TEST 10: ngx_configure.shared_dict (disables shm API in configure phase 1/2)
+--- http_config eval
+qq{
+ configure_by_lua_block {
+ local ngx_configure = require "ngx.configure"
+
+ ngx_configure.shared_dict("dogs", "12k")
+
+ ngx.shared.dogs:set("foo", true)
+ }
+
+ $::HttpConfig
+}
+--- config
+ location /t {
+ return 200;
+ }
+--- must_die
+--- error_log eval
+qr/\[error\] .*? configure_by_lua:\d+: API disabled in the context of configure_by_lua/
+--- no_error_log
+[crit]
+[alert]
+[emerg]
+
+
+
+=== TEST 11: ngx_configure.shared_dict (disables shm API in configure phase 2/2)
+--- http_config eval
+qq{
+ configure_by_lua_block {
+ local ngx_configure = require "ngx.configure"
+
+ ngx_configure.shared_dict("dogs", "12k")
+
+ ngx.shared.dogs:get("foo")
+ }
+
+ $::HttpConfig
+}
+--- config
+ location /t {
+ return 200;
+ }
+--- must_die
+--- error_log eval
+qr/\[error\] .*? configure_by_lua:\d+: API disabled in the context of configure_by_lua/
+--- no_error_log
+[crit]
+[alert]
+[emerg]
+
+
+
+=== TEST 12: ngx_configure.shared_dict (disables resty.core shm API in configure phase)
+--- http_config eval
+qq{
+ configure_by_lua_block {
+ local ngx_configure = require "ngx.configure"
+
+ ngx_configure.shared_dict("dogs", "12k")
+
+ -- TODO: requiring resty.core before creating shdicts would nullify
+ -- the core/shdict.lua metatable overrides, since `next(ngx_shared)` is
+ -- nil until we create shms. We should not allow resty.core in configure,
+ -- or find a way to trigger the metatable overrides if it is required
+ -- before any shm is created.
+ require "resty.core"
+
+ ngx.shared.dogs:get("foo")
+ }
+
+ $::HttpConfig
+}
+--- config
+ location /t {
+ return 200;
+ }
+--- must_die
+--- error_log eval
+qr/\[error\] .*? configure_by_lua:\d+: API disabled in the context of configure_by_lua/
+--- no_error_log
+[crit]
+[alert]
+[emerg]
+
+
+
+=== TEST 13: ngx_configure.shared_dict (sanity with multiple static shms)
+--- http_config eval
+qq{
+ lua_shared_dict cats 128k;
+ lua_shared_dict dogs 128k;
+
+ init_by_lua_block {
+ assert(ngx.shared.cats:set("marry", "black"))
+ assert(ngx.shared.dogs:incr("count", 1, 0))
+ }
+
+ $::HttpConfig
+}
+--- config
+ location /t {
+ content_by_lua_block {
+ local cats = ngx.shared.cats
+ local dogs = ngx.shared.dogs
+
+ ngx.say("cats marry = ", cats:get("marry"))
+ ngx.say("dogs count = ", dogs:get("count"))
+ }
+ }
+--- request
+GET /t
+--- response_body
+cats marry = black
+dogs count = 1
+--- no_error_log
+[crit]
+[alert]
+[emerg]
+
+
+
+=== TEST 14: ngx_configure.shared_dict (sanity with multiple dynamic shms)
+--- http_config eval
+qq{
+ configure_by_lua_block {
+ local ngx_configure = require "ngx.configure"
+
+ ngx_configure.shared_dict("cats", "128k")
+ ngx_configure.shared_dict("dogs", "128k")
+ }
+
+ init_by_lua_block {
+ assert(ngx.shared.cats:set("marry", "black"))
+ assert(ngx.shared.dogs:incr("count", 1, 0))
+ }
+
+ $::HttpConfig
+}
+--- config
+ location /t {
+ content_by_lua_block {
+ local cats = ngx.shared.cats
+ local dogs = ngx.shared.dogs
+
+ ngx.say("cats marry = ", cats:get("marry"))
+ ngx.say("dogs count = ", dogs:get("count"))
+ }
+ }
+--- request
+GET /t
+--- response_body
+cats marry = black
+dogs count = 1
+--- no_error_log
+[crit]
+[alert]
+[emerg]
+
+
+
+=== TEST 15: ngx_configure.shared_dict (sanity with multiple mixed shms)
+--- http_config eval
+qq{
+ lua_shared_dict cats 128k;
+ lua_shared_dict dogs 128k;
+
+ configure_by_lua_block {
+ local ngx_configure = require "ngx.configure"
+
+ ngx_configure.shared_dict("my_shm", "128k")
+ }
+
+ init_by_lua_block {
+ assert(ngx.shared.cats:set("marry", "black"))
+ assert(ngx.shared.dogs:incr("count", 1, 0))
+ assert(ngx.shared.my_shm:incr("count", 1, 127))
+ }
+
+ $::HttpConfig
+}
+--- config
+ location /t {
+ content_by_lua_block {
+ local cats = ngx.shared.cats
+ local dogs = ngx.shared.dogs
+ local my_shm = ngx.shared.my_shm
+
+ ngx.say("cats marry = ", cats:get("marry"))
+ ngx.say("dogs count = ", dogs:get("count"))
+ ngx.say("my_shm count = ", my_shm:get("count"))
+ }
+ }
+--- request
+GET /t
+--- response_body
+cats marry = black
+dogs count = 1
+my_shm count = 128
+--- no_error_log
+[crit]
+[alert]
+[emerg]
+
+
+
+=== TEST 16: ngx_configure.max_pending_timers (sanity with 1)
+--- http_config eval
+qq{
+ configure_by_lua_block {
+ local ngx_configure = require "ngx.configure"
+
+ ngx_configure.max_pending_timers(1)
+ }
+
+ $::HttpConfig
+}
+--- config
+ location /t {
+ content_by_lua_block {
+ local ok, err = ngx.timer.at(10, function() end)
+ if not ok then
+ ngx.log(ngx.ERR, "failed to set timer 1: ", err)
+ return
+ end
+
+ local ok, err = ngx.timer.at(10, function() end)
+ if not ok then
+ ngx.log(ngx.ERR, "failed to set timer 2: ", err)
+ return
+ end
+
+ ngx.say("ok")
+ }
+ }
+--- request
+GET /t
+--- ignore_response_body
+--- error_log
+failed to set timer 2: too many pending timers
+--- no_error_log
+[crit]
+[alert]
+[emerg]
+
+
+
+=== TEST 17: ngx_configure.max_pending_timers (arg not number)
+--- http_config eval
+qq{
+ configure_by_lua_block {
+ local ngx_configure = require "ngx.configure"
+
+ ngx_configure.max_pending_timers("foo")
+ }
+
+ $::HttpConfig
+}
+--- config
+ location /t {
+ return 200;
+ }
+--- request
+GET /t
+--- must_die
+--- error_log eval
+qr/\[error\] .*? configure_by_lua:\d+: n_timers must be a number/
+--- no_error_log
+[crit]
+[alert]
+[emerg]
+
+
+
+=== TEST 18: ngx_configure.max_pending_timers (arg not positive)
+--- http_config eval
+qq{
+ configure_by_lua_block {
+ local ngx_configure = require "ngx.configure"
+
+ ngx_configure.max_pending_timers(-1)
+ }
+
+ $::HttpConfig
+}
+--- config
+ location /t {
+ return 200;
+ }
+--- request
+GET /t
+--- must_die
+--- error_log eval
+qr/\[error\] .*? configure_by_lua:\d+: n_timers must be positive/
+--- no_error_log
+[crit]
+[alert]
+[emerg]
+
+
+
+=== TEST 19: ngx_configure.max_pending_timers (invalid context)
+--- http_config eval: $::HttpConfig
+--- config
+ location /t {
+ content_by_lua_block {
+ local ngx_configure = require "ngx.configure"
+
+ ngx_configure.max_pending_timers(1)
+ }
+ }
+--- request
+GET /t
+--- error_code: 500
+--- error_log eval
+qr/\[error\] .*? content_by_lua\(nginx.conf:\d+\):\d+: API disabled in the current context/
+--- no_error_log
+[crit]
+[alert]
+[emerg]
+
+
+
+=== TEST 20: ngx_configure.max_running_timers (sanity with 1)
+--- http_config eval
+qq{
+ configure_by_lua_block {
+ local ngx_configure = require "ngx.configure"
+
+ ngx_configure.max_running_timers(1)
+ }
+
+ $::HttpConfig
+}
+--- config
+ location /t {
+ content_by_lua_block {
+ local ok, err = ngx.timer.at(0, function() ngx.sleep(0.002) end)
+ if not ok then
+ ngx.log(ngx.ERR, "failed to set timer 1: ", err)
+ return
+ end
+
+ local ok, err = ngx.timer.at(0, function() end)
+ if not ok then
+ ngx.log(ngx.ERR, "failed to set timer 2: ", err)
+ return
+ end
+
+ ngx.sleep(0.001)
+
+ ngx.say("ok")
+ }
+ }
+--- request
+GET /t
+--- ignore_response_body
+--- error_log eval
+qr/\[alert\] .*? 1 lua_max_running_timers are not enough/
+--- no_error_log
+[crit]
+[error]
+[emerg]
+
+
+
+=== TEST 21: ngx_configure.max_running_timers (arg not number)
+--- http_config eval
+qq{
+ configure_by_lua_block {
+ local ngx_configure = require "ngx.configure"
+
+ ngx_configure.max_running_timers("foo")
+ }
+
+ $::HttpConfig
+}
+--- config
+ location /t {
+ return 200;
+ }
+--- request
+GET /t
+--- must_die
+--- error_log eval
+qr/\[error\] .*? configure_by_lua:\d+: n_timers must be a number/
+--- no_error_log
+[crit]
+[alert]
+[emerg]
+
+
+
+=== TEST 22: ngx_configure.max_running_timers (arg not positive)
+--- http_config eval
+qq{
+ configure_by_lua_block {
+ local ngx_configure = require "ngx.configure"
+
+ ngx_configure.max_running_timers(-1)
+ }
+
+ $::HttpConfig
+}
+--- config
+ location /t {
+ return 200;
+ }
+--- request
+GET /t
+--- must_die
+--- error_log eval
+qr/\[error\] .*? configure_by_lua:\d+: n_timers must be positive/
+--- no_error_log
+[crit]
+[alert]
+[emerg]
+
+
+
+=== TEST 23: ngx_configure.max_running_timers (invalid context)
+--- http_config eval: $::HttpConfig
+--- config
+ location /t {
+ content_by_lua_block {
+ local ngx_configure = require "ngx.configure"
+
+ ngx_configure.max_running_timers(1)
+ }
+ }
+--- request
+GET /t
+--- error_code: 500
+--- error_log eval
+qr/\[error\] .*? content_by_lua\(nginx.conf:\d+\):\d+: API disabled in the current context/
+--- no_error_log
+[crit]
+[alert]
+[emerg]
+
+
+
+=== TEST 24: ngx_configure.env (invalid context)
+--- http_config eval: $::HttpConfig
+--- config
+ location /t {
+ content_by_lua_block {
+ local ngx_configure = require "ngx.configure"
+
+ ngx_configure.env("FOO")
+ }
+ }
+--- request
+GET /t
+--- error_code: 500
+--- error_log eval
+qr/\[error\] .*? content_by_lua\(nginx.conf:\d+\):\d+: API disabled in the current context/
+--- no_error_log
+[crit]
+[alert]
+[emerg]
+
+
+
+=== TEST 25: ngx_configure.env (sanity)
+--- http_config eval
+qq{
+ configure_by_lua_block {
+ local ngx_configure = require "ngx.configure"
+
+ ngx_configure.env("TEST_NGINX_ENV")
+ }
+
+ $::HttpConfig
+}
+--- config
+ location /t {
+ content_by_lua_block {
+ ngx.say("TEST_NGINX_ENV: ", os.getenv("TEST_NGINX_ENV"))
+ }
+ }
+--- request
+GET /t
+--- response_body
+TEST_NGINX_ENV: hello
+--- no_error_log
+[crit]
+[alert]
+[emerg]
+
+
+
+=== TEST 26: ngx_configure.env (with set env variable)
+--- http_config eval
+qq{
+ configure_by_lua_block {
+ local ngx_configure = require "ngx.configure"
+
+ ngx_configure.env("TEST_NGINX_ENV_SET=foo")
+ }
+
+ $::HttpConfig
+}
+--- config
+ location /t {
+ content_by_lua_block {
+ ngx.say("TEST_NGINX_ENV_SET: ", os.getenv("TEST_NGINX_ENV_SET"))
+ }
+ }
+--- request
+GET /t
+--- response_body
+TEST_NGINX_ENV_SET: foo
+--- no_error_log
+[crit]
+[alert]
+[emerg]
+
+
+
+=== TEST 27: ngx_configure.env (invalid arg)
+--- http_config eval
+qq{
+ configure_by_lua_block {
+ local ngx_configure = require "ngx.configure"
+
+ ngx_configure.env(123)
+ }
+
+ $::HttpConfig
+}
+--- config
+ location /t {
+ content_by_lua_block {
+ ngx.say("TEST_NGINX_ENV_SET: ", os.getenv("TEST_NGINX_ENV_SET"))
+ }
+ }
+--- request
+GET /t
+--- must_die
+--- error_log eval
+qr/\[error\] .*? configure_by_lua:\d+: value must be a string/
+--- no_error_log
+[crit]
+[alert]
+[emerg]