| Index: filter/txnBuf/ds_txn.go
|
| diff --git a/filter/txnBuf/ds_txn.go b/filter/txnBuf/ds_txn.go
|
| index 7b25c607d2d4fc2a003d0a2ab8679d94be086929..a91d286ec32fb0a3cd6b6833d8ab446242d30acf 100644
|
| --- a/filter/txnBuf/ds_txn.go
|
| +++ b/filter/txnBuf/ds_txn.go
|
| @@ -116,6 +116,15 @@ func (d *dsTxnBuf) RunInTransaction(cb func(context.Context) error, opts *ds.Tra
|
| return withTxnBuf(d.ic, cb, opts)
|
| }
|
|
|
| -func (d *dsTxnBuf) Testable() ds.Testable {
|
| - return d.state.parentDS.Testable()
|
| +func (d *dsTxnBuf) CurrentTransaction() ds.Transaction { return d.state.parentDS.CurrentTransaction() }
|
| +
|
| +func (d *dsTxnBuf) WithoutTransaction() context.Context {
|
| + c := d.state.parentDS.WithoutTransaction()
|
| + c = context.WithValue(c, dsTxnBufParent, nil)
|
| + c = context.WithValue(c, dsTxnBufHaveLock, nil)
|
| + return c
|
| +}
|
| +
|
| +func (d *dsTxnBuf) GetTestable() ds.Testable {
|
| + return d.state.parentDS.GetTestable()
|
| }
|
|
|