Skip to content
This repository has been archived by the owner on Dec 23, 2024. It is now read-only.

Commit

Permalink
WIP tests
Browse files Browse the repository at this point in the history
  • Loading branch information
nurzhan-saktaganov committed Sep 7, 2024
1 parent f081a66 commit fc2de61
Showing 1 changed file with 20 additions and 0 deletions.
20 changes: 20 additions & 0 deletions tests/tnt/router_call_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -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")
}

0 comments on commit fc2de61

Please sign in to comment.