| OLD | NEW |
| 1 // Copyright 2015 The Chromium Authors. All rights reserved. | 1 // Copyright 2015 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 package memory | 5 package memory |
| 6 | 6 |
| 7 import ( | 7 import ( |
| 8 "fmt" | 8 "fmt" |
| 9 "testing" | 9 "testing" |
| 10 "time" | 10 "time" |
| (...skipping 81 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 92 Convey("Deleteing a DNE entity is fine", func() { | 92 Convey("Deleteing a DNE entity is fine", func() { |
| 93 So(ds.Delete(ds.NewKey("Foo", "wat", 0, nil)), S
houldBeNil) | 93 So(ds.Delete(ds.NewKey("Foo", "wat", 0, nil)), S
houldBeNil) |
| 94 }) | 94 }) |
| 95 | 95 |
| 96 Convey("Deleting entities from a nonexistant namespace w
orks", func() { | 96 Convey("Deleting entities from a nonexistant namespace w
orks", func() { |
| 97 aid := infoS.Get(c).FullyQualifiedAppID() | 97 aid := infoS.Get(c).FullyQualifiedAppID() |
| 98 keys := make([]*dsS.Key, 10) | 98 keys := make([]*dsS.Key, 10) |
| 99 for i := range keys { | 99 for i := range keys { |
| 100 keys[i] = ds.MakeKey(aid, "noexist", "Ki
nd", i+1) | 100 keys[i] = ds.MakeKey(aid, "noexist", "Ki
nd", i+1) |
| 101 } | 101 } |
| 102 » » » » So(ds.DeleteMulti(keys), ShouldBeNil) | 102 » » » » So(ds.DeleteMulti(keys...), ShouldBeNil) |
| 103 count := 0 | 103 count := 0 |
| 104 So(ds.Raw().DeleteMulti(keys, func(err error) er
ror { | 104 So(ds.Raw().DeleteMulti(keys, func(err error) er
ror { |
| 105 count++ | 105 count++ |
| 106 So(err, ShouldBeNil) | 106 So(err, ShouldBeNil) |
| 107 return nil | 107 return nil |
| 108 }), ShouldBeNil) | 108 }), ShouldBeNil) |
| 109 So(count, ShouldEqual, len(keys)) | 109 So(count, ShouldEqual, len(keys)) |
| 110 }) | 110 }) |
| 111 | 111 |
| 112 Convey("with multiple puts", func() { | 112 Convey("with multiple puts", func() { |
| 113 So(testGetMeta(c, k), ShouldEqual, 1) | 113 So(testGetMeta(c, k), ShouldEqual, 1) |
| 114 | 114 |
| 115 foos := make([]Foo, 10) | 115 foos := make([]Foo, 10) |
| 116 for i := range foos { | 116 for i := range foos { |
| 117 foos[i].Val = 10 | 117 foos[i].Val = 10 |
| 118 foos[i].Parent = k | 118 foos[i].Parent = k |
| 119 } | 119 } |
| 120 So(ds.PutMulti(foos), ShouldBeNil) | 120 So(ds.PutMulti(foos), ShouldBeNil) |
| 121 So(testGetMeta(c, k), ShouldEqual, 11) | 121 So(testGetMeta(c, k), ShouldEqual, 11) |
| 122 | 122 |
| 123 keys := make([]*dsS.Key, len(foos)) | 123 keys := make([]*dsS.Key, len(foos)) |
| 124 for i, f := range foos { | 124 for i, f := range foos { |
| 125 keys[i] = ds.KeyForObj(&f) | 125 keys[i] = ds.KeyForObj(&f) |
| 126 } | 126 } |
| 127 | 127 |
| 128 Convey("ensure that group versions persist acros
s deletes", func() { | 128 Convey("ensure that group versions persist acros
s deletes", func() { |
| 129 » » » » » So(ds.DeleteMulti(append(keys, k)), Shou
ldBeNil) | 129 » » » » » So(ds.DeleteMulti(append(keys, k)...), S
houldBeNil) |
| 130 | 130 |
| 131 ds.Testable().CatchupIndexes() | 131 ds.Testable().CatchupIndexes() |
| 132 | 132 |
| 133 count := 0 | 133 count := 0 |
| 134 So(ds.Run(dsS.NewQuery(""), func(_ *dsS.
Key) { | 134 So(ds.Run(dsS.NewQuery(""), func(_ *dsS.
Key) { |
| 135 count++ | 135 count++ |
| 136 }), ShouldBeNil) | 136 }), ShouldBeNil) |
| 137 So(count, ShouldEqual, 3) | 137 So(count, ShouldEqual, 3) |
| 138 | 138 |
| 139 So(testGetMeta(c, k), ShouldEqual, 22) | 139 So(testGetMeta(c, k), ShouldEqual, 22) |
| (...skipping 616 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 756 // Add "foos" to a new namespace, then confirm that it g
ets indexed. | 756 // Add "foos" to a new namespace, then confirm that it g
ets indexed. |
| 757 So(dsS.Get(infoS.Get(ctx).MustNamespace("qux")).PutMulti
(foos), ShouldBeNil) | 757 So(dsS.Get(infoS.Get(ctx).MustNamespace("qux")).PutMulti
(foos), ShouldBeNil) |
| 758 dsS.Get(ctx).Testable().CatchupIndexes() | 758 dsS.Get(ctx).Testable().CatchupIndexes() |
| 759 | 759 |
| 760 results = nil | 760 results = nil |
| 761 So(dsS.Get(infoS.Get(ctx).MustNamespace("qux")).GetAll(q
, &results), ShouldBeNil) | 761 So(dsS.Get(infoS.Get(ctx).MustNamespace("qux")).GetAll(q
, &results), ShouldBeNil) |
| 762 So(len(results), ShouldEqual, 2) | 762 So(len(results), ShouldEqual, 2) |
| 763 }) | 763 }) |
| 764 }) | 764 }) |
| 765 } | 765 } |
| OLD | NEW |