Skip to content

Commit 03a95d1

Browse files
cxljsofekshenawa
authored andcommitted
chore: remove unused param (redis#3384)
Signed-off-by: fukua95 <[email protected]>
1 parent fc9f067 commit 03a95d1

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

osscluster.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1593,7 +1593,7 @@ func (c *ClusterClient) processTxPipeline(ctx context.Context, cmds []Cmder) err
15931593
return err
15941594
}
15951595

1596-
cmdsMap := c.mapCmdsBySlot(ctx, cmds)
1596+
cmdsMap := c.mapCmdsBySlot(cmds)
15971597
for slot, cmds := range cmdsMap {
15981598
node, err := state.slotMasterNode(slot)
15991599
if err != nil {
@@ -1632,7 +1632,7 @@ func (c *ClusterClient) processTxPipeline(ctx context.Context, cmds []Cmder) err
16321632
return cmdsFirstErr(cmds)
16331633
}
16341634

1635-
func (c *ClusterClient) mapCmdsBySlot(ctx context.Context, cmds []Cmder) map[int][]Cmder {
1635+
func (c *ClusterClient) mapCmdsBySlot(cmds []Cmder) map[int][]Cmder {
16361636
cmdsMap := make(map[int][]Cmder)
16371637
for _, cmd := range cmds {
16381638
slot := c.cmdSlot(cmd)

ring.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -702,7 +702,7 @@ func (c *Ring) cmdsInfo(ctx context.Context) (map[string]*CommandInfo, error) {
702702
return nil, firstErr
703703
}
704704

705-
func (c *Ring) cmdShard(ctx context.Context, cmd Cmder) (*ringShard, error) {
705+
func (c *Ring) cmdShard(cmd Cmder) (*ringShard, error) {
706706
pos := cmdFirstKeyPos(cmd)
707707
if pos == 0 {
708708
return c.sharding.Random()
@@ -720,7 +720,7 @@ func (c *Ring) process(ctx context.Context, cmd Cmder) error {
720720
}
721721
}
722722

723-
shard, err := c.cmdShard(ctx, cmd)
723+
shard, err := c.cmdShard(cmd)
724724
if err != nil {
725725
return err
726726
}

0 commit comments

Comments
 (0)