Function multiNodeUpdate

db/sequence_allocator_test.go:852–875

multiNodeUpdate obtains an initial sequence from an import allocator (import node), then performs repeated updates to the doc using random pool of iterators (random SG node). Performs sequenceGreaterThan, then ensures that allocator doesn't release more than the sequence batch size

(t *testing.T, ctx context.Context, importAllocator *sequenceAllocator, clientAllocators []*sequenceAllocator, updateCount int, interval time.Duration)

// multiNodeUpdate obtains an initial sequence from an import allocator (import node), then performs repeated updates to the doc using random pool of iterators (random SG node).
// Performs sequenceGreaterThan, then ensures that allocator doesn't release more than the sequence batch size
func multiNodeUpdate(t *testing.T, ctx context.Context, importAllocator *sequenceAllocator, clientAllocators []*sequenceAllocator, updateCount int, interval time.Duration) (releasedCount uint64) {
	currentSequence, _ := importAllocator.nextSequence(ctx)

	for i := 0; i < updateCount; i++ {
		allocatorIndex := rand.Intn(len(clientAllocators))
		clientAllocator := clientAllocators[allocatorIndex]
		nextSequence, err := clientAllocator.nextSequence(ctx)
		require.NoError(t, err, "nextSequence error: %v", err)
		if nextSequence < currentSequence {
			prevNext := nextSequence
			var numReleased uint64
			nextSequence, numReleased, err = clientAllocator.nextSequenceGreaterThan(ctx, currentSequence)
			require.NoError(t, err, "nextSequenceGreaterThan error: %v", err)
			log.Printf("allocator %d released %d sequences because next < current (%d < %d)", numReleased, allocatorIndex, prevNext, currentSequence)
			// At most clientAllocator should only need to release the current batch
			assert.LessOrEqual(t, numReleased, getClientSequenceBatchSize(clientAllocator))
			releasedCount += numReleased
		}
		currentSequence = nextSequence
		time.Sleep(interval)
	}

	return releasedCount
}

func runAllocator(ctx context.Context, a *sequenceAllocator, frequency time.Duration) (allocationCount uint64) {