| Index: go/src/infra/gae/libs/wrapper/memory/memcache_test.go
 | 
| diff --git a/go/src/infra/gae/libs/wrapper/memory/memcache_test.go b/go/src/infra/gae/libs/wrapper/memory/memcache_test.go
 | 
| deleted file mode 100644
 | 
| index ab1934c7aea78b8a39f47e86d67d223e6ab8764c..0000000000000000000000000000000000000000
 | 
| --- a/go/src/infra/gae/libs/wrapper/memory/memcache_test.go
 | 
| +++ /dev/null
 | 
| @@ -1,215 +0,0 @@
 | 
| -// Copyright 2015 The Chromium Authors. All rights reserved.
 | 
| -// Use of this source code is governed by a BSD-style license that can be
 | 
| -// found in the LICENSE file.
 | 
| -
 | 
| -package memory
 | 
| -
 | 
| -import (
 | 
| -	"infra/gae/libs/wrapper"
 | 
| -	"infra/gae/libs/wrapper/unsafe"
 | 
| -	"infra/libs/clock/testclock"
 | 
| -	"testing"
 | 
| -	"time"
 | 
| -
 | 
| -	. "github.com/smartystreets/goconvey/convey"
 | 
| -	"golang.org/x/net/context"
 | 
| -
 | 
| -	"appengine/memcache"
 | 
| -)
 | 
| -
 | 
