mirrors/dragonfly
1
0
Fork 0
mirror of https://github.com/dragonflydb/dragonfly.git synced 2025-05-11 18:35:46 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions 5

test: add ClusterEvalCrossslot (#4587)

Browse source
This commit is contained in:
Borys 2025-02-10 18:16:21 +02:00 • committed by GitHub
parent 8eb5e24147
commit a56b129f69
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 15 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

15
src/server/cluster/cluster_family_test.cc
View file

@ -480,6 +480,21 @@ TEST_F(ClusterFamilyTest, ClusterSlotsPopulate) {
} }
} }
TEST_F(ClusterFamilyTest, ClusterEvalCrossslot) {
ConfigSingleNodeCluster(GetMyId());
auto res = Run({"EVAL", "return redis.call('MSET', 'x1', 'x1', 'x2', 'x2', 'x3', 'x3');", "3",
"x1", "x2", "x3"});
EXPECT_THAT(res, ErrArg("CROSSSLOT"));
auto sha =
Run({"SCRPIT", "LOAD", "return redis.call('MSET', 'x1', 'x1', 'x2', 'x2', 'x3', 'x3');", "3",
"x1", "x2", "x3"});
EXPECT_THAT(Run({"EVALSHA", sha.GetString(), "3", "x1", "x2", "x3"}), ErrArg("CROSSSLOT"));
}
TEST_F(ClusterFamilyTest, ClusterConfigDeleteSlots) { TEST_F(ClusterFamilyTest, ClusterConfigDeleteSlots) {
ConfigSingleNodeCluster(GetMyId()); ConfigSingleNodeCluster(GetMyId());