| Index: impl/memory/taskqueue_data.go
|
| diff --git a/impl/memory/taskqueue_data.go b/impl/memory/taskqueue_data.go
|
| index 4bc24a1a7436a074e6b3071393818ef83146b426..25d1db682b45d579dd282d3fdbe3d88fd676bdc0 100644
|
| --- a/impl/memory/taskqueue_data.go
|
| +++ b/impl/memory/taskqueue_data.go
|
| @@ -196,9 +196,14 @@ var _ interface {
|
| tq.Testable
|
| } = (*txnTaskQueueData)(nil)
|
|
|
| -func (t *txnTaskQueueData) canApplyTxn(obj memContextObj) bool { return false }
|
| -func (t *txnTaskQueueData) applyTxn(context.Context, memContextObj) { panic("impossible") }
|
| -func (t *txnTaskQueueData) mkTxn(*ds.TransactionOptions) memContextObj { panic("impossible") }
|
| +func (t *txnTaskQueueData) canApplyTxn(obj memContextObj) bool { return false }
|
| +func (t *txnTaskQueueData) applyTxn(context.Context, memContextObj) {
|
| + impossible(fmt.Errorf("cannot apply nested transaction"))
|
| +}
|
| +func (t *txnTaskQueueData) mkTxn(*ds.TransactionOptions) memContextObj {
|
| + impossible(fmt.Errorf("cannot start nested transaction"))
|
| + return nil
|
| +}
|
|
|
| func (t *txnTaskQueueData) endTxn() {
|
| if atomic.LoadInt32(&t.closed) == 1 {
|
|
|