| Index: go/src/infra/gae/libs/gae/memory/context.go
 | 
| diff --git a/go/src/infra/gae/libs/wrapper/memory/context.go b/go/src/infra/gae/libs/gae/memory/context.go
 | 
| similarity index 93%
 | 
| rename from go/src/infra/gae/libs/wrapper/memory/context.go
 | 
| rename to go/src/infra/gae/libs/gae/memory/context.go
 | 
| index b6607fcc4d0231f8b23874083be039c09a157545..2df9556240449c8e347dba0bf6a4ac1e7ce42f5d 100644
 | 
| --- a/go/src/infra/gae/libs/wrapper/memory/context.go
 | 
| +++ b/go/src/infra/gae/libs/gae/memory/context.go
 | 
| @@ -10,7 +10,7 @@ import (
 | 
|  
 | 
|  	"golang.org/x/net/context"
 | 
|  
 | 
| -	"appengine/datastore"
 | 
| +	"infra/gae/libs/gae"
 | 
|  )
 | 
|  
 | 
|  type memContextObj interface {
 | 
| @@ -19,7 +19,7 @@ type memContextObj interface {
 | 
|  	applyTxn(c context.Context, m memContextObj)
 | 
|  
 | 
|  	endTxn()
 | 
| -	mkTxn(*datastore.TransactionOptions) (memContextObj, error)
 | 
| +	mkTxn(*gae.DSTransactionOptions) (memContextObj, error)
 | 
|  }
 | 
|  
 | 
|  type memContext []memContextObj
 | 
| @@ -62,7 +62,7 @@ func (m memContext) endTxn() {
 | 
|  	}
 | 
|  }
 | 
|  
 | 
| -func (m memContext) mkTxn(o *datastore.TransactionOptions) (memContextObj, error) {
 | 
| +func (m memContext) mkTxn(o *gae.DSTransactionOptions) (memContextObj, error) {
 | 
|  	ret := make(memContext, len(m))
 | 
|  	for i, itm := range m {
 | 
|  		newItm, err := itm.mkTxn(o)
 | 
| @@ -137,7 +137,7 @@ var memContextKey memContextKeyType
 | 
|  // fake TaskQueue is NOT backed by the fake Datastore. This is done to make the
 | 
|  // test-access API for TaskQueue better (instead of trying to reconstitute the
 | 
|  // state of the task queue from a bunch of datastore accesses).
 | 
| -func (d *dsImpl) RunInTransaction(f func(context.Context) error, o *datastore.TransactionOptions) error {
 | 
| +func (d *dsImpl) RunInTransaction(f func(context.Context) error, o *gae.DSTransactionOptions) error {
 | 
|  	curMC := cur(d.c)
 | 
|  
 | 
|  	txnMC, err := curMC.mkTxn(o)
 | 
| @@ -162,7 +162,7 @@ func (d *dsImpl) RunInTransaction(f func(context.Context) error, o *datastore.Tr
 | 
|  	if curMC.canApplyTxn(txnMC) {
 | 
|  		curMC.applyTxn(d.c, txnMC)
 | 
|  	} else {
 | 
| -		return datastore.ErrConcurrentTransaction
 | 
| +		return gae.ErrDSConcurrentTransaction
 | 
|  	}
 | 
|  	return nil
 | 
|  }
 | 
| 
 |