// Rollback implements the MVCCStore interface.
Rollback implements the MVCCStore interface.
// Rollback implements the MVCCStore interface .
func (mvcc *MVCCRocksDB) Rollback(keys [][]byte, startTS uint64) error {
	mvcc.mu.Lock()
	defer func() {
		mvcc.mu.Unlock()
		mvcc.deadlockDetector.CleanUp(startTS)
	}()
	batch := gorocksdb.NewWriteBatch()
	for _, k := range keys {
		err := rollbackKey(mvcc.db, batch, k, startTS)
		if err != nil {
			return errors.Trace(err)
		}
	}
	return mvcc.db.Write(gorocksdb.NewDefaultWriteOptions(), batch)
}
func ( mvcc * MVCCRocksDB ) Rollback ( keys [ ] [ ] byte , startTS uint64 ) error { mvcc . mu . Lock ( ) defer func ( ) { mvcc . mu . Unlock ( ) mvcc . deadlockDetector . CleanUp ( startTS ) } ( ) batch := gorocksdb . NewWriteBatch ( ) for _ , k := range keys { err := rollbackKey ( mvcc . db , batch , k , startTS ) if err != nil { return errors . Trace ( err ) } } return mvcc . db . Write ( gorocksdb . NewDefaultWriteOptions ( ) , batch ) }
Rollback implements the MVCCStore interface.
Rollback implements the MVCCStore interface .