Function TestDeltaSyncConcurrentClientCachePopulation

db/database_test.go:1154–1232

TestDeltaSyncConcurrentClientCachePopulation tests delta sync behavior when multiple goroutines request the same delta simultaneously. Ensures that only one delta is computed and others wait for the cached result. More instances of duplicated delta computation will be seen for larger documents since

(t *testing.T)

// Ensures that only one delta is computed and others wait for the cached result.
// More instances of duplicated delta computation will be seen for larger documents since the delta computation takes longer.
func TestDeltaSyncConcurrentClientCachePopulation(t *testing.T) {
	if !base.IsEnterpriseEdition() {
		t.Skip("Delta sync only supported in EE")
	}

	tests := []struct {
		name              string
		docSize           int
		concurrentClients int
	}{
		{
			name:              "100KBDoc_100Clients",
			docSize:           100 * 1024,
			concurrentClients: 100,
		},
		{
			name:              "100KBDoc_1000Clients",
			docSize:           100 * 1024,
			concurrentClients: 1000,
		},
		{
			name:              "100KBDoc_5000Clients",
			docSize:           100 * 1024,
			concurrentClients: 5000,
		},
		{
			name:              "5MBDoc_10Clients",
			docSize:           5 * 1024 * 1024,
			concurrentClients: 10,
		},
		{
			name:              "5MBDoc_100Clients",
			docSize:           5 * 1024 * 1024,
			concurrentClients: 100,
		},
		{
			name:              "5MBDoc_1000Clients",
			docSize:           5 * 1024 * 1024,
			concurrentClients: 1000,
		},
		{
			name:              "5MBDoc_5000Clients",
			docSize:           5 * 1024 * 1024,
			concurrentClients: 5000,
		},
	}

	for _, test := range tests {
		t.Run(test.name, func(t *testing.T) {
			db, ctx := SetupTestDBWithOptions(t, DatabaseContextOptions{DeltaSyncOptions: DeltaSyncOptions{Enabled: true, RevMaxAgeSeconds: 300}})
			defer db.Close(ctx)
			collection, ctx := GetSingleDatabaseCollectionWithUser(ctx, t, db)

			docID := "doc1_" + test.name
			rev1, _, err := collection.Put(ctx, docID, Body{"foo": "bar", "bar": "buzz", "quux": strings.Repeat("a", test.docSize)})
			require.NoError(t, err)
			rev2, _, err := collection.Put(ctx, docID, Body{"foo": "bar", "quux": strings.Repeat("b", test.docSize), BodyRev: rev1})
			require.NoError(t, err)