Ensure subsequent updates to delta don't mutate previously retrieved deltas
(t *testing.T)
| 1292 | |
| 1293 | // Ensure subsequent updates to delta don't mutate previously retrieved deltas |
| 1294 | func TestSingleLoad(t *testing.T) { |
| 1295 | cacheHitCounter, cacheMissCounter, getDocumentCounter, getRevisionCounter, cacheNumItems, memoryBytesCounted := base.SgwIntStat{}, base.SgwIntStat{}, base.SgwIntStat{}, base.SgwIntStat{}, base.SgwIntStat{}, base.SgwIntStat{} |
| 1296 | backingStoreMap := CreateTestSingleBackingStoreMap(&testBackingStore{nil, &getDocumentCounter, &getRevisionCounter}, testCollectionID) |
| 1297 | cacheOptions := &RevisionCacheOptions{ |
| 1298 | MaxItemCount: 10, |
| 1299 | MaxBytes: 0, |
| 1300 | } |
| 1301 | cache := NewLRURevisionCache(cacheOptions, backingStoreMap, &cacheHitCounter, &cacheMissCounter, &cacheNumItems, &memoryBytesCounted) |
| 1302 | |
| 1303 | cache.Put(base.TestCtx(t), DocumentRevision{BodyBytes: []byte(`{"test":"1234"}`), DocID: "doc123", RevID: "1-abc", CV: &Version{Value: 123, SourceID: "test"}, History: Revisions{"start": 1}}, testCollectionID) |
| 1304 | _, err := cache.GetWithRev(base.TestCtx(t), "doc123", "1-abc", testCollectionID, false) |
| 1305 | |
| 1306 | assert.NoError(t, err) |
| 1307 | } |
| 1308 | |
| 1309 | // Ensure subsequent updates to delta don't mutate previously retrieved deltas |
| 1310 | func TestConcurrentLoad(t *testing.T) { |
nothing calls this directly
no test coverage detected