bugfix: windows also need to support ngx_http_lua_ffi_worker_pids.

Author: zhuizhuhaomeng

README.markdown

@@ -9034,7 +9034,7 @@ ngx.worker.pids
 
 **context:** *set_by_lua*, rewrite_by_lua*, access_by_lua*, content_by_lua*, header_filter_by_lua*, body_filter_by_lua*, log_by_lua*, ngx.timer.*, exit_worker_by_lua**
 
-This function returns a Lua table for all Nginx worker process ID (PID). Nginx uses channel to send the current worker PID to another worker in the worker process start or restart. So this API can get all current worker PID.
+This function returns a Lua table for all Nginx worker process IDs (PIDs). Nginx uses channel to send the current worker PID to another worker in the worker process start or restart. So this API can get all current worker PIDs. Windows does not have this API.
 
 This API was first introduced in the `0.10.23` release.
 

src/ngx_http_lua_worker.c

@@ -37,11 +37,12 @@ ngx_http_lua_ffi_worker_pids(int *pids, size_t *pids_len)
             break;
         }
 
-        if (i == ngx_process_slot && ngx_processes[i].pid == 0) {
+        /* The current process */
+        if (i == ngx_process_slot) {
             pids[n++] = ngx_pid;
         }
 
-        if (ngx_processes[i].pid > 0) {
+        if (ngx_processes[i].channel[0] > 0 && ngx_processes[i].pid > 0) {
             pids[n++] = ngx_processes[i].pid;
         }
     }

t/122-worker-2.t

@@ -0,0 +1,49 @@
+# vim:set ft= ts=4 sw=4 et fdm=marker:
+
+use Test::Nginx::Socket::Lua;
+
+#worker_connections(1014);
+master_on();
+workers(4);
+#log_level('warn');
+
+repeat_each(2);
+
+plan tests => repeat_each() * (blocks() * 3);
+
+#no_diff();
+no_long_string();
+run_tests();
+
+__DATA__
+
+=== TEST 1: get worker pids with multiple worker
+--- config
+    location /lua {
+        content_by_lua_block {
+            local pids, err = ngx.worker.pids()
+            if err ~= nil then
+                return
+            end
+            local pid = ngx.worker.pid()
+            ngx.say("worker pid: ", pid)
+            local count = ngx.worker.count()
+            ngx.say("worker count: ", count)
+            ngx.say("worker pids count: ", #pids)
+            for i = 1, count do
+                if pids[i] == pid then
+                    ngx.say("worker pid is correct.")
+                    return
+                end
+            end
+        }
+    }
+--- request
+GET /lua
+--- response_body_like
+worker pid: \d+
+worker count: 4
+worker pids count: 4
+worker pid is correct\.
+--- no_error_log
+[error]

t/122-worker-3.t

@@ -0,0 +1,58 @@
+# vim:set ft= ts=4 sw=4 et fdm=marker:
+our $SkipReason;
+
+BEGIN {
+    if ($ENV{TEST_NGINX_CHECK_LEAK}) {
+        $SkipReason = "unavailable for the hup tests";
+
+    } else {
+        $ENV{TEST_NGINX_USE_HUP} = 1;
+        undef $ENV{TEST_NGINX_USE_STAP};
+    }
+}
+
+use Test::Nginx::Socket::Lua 'no_plan';
+
+#worker_connections(1014);
+master_on();
+workers(4);
+#log_level('warn');
+
+repeat_each(2);
+
+#no_diff();
+no_long_string();
+run_tests();
+
+__DATA__
+
+=== TEST 1: get worker pids with multiple worker
+--- config
+    location /lua {
+        content_by_lua_block {
+            local pids, err = ngx.worker.pids()
+            if err ~= nil then
+                return
+            end
+            local pid = ngx.worker.pid()
+            ngx.say("worker pid: ", pid)
+            local count = ngx.worker.count()
+            ngx.say("worker count: ", count)
+            ngx.say("worker pids count: ", #pids)
+            for i = 1, count do
+                if pids[i] == pid then
+                    ngx.say("worker pid is correct.")
+                    return
+                end
+            end
+        }
+    }
+--- request
+GET /lua
+--- response_body_like
+worker pid: \d+
+worker count: 4
+worker pids count: 4
+worker pid is correct\.
+--- no_error_log
+[error]