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() |
} |