From fc2de61414446642b85d73544ff58a4f730624f5 Mon Sep 17 00:00:00 2001 From: Nurzhan Saktaganov Date: Sat, 7 Sep 2024 16:34:11 +0300 Subject: [PATCH] WIP tests --- tests/tnt/router_call_test.go | 20 ++++++++++++++++++++ 1 file changed, 20 insertions(+) diff --git a/tests/tnt/router_call_test.go b/tests/tnt/router_call_test.go index eac7288..85d2127 100644 --- a/tests/tnt/router_call_test.go +++ b/tests/tnt/router_call_test.go @@ -95,4 +95,24 @@ func TestRouterCallProto(t *testing.T) { require.Equal(t, expect[0], typed, "RouterCallImpl getTyped resp ok for arglen %d", argLen) } } + + // simulate vshard error + + // 1. Replace replicaset for bucketID + rs, err := router.BucketResolve(ctx, bucketID) + require.Nil(t, err, "BucketResolve finished with no err") + rsMap := router.RouterRouteAll() + + for k, v := range rsMap { + if rs != v { + res, err := router.BucketSet(bucketID, k) + require.Nil(t, err, "BucketSet finished with no err") + require.Equal(t, res, v) + break + } + } + + // 2. Try to call something + _, _, err = router.RouterCallImpl(ctx, bucketID, callOpts, "echo", args) + require.Nil(t, err, "RouterCallImpl echo finished with no err even on dirty bucket map") }