cluster restore quick list panic

v4
vinllen 5 years ago
parent 177a6fb59e
commit dd0d244ff7
  1. 5
      src/redis-shake/common/cluster.go
  2. 6
      src/vendor/vendor.json

@ -61,6 +61,11 @@ func (cc *ClusterConn) Send(commandName string, args ...interface{}) error {
// send batcher and put the return into recvChan // send batcher and put the return into recvChan
func (cc *ClusterConn) Flush() error { func (cc *ClusterConn) Flush() error {
if cc.batcher == nil {
log.Info("batcher is empty, no need to flush")
return nil
}
ret, err := cc.client.RunBatch(cc.batcher) ret, err := cc.client.RunBatch(cc.batcher)
defer func() { defer func() {
cc.batcher = nil // reset batcher cc.batcher = nil // reset batcher

@ -159,10 +159,10 @@
"revisionTime": "2019-03-04T09:57:49Z" "revisionTime": "2019-03-04T09:57:49Z"
}, },
{ {
"checksumSHA1": "1PrwQi6VvhLG4ovw1B7zD/afGZ4=", "checksumSHA1": "qW5Sb6hcZxGHxZbkLoHrCQtYyBs=",
"path": "github.com/vinllen/redis-go-cluster", "path": "github.com/vinllen/redis-go-cluster",
"revision": "0799101ddfdb7d2bc9d47948f8a0cc17d23a216e", "revision": "1883b18765aeed1a0b01320791dfe6103aa9a6b6",
"revisionTime": "2019-08-12T11:22:58Z" "revisionTime": "2019-09-04T07:01:13Z"
}, },
{ {
"checksumSHA1": "TM3Neoy1xRAKyZYMGzKc41sDFW4=", "checksumSHA1": "TM3Neoy1xRAKyZYMGzKc41sDFW4=",

Loading…
Cancel
Save