Skip to content

Commit aca935d

Browse files
committed
chore: remove unused param
Signed-off-by: fukua95 <[email protected]>
1 parent af833b7 commit aca935d

File tree

1 file changed

+2
-4
lines changed

1 file changed

+2
-4
lines changed

osscluster.go

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1562,15 +1562,13 @@ func (c *ClusterClient) processTxPipelineNode(
15621562
defer func() {
15631563
node.Client.releaseConn(ctx, cn, processErr)
15641564
}()
1565-
processErr = c.processTxPipelineNodeConn(ctx, node, cn, cmds, failedCmds)
1565+
processErr = c.processTxPipelineNodeConn(ctx, cn, cmds, failedCmds)
15661566

15671567
return processErr
15681568
})
15691569
}
15701570

1571-
func (c *ClusterClient) processTxPipelineNodeConn(
1572-
ctx context.Context, node *clusterNode, cn *pool.Conn, cmds []Cmder, failedCmds *cmdsMap,
1573-
) error {
1571+
func (c *ClusterClient) processTxPipelineNodeConn(ctx context.Context, cn *pool.Conn, cmds []Cmder, failedCmds *cmdsMap) error {
15741572
if err := cn.WithWriter(c.context(ctx), c.opt.WriteTimeout, func(wr *proto.Writer) error {
15751573
return writeCmds(wr, cmds)
15761574
}); err != nil {

0 commit comments

Comments
 (0)