| -func TestMemcache(t *testing.T) {
 | 
| -	t.Parallel()
 | 
| -
 | 
| -	Convey("memcache", t, func() {
 | 
| -		now := time.Date(2015, 1, 1, 0, 0, 0, 0, time.UTC)
 | 
| -		c, tc := testclock.UseTime(context.Background(), now)
 | 
| -		c = Use(c)
 | 
| -		mc := wrapper.GetMC(c)
 | 
| -		mci := wrapper.GetMC(c).(*memcacheImpl)
 | 
| -		So(mc, ShouldNotEqual, mci) // two impls with the same memcacheData
 | 
| -
 | 
| -		Convey("implements MCSingleReadWriter", func() {
 | 
| -			Convey("Add", func() {
 | 
| -				itm := &memcache.Item{
 | 
| -					Key:        "sup",
 | 
| -					Value:      []byte("cool"),
 | 
| -					Expiration: time.Second,
 | 
| -				}
 | 
| -				err := mc.Add(itm)
 | 
| -				So(err, ShouldBeNil)
 | 
| -				Convey("which rejects objects already there", func() {
 | 
| -					err := mc.Add(itm)
 | 
| -					So(err, ShouldEqual, memcache.ErrNotStored)
 | 
| -				})
 | 
| -
 | 
| -				Convey("which can be broken intentionally", func() {
 | 
| -					mci.BreakFeatures(nil, "Add")
 | 
| -					err := mc.Add(itm)
 | 
| -					So(err, ShouldEqual, memcache.ErrServerError)
 | 
| -				})
 | 
| -			})
 | 
| -
 | 
| -			Convey("Get", func() {
 | 
| -				itm := &memcache.Item{
 | 
| -					Key:        "sup",
 | 
| -					Value:      []byte("cool"),
 | 
| -					Expiration: time.Second,
 | 
| -				}
 | 
| -				err := mc.Add(itm)
 | 
| -				So(err, ShouldBeNil)
 | 
| -
 | 
| -				testItem := &memcache.Item{
 | 
| -					Key:   "sup",
 | 
| -					Value: []byte("cool"),
 | 
| -				}
 | 
| -				unsafe.MCSetCasID(testItem, 1)
 | 
| -				i, err := mc.Get("sup")
 | 
| -				So(err, ShouldBeNil)
 | 
| -				So(i, ShouldResemble, testItem)
 | 
| -
 | 
| -				Convey("which can expire", func() {
 | 
| -					tc.Add(time.Second * 4)
 | 
| -					i, err := mc.Get("sup")
 | 
| -					So(err, ShouldEqual, memcache.ErrCacheMiss)
 | 
| -					So(i, ShouldBeNil)
 | 
| -				})
 | 
| -
 | 
| -				Convey("which can be broken intentionally", func() {
 | 
| -					mci.BreakFeatures(nil, "Get")
 | 
| -					_, err := mc.Get("sup")
 | 
| -					So(err, ShouldEqual, memcache.ErrServerError)
 | 
| -				})
 | 
| -			})
 | 
| -
 | 
| -			Convey("Delete", func() {
 | 
| -				Convey("works if it's there", func() {
 | 
| -					itm := &memcache.Item{
 | 
| -						Key:        "sup",
 | 
| -						Value:      []byte("cool"),
 | 
| -						Expiration: time.Second,
 | 
| -					}
 | 
| -					err := mc.Add(itm)
 | 
| -					So(err, ShouldBeNil)
 | 
| -
 | 
| -					err = mc.Delete("sup")
 | 
| -					So(err, ShouldBeNil)
 | 
| -
 | 
| -					i, err := mc.Get("sup")
 | 
| -					So(err, ShouldEqual, memcache.ErrCacheMiss)
 | 
| -					So(i, ShouldBeNil)
 | 
| -				})
 | 
| -
 | 
| -				Convey("but not if it's not there", func() {
 | 
| -					err := mc.Delete("sup")
 | 
| -					So(err, ShouldEqual, memcache.ErrCacheMiss)
 | 
| -				})
 | 
| -
 | 
| -				Convey("and can be broken", func() {
 | 
| -					mci.BreakFeatures(nil, "Delete")
 | 
| -					err := mc.Delete("sup")
 | 
| -					So(err, ShouldEqual, memcache.ErrServerError)
 | 
| -				})
 | 
| -			})
 | 
| -
 | 
| -			Convey("Set", func() {
 | 
| -				itm := &memcache.Item{
 | 
| -					Key:        "sup",
 | 
| -					Value:      []byte("cool"),
 | 
| -					Expiration: time.Second,
 | 
| -				}
 | 
| -				err := mc.Add(itm)
 | 
| -				So(err, ShouldBeNil)
 | 
| -
 | 
| -				itm.Value = []byte("newp")
 | 
| -				err = mc.Set(itm)
 | 
| -				So(err, ShouldBeNil)
 | 
| -
 | 
| -				testItem := &memcache.Item{
 | 
| -					Key:   "sup",
 | 
| -					Value: []byte("newp"),
 | 
| -				}
 | 
| -				unsafe.MCSetCasID(testItem, 2)
 | 
| -				i, err := mc.Get("sup")
 | 
| -				So(err, ShouldBeNil)
 | 
| -				So(i, ShouldResemble, testItem)
 | 
| -
 | 
| -				Convey("and can be broken", func() {
 | 
| -					mci.BreakFeatures(nil, "Set")
 | 
| -					err := mc.Set(itm)
 | 
| -					So(err, ShouldEqual, memcache.ErrServerError)
 | 
| -				})
 | 
| -			})
 | 
| -
 | 
| -			Convey("CompareAndSwap", func() {
 | 
| -				itm := &memcache.Item{
 | 
| -					Key:        "sup",
 | 
| -					Value:      []byte("cool"),
 | 
| -					Expiration: time.Second * 2,
 | 
| -				}
 | 
| -				err := mc.Add(itm)
 | 
| -				So(err, ShouldBeNil)
 | 
| -
 | 
| -				Convey("works after a Get", func() {
 | 
| -					itm, err = mc.Get("sup")
 | 
| -					So(err, ShouldBeNil)
 | 
| -					So(unsafe.MCGetCasID(itm), ShouldEqual, 1)
 | 
| -
 | 
| -					itm.Value = []byte("newp")
 | 
| -					err = mc.CompareAndSwap(itm)
 | 
| -					So(err, ShouldBeNil)
 | 
| -				})
 | 
| -
 | 
| -				Convey("but fails if you don't", func() {
 | 
| -					itm.Value = []byte("newp")
 | 
| -					err = mc.CompareAndSwap(itm)
 | 
| -					So(err, ShouldEqual, memcache.ErrCASConflict)
 | 
| -				})
 | 
| -
 | 
| -				Convey("and fails if the item is expired/gone", func() {
 | 
| -					tc.Add(3 * time.Second)
 | 
| -					itm.Value = []byte("newp")
 | 
| -					err = mc.CompareAndSwap(itm)
 | 
| -					So(err, ShouldEqual, memcache.ErrNotStored)
 | 
| -				})
 | 
| -
 | 
| -				Convey("and can be broken", func() {
 | 
| -					mci.BreakFeatures(nil, "CompareAndSwap")
 | 
| -					err = mc.CompareAndSwap(itm)
 | 
| -					So(err, ShouldEqual, memcache.ErrServerError)
 | 
| -				})
 | 
| -			})
 | 
| -		})
 | 
| -
 | 
| -		Convey("check that the internal implementation is sane", func() {
 | 
| -			curTime := now
 | 
| -			err := mc.Add(&memcache.Item{
 | 
| -				Key:        "sup",
 | 
| -				Value:      []byte("cool"),
 | 
| -				Expiration: time.Second * 2,
 | 
| -			})
 | 
| -
 | 
| -			So(err, ShouldBeNil)
 | 
| -			So(len(mci.data.items), ShouldEqual, 1)
 | 
| -			So(mci.data.casID, ShouldEqual, 1)
 | 
| -			So(mci.data.items["sup"], ShouldResemble, &unsafe.Item{
 | 
| -				Key:        "sup",
 | 
| -				Value:      []byte("cool"),
 | 
| -				CasID:      1,
 | 
| -				Expiration: time.Duration(curTime.Add(time.Second * 2).UnixNano()),
 | 
| -			})
 | 
| -
 | 
| -			el, err := mc.Get("sup")
 | 
| -			So(err, ShouldBeNil)
 | 
| -			So(len(mci.data.items), ShouldEqual, 1)
 | 
| -			So(mci.data.casID, ShouldEqual, 1)
 | 
| -
 | 
| -			testItem := &memcache.Item{
 | 
| -				Key:   "sup",
 | 
| -				Value: []byte("cool"),
 | 
| -			}
 | 
| -			unsafe.MCSetCasID(testItem, 1)
 | 
| -			So(el, ShouldResemble, testItem)
 | 
| -		})
 | 
| -
 | 
| -	})
 | 
| -}
 | 
| 
 |