[tarantool-patches] Re: [PATCH v1 1/1] box: increase connection timeout in "net.box.test.lua"

Vladislav Shpilevoy v.shpilevoy at tarantool.org
Tue Jul 16 01:13:17 MSK 2019


LGTM.

On 15/07/2019 12:20, imeevma at tarantool.org wrote:
> The "box/net.box.test.lua" test contains a check that the error
> received contains a 'timed out'. But in cases when testing was
> conducted on a slow computer or in the case of a very large load,
> it is possible that the connection time-out will be reached
> earlier than the mentioned error. In this case, the error "Invalid
> argument" will be returned. To prevent this from happening,
> this patch will increase the connection timeout.
> 
> Closes #4341
> ---
> The patch was tested by @avtikhon. The specified error no longer
> occurs.
> 
> https://github.com/tarantool/tarantool/issues/4341
> https://github.com/tarantool/tarantool/tree/imeevma/gh-4341-increase-connection-timeout
> 
>  test/box/net.box.result   | 10 ++++++++--
>  test/box/net.box.test.lua |  8 ++++++--
>  2 files changed, 14 insertions(+), 4 deletions(-)
> 
> diff --git a/test/box/net.box.result b/test/box/net.box.result
> index 6467629..0803956 100644
> --- a/test/box/net.box.result
> +++ b/test/box/net.box.result
> @@ -2109,6 +2109,9 @@ test_run:cmd("setopt delimiter ';'");
>  ---
>  - true
>  ...
> +need_stop = false;
> +---
> +...
>  greeting =
>  "Tarantool 1.7.3 (Lua console)~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~\n" ..
>  "type 'help' for interactive help~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~\n";
> @@ -2120,7 +2123,9 @@ socket = require('socket');
>  srv = socket.tcp_server('localhost', 0, {
>      handler = function(fd)
>          local fiber = require('fiber')
> -        fiber.sleep(0.1)
> +        while not need_stop do
> +            fiber.sleep(0.01)
> +        end
>          fd:write(greeting)
>      end
>  });
> @@ -2130,7 +2135,7 @@ srv = socket.tcp_server('localhost', 0, {
>  port = srv:name().port
>  nb = net.new('localhost:' .. port, {
>      wait_connected = true, console = true,
> -    connect_timeout = 0.01
> +    connect_timeout = 0.1
>  });
>  ---
>  ...
> @@ -2138,6 +2143,7 @@ nb.error:find('timed out') ~= nil;
>  ---
>  - true
>  ...
> +need_stop = true
>  nb:close();
>  ---
>  ...
> diff --git a/test/box/net.box.test.lua b/test/box/net.box.test.lua
> index a84f6db..3677b30 100644
> --- a/test/box/net.box.test.lua
> +++ b/test/box/net.box.test.lua
> @@ -837,6 +837,7 @@ c:close()
>  
>  -- Test for connect_timeout > 0 in netbox connect
>  test_run:cmd("setopt delimiter ';'");
> +need_stop = false;
>  greeting =
>  "Tarantool 1.7.3 (Lua console)~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~\n" ..
>  "type 'help' for interactive help~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~\n";
> @@ -844,7 +845,9 @@ socket = require('socket');
>  srv = socket.tcp_server('localhost', 0, {
>      handler = function(fd)
>          local fiber = require('fiber')
> -        fiber.sleep(0.1)
> +        while not need_stop do
> +            fiber.sleep(0.01)
> +        end
>          fd:write(greeting)
>      end
>  });
> @@ -852,9 +855,10 @@ port = srv:name().port
>  -- we must get timeout
>  nb = net.new('localhost:' .. port, {
>      wait_connected = true, console = true,
> -    connect_timeout = 0.01
> +    connect_timeout = 0.1
>  });
>  nb.error:find('timed out') ~= nil;
> +need_stop = true
>  nb:close();
>  -- we must get peer closed
>  nb = net.new('localhost:' .. port, {
> 




More information about the Tarantool-patches mailing list