Fix race condition in transaction handling

client.go

@@ -191,6 +191,8 @@ func (this *Client) FlushRedisAndRespond() (err error) {
  if this.transactionDoneChannel != nil {
  // If there was a transaction going on, we need to stop it, which will recycle the connection
  close(this.transactionDoneChannel)
+ this.reservedRedisConn = nil
+ this.transactionDoneChannel = nil
  } else {
  // We are not in a transaction, so we can simply recycle it
  connectionPool.RecycleRemoteConnection(redisConn)
@@ -201,6 +203,8 @@ func (this *Client) FlushRedisAndRespond() (err error) {
  // Reset client and server connection as we can not recover from any error states
  this.ReadChannel <- readItem{nil, err}
  close(this.transactionDoneChannel)
+ this.reservedRedisConn = nil
+ this.transactionDoneChannel = nil
  } else if this.reservedRedisConn == nil {
  this.reservedRedisConn = redisConn
  this.transactionDoneChannel = make(chan interface{}, 1)