| Index: filter/txnBuf/race_test.go
|
| diff --git a/filter/txnBuf/race_test.go b/filter/txnBuf/race_test.go
|
| index c1d60f004d68e3914575f5e89808deac7f043885..32d7a824dd73d2cc9176d376ba17ae0dc65811fc 100644
|
| --- a/filter/txnBuf/race_test.go
|
| +++ b/filter/txnBuf/race_test.go
|
| @@ -9,7 +9,7 @@ import (
|
| "testing"
|
|
|
| "github.com/luci/gae/impl/memory"
|
| - "github.com/luci/gae/service/datastore"
|
| + ds "github.com/luci/gae/service/datastore"
|
| "golang.org/x/net/context"
|
| )
|
|
|
| @@ -23,7 +23,6 @@ func TestRace(t *testing.T) {
|
| t.Parallel()
|
|
|
| c := FilterRDS(memory.Use(context.Background()))
|
| - ds := datastore.Get(c)
|
|
|
| wg := sync.WaitGroup{}
|
| for i := 0; i < 100; i++ {
|
| @@ -32,19 +31,15 @@ func TestRace(t *testing.T) {
|
| wg.Add(1)
|
| go func() {
|
| defer wg.Done()
|
| - err := ds.RunInTransaction(func(c context.Context) error {
|
| - ds := datastore.Get(c)
|
| -
|
| + err := ds.RunInTransaction(c, func(c context.Context) error {
|
| for i := 0; i < 100; i++ {
|
| - err := ds.RunInTransaction(func(c context.Context) error {
|
| - ds := datastore.Get(c)
|
| -
|
| + err := ds.RunInTransaction(c, func(c context.Context) error {
|
| ctr := &Counter{ID: id}
|
| - if err := ds.Get(ctr); err != nil && err != datastore.ErrNoSuchEntity {
|
| + if err := ds.Get(c, ctr); err != nil && err != ds.ErrNoSuchEntity {
|
| t.Fatal("bad Get", err)
|
| }
|
| ctr.Value++
|
| - return ds.Put(ctr)
|
| + return ds.Put(c, ctr)
|
| }, nil)
|
| if err != nil {
|
| t.Fatal("bad inner RIT", err)
|
|
|