[Tarantool-patches] [PATCH 5/5] [tosquash] replication: add test on local row in the end of sync txn
Vladislav Shpilevoy
v.shpilevoy at tarantool.org
Sun Jul 5 18:13:20 MSK 2020
>> diff --git a/test/replication/qsync_basic.test.lua b/test/replication/qsync_basic.test.lua
>> index 6e40131bf..74083a0b9 100644
>> --- a/test/replication/qsync_basic.test.lua
>> +++ b/test/replication/qsync_basic.test.lua
>> @@ -163,6 +163,26 @@ box.space.sync:select{9}
>> box.space.locallocal:select{9}
>> box.space.test:select{9}
>> +--
>> +-- gh-4928: test that a sync transaction works fine with local
>> +-- rows in the end.
>> +--
>> +
>> +-- test_run:switch('default')
>> +-- box.cfg{replication_synchro_timeout = 1000, replication_synchro_quorum = 2}
>> +-- do \
>> +-- box.begin() \
>> +-- box.space.sync:replace{10} \
>> +-- box.space.locallocal:replace({10}) \
>> +-- box.commit() \
>> +-- end
>> +-- box.space.sync:select{10}
>> +-- box.space.locallocal:select{10}
>> +
>> +-- test_run:switch('replica')
>> +-- box.space.sync:select{10}
>> +-- box.space.locallocal:select{10}
>> +
>> --
>> -- gh-5123: quorum 1 still should write CONFIRM.
>> --
> Hi! Thanks for the test!
> LGTM with one comment.
>
> Looks like it relies on the vclock[0] increase you performed in
> the previous test (patch 4/5).
Yup.
> If it wasn't for this increase,both correctly and incorrectly
> working tarantools would complete the transaction. (The incorrect
> one would take lsn = 1 from vclock[0])
>
> Maybe add the same increase here, to make sure the test stays
> valid if someone changes the previous test case?
Ok, fair. I also reduced the first bump count, to speed up the
test a bit.
====================
diff --git a/test/replication/qsync_basic.result b/test/replication/qsync_basic.result
index 83ff7d3d1..3e28607b0 100644
--- a/test/replication/qsync_basic.result
+++ b/test/replication/qsync_basic.result
@@ -317,7 +317,7 @@ _ = _:create_index('pk')
| ...
-- Propagate local vclock to some insane value to ensure it won't
-- affect anything.
-box.begin() for i = 1, 2000 do box.space.locallocal:replace{1} end box.commit()
+box.begin() for i = 1, 500 do box.space.locallocal:replace{1} end box.commit()
| ---
| ...
do \
@@ -426,6 +426,9 @@ box.space.test:select{9}
-- test_run:switch('default')
-- box.cfg{replication_synchro_timeout = 1000, replication_synchro_quorum = 2}
+-- -- Propagate local vclock to some insane value to ensure it won't
+-- -- affect anything.
+-- box.begin() for i = 1, 500 do box.space.locallocal:replace{1} end box.commit()
-- do \
-- box.begin() \
-- box.space.sync:replace{10} \
diff --git a/test/replication/qsync_basic.test.lua b/test/replication/qsync_basic.test.lua
index 74083a0b9..860d6d6c4 100644
--- a/test/replication/qsync_basic.test.lua
+++ b/test/replication/qsync_basic.test.lua
@@ -127,7 +127,7 @@ _ = box.schema.create_space('locallocal', {is_local = true})
_ = _:create_index('pk')
-- Propagate local vclock to some insane value to ensure it won't
-- affect anything.
-box.begin() for i = 1, 2000 do box.space.locallocal:replace{1} end box.commit()
+box.begin() for i = 1, 500 do box.space.locallocal:replace{1} end box.commit()
do \
f1 = fiber.create(box.space.sync.replace, box.space.sync, {8}) \
f2 = fiber.create(box.space.locallocal.replace, box.space.locallocal, {8}) \
@@ -170,6 +170,9 @@ box.space.test:select{9}
-- test_run:switch('default')
-- box.cfg{replication_synchro_timeout = 1000, replication_synchro_quorum = 2}
+-- -- Propagate local vclock to some insane value to ensure it won't
+-- -- affect anything.
+-- box.begin() for i = 1, 500 do box.space.locallocal:replace{1} end box.commit()
-- do \
-- box.begin() \
-- box.space.sync:replace{10}
More information about the Tarantool-patches
mailing list