tests: 091-coroutine.t: ported ngx_http_lua test cases for 'coroutine.wrap()' propagating errors and 'coroutine.resume()' not logging runtime errors.

Author: thibaultcha

t/091-coroutine.t

@@ -4,7 +4,7 @@ use Test::Nginx::Socket::Lua::Stream;
 
 repeat_each(2);
 
-plan tests => repeat_each() * (blocks() * 3 + 4);
+plan tests => repeat_each() * (blocks() * 3 + 27);
 
 $ENV{TEST_NGINX_RESOLVER} ||= '8.8.8.8';
 
@@ -1092,3 +1092,315 @@ Hello, 2
 ***
 --- no_error_log
 [error]
+
+
+
+=== TEST 28: coroutine.wrap propagates errors to parent coroutine
+--- stream_server_config
+    content_by_lua_block {
+        local co = coroutine.wrap(function()
+            print("in wrapped coroutine")
+            error("something went wrong")
+        end)
+
+        co()
+
+        ngx.say("ok")
+    }
+--- stream_response
+--- error_log eval
+[
+    qr/\[notice\] .*? in wrapped coroutine/,
+    qr/\[error\] .*? lua entry thread aborted: runtime error: content_by_lua\(nginx\.conf:\d+\):\d+: something went wrong/,
+    "stack traceback:",
+    "coroutine 0:",
+    "coroutine 1:"
+]
+
+
+
+=== TEST 29: coroutine.wrap propagates nested errors to parent coroutine
+Note: in this case, both the error message and the traceback are constructed
+from co1's stack level.
+--- stream_server_config
+    content_by_lua_block {
+        local co1 = coroutine.wrap(function()
+            error("something went wrong in co1")
+        end)
+
+        local co2 = coroutine.wrap(function()
+            co1()
+        end)
+
+        co2()
+    }
+--- stream_response
+--- error_log eval
+[
+    qr/\[error\] .*? lua entry thread aborted: runtime error: content_by_lua\(nginx\.conf:\d+\):\d+: something went wrong in co1/,
+    "stack traceback:",
+    "coroutine 0:",
+    "coroutine 1:",
+    "coroutine 2:"
+]
+
+
+
+=== TEST 30: coroutine.wrap propagates nested errors with stack level to parent coroutine
+Note: in this case, the error message is constructed at the entry thread stack
+level, and the traceback is constructed from co1's stack level.
+--- stream_server_config
+    content_by_lua_block {
+        local co1 = coroutine.wrap(function()
+            error("something went wrong in co1", 2)
+        end)
+
+        local co2 = coroutine.wrap(function()
+            co1()
+        end)
+
+        co2()
+    }
+--- stream_response
+--- error_log eval
+[
+    qr/\[error\] .*? lua entry thread aborted: runtime error: something went wrong in co1/,
+    "stack traceback:",
+    "coroutine 0:",
+    "coroutine 1:",
+    "coroutine 2:"
+]
+
+
+
+=== TEST 31: coroutine.wrap runtime errors do not log errors
+--- stream_server_config
+    content_by_lua_block {
+        local co = coroutine.wrap(function()
+            print("in wrapped coroutine")
+            error("something went wrong")
+        end)
+
+        co()
+    }
+--- stream_response
+--- no_error_log eval
+[
+    qr/\[error\] .*? lua coroutine: runtime error:/,
+    "[alert]",
+    "[crit]",
+    "[emerg]",
+    "[warn]",
+]
+
+
+
+=== TEST 32: coroutine.wrap does not return status boolean on yield
+--- stream_server_config
+    content_by_lua_block {
+        local co = coroutine.wrap(function()
+            coroutine.yield("ok", "err")
+        end)
+
+        local ret1, ret2 = co()
+
+        ngx.say(ret1, ", ", ret2)
+    }
+--- stream_response
+ok, err
+--- no_error_log
+[error]
+
+
+
+=== TEST 33: coroutine.wrap does not return status boolean on done
+--- stream_server_config
+    content_by_lua_block {
+        local co = coroutine.wrap(function() end)
+
+        local ret1 = co()
+
+        ngx.say(ret1)
+    }
+--- stream_response
+nil
+--- no_error_log
+[emerg]
+[alert]
+[crit]
+[error]
+[warn]
+
+
+
+=== TEST 34: coroutine.wrap does not return status boolean on error
+--- SKIP: not supported
+--- stream_server_config
+    content_by_lua_block {
+        local co = coroutine.wrap(function()
+            error("something went wrong")
+        end)
+
+        local ret1, ret2 = pcall(co)
+
+        ngx.say(ret1, ", ", ret2)
+    }
+--- response_body
+false, something went wrong
+--- no_error_log
+[error]
+
+
+
+=== TEST 35: coroutine.wrap creates different function refs
+--- stream_server_config
+    content_by_lua_block {
+        local f = function() end
+        local co = coroutine.wrap(f)
+        local co2 = coroutine.wrap(f)
+
+        ngx.say("co == co2: ", co == co2)
+    }
+--- stream_response
+co == co2: false
+--- no_error_log
+[emerg]
+[alert]
+[crit]
+[error]
+[warn]
+
+
+
+=== TEST 36: coroutine.wrap supports yielding and resuming
+--- stream_server_config
+    content_by_lua_block {
+        local function f()
+            local cnt = 0
+            for i = 1, 20 do
+                ngx.say("co yield: ", cnt)
+                coroutine.yield()
+                cnt = cnt + 1
+            end
+        end
+
+        local f = coroutine.wrap(f)
+        for i = 1, 3 do
+            ngx.say("co resume")
+            f()
+        end
+    }
+--- stream_response
+co resume
+co yield: 0
+co resume
+co yield: 1
+co resume
+co yield: 2
+--- no_error_log
+[error]
+
+
+
+=== TEST 37: coroutine.wrap return values
+--- stream_server_config
+    content_by_lua_block {
+        local function f()
+            local cnt = 0
+            for i = 1, 20 do
+                coroutine.yield(cnt, cnt + 1)
+                cnt = cnt + 1
+            end
+        end
+
+        local f = coroutine.wrap(f)
+        for i = 1, 3 do
+            ngx.say("co resume")
+            local ret1, ret2 = f()
+            ngx.say("co yield: ", ret1, ", ", ret2)
+        end
+    }
+--- stream_response
+co resume
+co yield: 0, 1
+co resume
+co yield: 1, 2
+co resume
+co yield: 2, 3
+--- no_error_log
+[error]
+
+
+
+=== TEST 38: coroutine.wrap arguments
+--- stream_server_config
+    content_by_lua_block {
+        local function f(step)
+            local cnt = 0
+            for i = 1, 20 do
+                ngx.say("co yield: ", cnt)
+                coroutine.yield()
+                cnt = cnt + step
+            end
+        end
+
+        local f = coroutine.wrap(f)
+        for i = 1, 3 do
+            ngx.say("co resume")
+            f(i)
+        end
+    }
+--- stream_response
+co resume
+co yield: 0
+co resume
+co yield: 1
+co resume
+co yield: 2
+--- no_error_log
+[error]
+
+
+
+=== TEST 39: coroutine.wrap in init_by_lua propagates errors (orig coroutine.wrap)
+--- stream_config
+    init_by_lua_block {
+        local co = coroutine.wrap(function()
+            print("in wrapped coroutine")
+            error("something went wrong")
+        end)
+
+        local err = co()
+
+        ngx.log(ngx.CRIT, "err: ", err)
+    }
+--- stream_server_config
+    content_by_lua_block {
+        ngx.say("ok")
+    }
+--- must_die
+--- grep_error_log eval: qr/init_by_lua error: .*? something went wrong/
+--- grep_error_log_out
+init_by_lua error: init_by_lua:7: init_by_lua:4: something went wrong
+
+
+
+=== TEST 40: coroutine.resume runtime errors do not log errors
+--- stream_server_config
+    content_by_lua_block {
+        local function f()
+            error("something went wrong")
+        end
+
+        local ret1, ret2 = coroutine.resume(coroutine.create(f))
+        ngx.say(ret1)
+        ngx.say(ret2)
+    }
+--- stream_response_like
+false
+content_by_lua\(nginx.conf:\d+\):\d+: something went wrong
+--- no_error_log eval
+[
+    qr/\[error\] .*? lua coroutine: runtime error:",
+    "stack traceback:",
+]