mirror
/
redis
mirror of https://github.com/go-redis/redis.git
1
0
Fork 1
Code Issues Packages Projects Releases Wiki Activity

reset cmdable.process when copying cluster client

This commit is contained in:
Nathan Ziebart 2018-05-23 17:30:50 -07:00
parent e3d9f9d1c7
commit d790448589
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
cluster.go
View File

@ -650,7 +650,7 @@ func NewClusterClient(opt *ClusterOptions) *ClusterClient {
c.processPipeline = c.defaultProcessPipeline c.processPipeline = c.defaultProcessPipeline
c.processTxPipeline = c.defaultProcessTxPipeline c.processTxPipeline = c.defaultProcessTxPipeline
c.cmdable.setProcessor(c.Process) c.init()
_, _ = c.state.Reload() _, _ = c.state.Reload()
if opt.IdleCheckFrequency > 0 { if opt.IdleCheckFrequency > 0 {
@ -660,6 +660,10 @@ func NewClusterClient(opt *ClusterOptions) *ClusterClient {
return c return c
} }
func (c *ClusterClient) init() {
c.cmdable.setProcessor(c.Process)
}
func (c *ClusterClient) Context() context.Context { func (c *ClusterClient) Context() context.Context {
if c.ctx != nil { if c.ctx != nil {
return c.ctx return c.ctx
@ -678,6 +682,7 @@ func (c *ClusterClient) WithContext(ctx context.Context) *ClusterClient {
func (c *ClusterClient) copy() *ClusterClient { func (c *ClusterClient) copy() *ClusterClient {
cp := *c cp := *c
cp.init()
return &cp return &cp
} }