apisix/t/stream-node/random.t

#
# Licensed to the Apache Software Foundation (ASF) under one or more
# contributor license agreements.  See the NOTICE file distributed with
# this work for additional information regarding copyright ownership.
# The ASF licenses this file to You under the Apache License, Version 2.0
# (the "License"); you may not use this file except in compliance with
# the License.  You may obtain a copy of the License at
#
#     http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
#
use t::APISIX 'no_plan';

master_on();
workers(4);
log_level('info');
repeat_each(1);
no_long_string();
no_root_location();

run_tests();

__DATA__

=== TEST 1: generate different random number in different worker process
--- stream_enable
--- config
    location /test {
        content_by_lua_block {
            ngx.sleep(0.3)
            local log_file = ngx.config.prefix() .. "logs/error.log"
            local file = io.open(log_file, "r")
            local log = file:read("*a")

            local it, err = ngx.re.gmatch(log, [[random stream test in \[1, 10000\]: (\d+)]], "jom")
            if not it then
                ngx.log(ngx.ERR, "failed to gmatch: ", err)
                return
            end

            local random_nums = {}
            while true do
                local m, err = it()
                if err then
                    ngx.log(ngx.ERR, "error: ", err)
                    return
                end

                if not m then
                    break
                end

                -- found a match
                table.insert(random_nums, m[1])
            end

            for i = 2, #random_nums do
                local pre = random_nums[i - 1]
                local cur = random_nums[i]
                ngx.say("random[", i - 1, "] == random[", i, "]: ", pre == cur)
                if not pre == cur then
                    ngx.say("random info in log: ", table.concat(random_nums, ", "))
                    break
                end
            end
        }
    }
--- request
GET /test
--- response_body
random[1] == random[2]: false
random[2] == random[3]: false
random[3] == random[4]: false
random[4] == random[5]: false
--- no_error_log
[error]