client rollback tx when close

This commit is contained in:
siddontang 2014-09-27 20:11:36 +08:00
parent f49a3bbece
commit 7df7af8b54
1 changed files with 5 additions and 0 deletions

View File

@ -55,6 +55,11 @@ func (c *respClient) run() {
c.conn.Close()
}
if c.tx != nil {
c.tx.Rollback()
c.tx = nil
}
c.app.removeSlave(c.client)
}()