From mboxrd@z Thu Jan 1 00:00:00 1970 Return-Path: Received: from localhost (localhost [127.0.0.1]) by turing.freelists.org (Avenir Technologies Mail Multiplex) with ESMTP id D436027009 for ; Tue, 16 Apr 2019 01:45:26 -0400 (EDT) Received: from turing.freelists.org ([127.0.0.1]) by localhost (turing.freelists.org [127.0.0.1]) (amavisd-new, port 10024) with ESMTP id WC7YvxA-eLfN for ; Tue, 16 Apr 2019 01:45:26 -0400 (EDT) Received: from smtp43.i.mail.ru (smtp43.i.mail.ru [94.100.177.103]) (using TLSv1.2 with cipher ECDHE-RSA-AES256-GCM-SHA384 (256/256 bits)) (No client certificate requested) by turing.freelists.org (Avenir Technologies Mail Multiplex) with ESMTPS id 3EBE126395 for ; Tue, 16 Apr 2019 01:45:26 -0400 (EDT) From: avtikhon Subject: [tarantool-patches] [PATCH v1] test: need to wait for upstream/downstream status Date: Tue, 16 Apr 2019 08:45:22 +0300 Message-Id: <887b72d40ae9e9b573658cc971fe2ea524070b8a.1555393509.git.avtikhon@tarantool.org> Sender: tarantool-patches-bounce@freelists.org Errors-to: tarantool-patches-bounce@freelists.org Reply-To: tarantool-patches@freelists.org List-Help: List-Unsubscribe: List-software: Ecartis version 1.0.0 List-Id: tarantool-patches List-Subscribe: List-Owner: List-post: List-Archive: To: Alexander Turenko Cc: avtikhon , tarantool-patches@freelists.org It is needed to wait for upstream/downstream status, otherwise error occurs: [025] --- replication/show_error_on_disconnect.result Fri Apr 12 14:49:26 2019 [025] +++ replication/show_error_on_disconnect.reject Tue Apr 16 07:35:41 2019 [025] @@ -77,11 +77,12 @@ [025] ... [025] box.info.replication[other_id].upstream.status [025] --- [025] -- stopped [025] +- sync [025] ... [025] box.info.replication[other_id].upstream.message:match("Missing") [025] --- [025] -- Missing [025] +- error: '[string "return box.info.replication[other_id].upstrea..."]:1: attempt to [025] + index field ''message'' (a nil value)' [025] ... [025] test_run:cmd("switch master_quorum2") [025] --- [025] Close #4161 --- test/replication/show_error_on_disconnect.result | 12 ++++++------ test/replication/show_error_on_disconnect.test.lua | 6 +++--- 2 files changed, 9 insertions(+), 9 deletions(-) diff --git a/test/replication/show_error_on_disconnect.result b/test/replication/show_error_on_disconnect.result index af082203b..ef239af39 100644 --- a/test/replication/show_error_on_disconnect.result +++ b/test/replication/show_error_on_disconnect.result @@ -75,9 +75,9 @@ box.space.test:select() other_id = box.info.id % 2 + 1 --- ... -box.info.replication[other_id].upstream.status +test_run:wait_upstream(box.info.replication[other_id], 'stopped') --- -- stopped +- true ... box.info.replication[other_id].upstream.message:match("Missing") --- @@ -96,17 +96,17 @@ box.space.test:select() other_id = box.info.id % 2 + 1 --- ... -box.info.replication[other_id].upstream.status +test_run:wait_upstream(box.info.replication[other_id], 'follow') --- -- follow +- true ... box.info.replication[other_id].upstream.message --- - null ... -box.info.replication[other_id].downstream.status +test_run:wait_downstream(box.info.replication[other_id], 'stopped') --- -- stopped +- true ... box.info.replication[other_id].downstream.message:match("Missing") --- diff --git a/test/replication/show_error_on_disconnect.test.lua b/test/replication/show_error_on_disconnect.test.lua index 40e9dbc5e..191c5b090 100644 --- a/test/replication/show_error_on_disconnect.test.lua +++ b/test/replication/show_error_on_disconnect.test.lua @@ -30,14 +30,14 @@ box.cfg{replication = repl} require('fiber').sleep(0.1) box.space.test:select() other_id = box.info.id % 2 + 1 -box.info.replication[other_id].upstream.status +test_run:wait_upstream(box.info.replication[other_id], 'stopped') box.info.replication[other_id].upstream.message:match("Missing") test_run:cmd("switch master_quorum2") box.space.test:select() other_id = box.info.id % 2 + 1 -box.info.replication[other_id].upstream.status +test_run:wait_upstream(box.info.replication[other_id], 'follow') box.info.replication[other_id].upstream.message -box.info.replication[other_id].downstream.status +test_run:wait_downstream(box.info.replication[other_id], 'stopped') box.info.replication[other_id].downstream.message:match("Missing") test_run:cmd("switch default") -- Cleanup. -- 2.17.1