redis/go-redis
1
0
Fork 0
mirror of https://github.com/redis/go-redis.git synced 2025-07-28 06:42:00 +03:00
Code Activity

Merge branch 'master' into ndyakov/CAE-1046-cache-loading-state

Browse Source
This commit is contained in:
Nedyalko Dyakov
2025-06-18 14:18:16 +03:00
committed by GitHub
parent 2d9baf0ae1 4c635cc563
commit 6ffc0c7413
3 changed files with 49 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
osscluster.go
View File

@ -1509,6 +1509,10 @@ func (c *ClusterClient) processTxPipeline(ctx context.Context, cmds []Cmder) err
// Trim multi .. exec.
cmds = cmds[1 : len(cmds)-1]
if len(cmds) == 0 {
return nil
}
state, err := c.state.Get(ctx)
if err != nil {
setCmdsErr(cmds, err)
@ -1516,6 +1520,12 @@ func (c *ClusterClient) processTxPipeline(ctx context.Context, cmds []Cmder) err
}
cmdsMap := c.mapCmdsBySlot(cmds)
// TxPipeline does not support cross slot transaction.
if len(cmdsMap) > 1 {
setCmdsErr(cmds, ErrCrossSlot)
return ErrCrossSlot
}
for slot, cmds := range cmdsMap {
node, err := state.slotMasterNode(slot)
if err != nil {