Function TestResyncStopUsingDCPStream

rest/adminapitest/admin_api_test.go:1401–1445

(t *testing.T)

}

func TestResyncStopUsingDCPStream(t *testing.T) {
	base.TestRequiresDCPResync(t)

	syncFn := `
	function(doc) {
		channel("x")
	}`

	testBucket := base.GetTestBucket(t)

	rt := rest.NewRestTester(t,
		&rest.RestTesterConfig{
			SyncFn:           syncFn,
			CustomTestBucket: testBucket,
		},
	)
	defer rt.Close()

	numOfDocs := 1000
	// gsi is slower than views, so update the number of documents for views so stopping the resync will not complete
	if base.TestsDisableGSI() {
		numOfDocs = 5000
	}
	for i := range numOfDocs {
		rt.CreateTestDoc(fmt.Sprintf("doc%d", i))
	}

	rt.WaitForPendingChanges()

	require.Equal(t, int64(numOfDocs), rt.GetDatabase().DbStats.Database().SyncFunctionCount.Value())

	rt.TakeDbOffline()

	response := rt.SendAdminRequest("POST", "/db/_resync?action=start", "")
	rest.RequireStatus(t, response, http.StatusOK)
	rt.WaitForResyncDCPStatus(db.BackgroundProcessStateRunning)

	response = rt.SendAdminRequest("POST", "/db/_resync?action=stop", "")
	rest.RequireStatus(t, response, http.StatusOK)

	rt.WaitForResyncDCPStatus(db.BackgroundProcessStateStopped)

	// make sure resync stopped before it completed
	require.Less(t, int(rt.GetDatabase().DbStats.Database().SyncFunctionCount.Value()), numOfDocs*2)
}

// Single threaded bring DB online
func TestDBOnlineSingle(t *testing.T) {