| Index: go/src/infra/gae/epservice/example/service_cas.go
|
| diff --git a/go/src/infra/gae/epservice/example/service_cas.go b/go/src/infra/gae/epservice/example/service_cas.go
|
| index 4c2d8214f9cf0d303b2e3ac198d835edffc1ab3b..b03e0aff4a3d58ee478c2e8ae1647567afa80e61 100644
|
| --- a/go/src/infra/gae/epservice/example/service_cas.go
|
| +++ b/go/src/infra/gae/epservice/example/service_cas.go
|
| @@ -6,7 +6,9 @@ package example
|
|
|
| import (
|
| "golang.org/x/net/context"
|
| +
|
| "infra/gae/libs/gae"
|
| + "infra/gae/libs/gae/helper"
|
| "infra/gae/libs/gae/prod"
|
|
|
| "github.com/GoogleCloudPlatform/go-endpoints/endpoints"
|
| @@ -28,13 +30,14 @@ func (Example) CAS(c context.Context, r *CASReq) (err error) {
|
| rds := gae.GetRDS(c)
|
| key := rds.NewKey("Counter", r.Name, 0, nil)
|
| ctr := &Counter{}
|
| - if err := rds.Get(key, ctr); err != nil {
|
| + pls := helper.GetPLS(ctr)
|
| + if err := rds.Get(key, pls); err != nil {
|
| return err
|
| }
|
| if ctr.Val == r.OldVal {
|
| success = true
|
| ctr.Val = r.NewVal
|
| - _, err := rds.Put(key, ctr)
|
| + _, err := rds.Put(key, pls)
|
| return err
|
| }
|
| success = false
|
|
|