Index: impl/memory/context.go |
diff --git a/impl/memory/context.go b/impl/memory/context.go |
index 8859ebb15c491f7ef2372158f0c2fbd1ed095633..9b388e70fc761a01eca96c7f23a9375344f1d0b6 100644 |
--- a/impl/memory/context.go |
+++ b/impl/memory/context.go |
@@ -169,7 +169,7 @@ func (d *dsImpl) RunInTransaction(f func(context.Context) error, o *ds.Transacti |
attempts = o.Attempts |
} |
for attempt := 0; attempt < attempts; attempt++ { |
- if err := loopBody(attempt >= d.txnFakeRetry); err != ds.ErrConcurrentTransaction { |
+ if err := loopBody(attempt >= d.data.txnFakeRetry); err != ds.ErrConcurrentTransaction { |
return err |
} |
} |