mvcc: rollback tmptx in case of error (#11525)

Co-authored-by: yutedz <54038175+yutedz@users.noreply.github.com>
etcd-io · Jan 15, 2020 · 574ee42 · 574ee42
1 parent af131b5
commit 574ee42
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/mvcc/backend/backend.go b/mvcc/backend/backend.go
@@ -464,6 +464,11 @@ func defragdb(odb, tmpdb *bolt.DB, limit int) error {
 	if err != nil {
 		return err
 	}
+	defer func() {
+		if err != nil {
+			tmptx.Rollback()
+		}
+	}()
 
 	// open a tx on old db for read
 	tx, err := odb.Begin(false)