Function TestConcurrentPutAndGetOnRevCache

db/revision_cache_test.go:2028–2080

TestConcurrentPutAndGetOnRevCache: - Perform a Get with rev on the cache for a doc not in the cache - Concurrently perform a PUT on the cache with doc revision the same as the GET - Assert we get consistent cache with only 1 entry in lookup maps and the cache itself

(t *testing.T)

//   - Concurrently perform a PUT on the cache with doc revision the same as the GET
//   - Assert we get consistent cache with only 1 entry in lookup maps and the cache itself
func TestConcurrentPutAndGetOnRevCache(t *testing.T) {
	cacheHitCounter, cacheMissCounter, cacheNumItems, memoryBytesCounted, getDocumentCounter, getRevisionCounter := base.SgwIntStat{}, base.SgwIntStat{}, base.SgwIntStat{}, base.SgwIntStat{}, base.SgwIntStat{}, base.SgwIntStat{}
	cacheOptions := &RevisionCacheOptions{
		MaxItemCount: 10,
		MaxBytes:     0,
	}
	cache := NewLRURevisionCache(cacheOptions, CreateTestSingleBackingStoreMap(&testBackingStore{[]string{"test_doc"}, &getDocumentCounter, &getRevisionCounter}, testCollectionID), &cacheHitCounter, &cacheMissCounter, &cacheNumItems, &memoryBytesCounted)

	ctx := base.TestCtx(t)

	wg := sync.WaitGroup{}
	wg.Add(2)

	cv := Version{SourceID: "test", Value: 123}
	docRev := DocumentRevision{
		DocID:     "doc1",
		RevID:     "1-abc",
		BodyBytes: []byte(`{"testing":true}`),
		Channels:  base.SetOf("chan1"),
		History:   Revisions{"start": 1},
		CV:        &cv,
	}

	go func() {
		_, err := cache.GetWithRev(ctx, "doc1", "1-abc", testCollectionID, RevCacheIncludeDelta)
		require.NoError(t, err)
		wg.Done()
	}()

	go func() {
		cache.Put(ctx, docRev, testCollectionID)
		wg.Done()
	}()

	wg.Wait()

	revElement := cache.cache[IDAndRev{RevID: "1-abc", DocID: "doc1"}].Value.(*revCacheValue)
	cvElement := cache.hlvCache[IDandCV{DocID: "doc1", Source: "test", Version: 123}].Value.(*revCacheValue)

	assert.LessOrEqual(t, cache.lruList.Len(), 2)
	assert.Equal(t, 1, len(cache.cache))
	assert.Equal(t, 1, len(cache.hlvCache))
	assert.Equal(t, revElement.revID, cvElement.revID)
	assert.Equal(t, revElement.id, cvElement.id)
	assert.Equal(t, revElement.cv.String(), cvElement.cv.String())
	var revElem Body
	var cvElem Body
	err := base.JSONUnmarshal(revElement.bodyBytes, &revElem)
	require.NoError(t, err)
	err = base.JSONUnmarshal(cvElement.bodyBytes, &cvElem)
	require.NoError(t, err)
	assert.Equal(t, revElem["testing"].(bool), cvElem["testing"].(bool))
}

func TestLoadActiveDocFromBucketRevCacheChurn(t *testing.T) {
	base.SkipImportTestsIfNotEnabled(t)