Function TestLockWriteBlocksRead

pkg/internal/filesystem/lock_test.go:228–273

(t *testing.T)

}

func TestLockWriteBlocksRead(t *testing.T) {
	t.Parallel()

	var waitGroup sync.WaitGroup

	var concurrentKey uint32

	tempDir := t.TempDir()

	waitGroup.Add(2)

	// Start a lock, set the key, sleep 1s and confirm the key is still the same
	go func() {
		defer waitGroup.Done()

		lErr := filesystem.WithLock(tempDir, func() error {
			time.Sleep(1 * time.Second)

			atomic.StoreUint32(&concurrentKey, routine1)

			assert.Equal(t, atomic.LoadUint32(&concurrentKey), routine1)

			return nil
		})

		assert.NilError(t, lErr, "locking should not error")
	}()

	time.Sleep(50 * time.Millisecond)

	// Start a readonly lock immediately
	// Confirm the key has been set by the write lock
	go func() {
		defer waitGroup.Done()

		lErr := filesystem.WithReadOnlyLock(tempDir, func() error {
			assert.Equal(t, atomic.LoadUint32(&concurrentKey), routine1)

			return nil
		})

		assert.NilError(t, lErr, "locking should not error")
	}()

	waitGroup.Wait()
}