OLD | NEW |
---|---|
1 // Copyright 2015 The LUCI Authors. All rights reserved. | 1 // Copyright 2015 The LUCI Authors. All rights reserved. |
2 // Use of this source code is governed under the Apache License, Version 2.0 | 2 // Use of this source code is governed under the Apache License, Version 2.0 |
3 // that can be found in the LICENSE file. | 3 // that can be found in the LICENSE file. |
4 | 4 |
5 package txnBuf | 5 package txnBuf |
6 | 6 |
7 import ( | 7 import ( |
8 ds "github.com/luci/gae/service/datastore" | 8 ds "github.com/luci/gae/service/datastore" |
9 "github.com/luci/luci-go/common/errors" | 9 "github.com/luci/luci-go/common/errors" |
10 "golang.org/x/net/context" | 10 "golang.org/x/net/context" |
(...skipping 98 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
109 } | 109 } |
110 | 110 |
111 func (d *dsTxnBuf) RunInTransaction(cb func(context.Context) error, opts *ds.Tra nsactionOptions) error { | 111 func (d *dsTxnBuf) RunInTransaction(cb func(context.Context) error, opts *ds.Tra nsactionOptions) error { |
112 if !d.haveLock { | 112 if !d.haveLock { |
113 d.state.Lock() | 113 d.state.Lock() |
114 defer d.state.Unlock() | 114 defer d.state.Unlock() |
115 } | 115 } |
116 return withTxnBuf(d.ic, cb, opts) | 116 return withTxnBuf(d.ic, cb, opts) |
117 } | 117 } |
118 | 118 |
119 func (d *dsTxnBuf) Testable() ds.Testable { | 119 func (d *dsTxnBuf) CurrentTransaction() ds.Transaction { return d.state.parentDS .CurrentTransaction() } |
dnj
2016/09/01 15:25:39
Perhaps in the future, we can synthesize transacti
iannucci
2016/09/16 01:01:13
hm good point. Yes I think waiting on this is a go
dnj
2016/09/16 05:44:42
Done.
| |
120 » return d.state.parentDS.Testable() | 120 |
121 func (d *dsTxnBuf) WithTransaction(t ds.Transaction) context.Context { | |
122 » return d.state.parentDS.WithTransaction(nil) | |
iannucci
2016/09/16 01:01:13
doesn't this need to remove transaction stuff from
dnj
2016/09/16 05:44:42
Done.
| |
121 } | 123 } |
124 | |
125 func (d *dsTxnBuf) GetTestable() ds.Testable { | |
126 return nil | |
dnj
2016/09/01 15:25:39
oops, I'll make sure this returns parentDS's Testa
dnj
2016/09/16 05:44:42
Done.
| |
127 } | |
OLD | NEW |