Function TestActivateConcurrentSameName

core/mount/manager/manager_test.go:562–601

(t *testing.T)

}

func TestActivateConcurrentSameName(t *testing.T) {
	td := t.TempDir()
	metadb := filepath.Join(td, "mounts.db")
	targetdir := filepath.Join(td, "m")
	db, err := bolt.Open(metadb, 0600, nil)
	require.NoError(t, err)
	ctx := namespaces.WithNamespace(context.Background(), "test")

	mountC := new(atomic.Int32)
	m, err := NewManager(db, targetdir, WithMountHandler("noop", &noopHandler{mounts: mountC}))
	require.NoError(t, err)
	t.Cleanup(func() { assert.NoError(t, m.(io.Closer).Close()) })

	mounts := []mount.Mount{{Type: "noop"}}

	// Launch two concurrent activations with the same name.
	// The per-name lock should serialize them: first succeeds,
	// second gets ErrAlreadyExists (not a stale-recovery race).
	errs := make(chan error, 2)
	for i := 0; i < 2; i++ {
		go func() {
			_, err := m.Activate(ctx, "task1", mounts)
			errs <- err
		}()
	}

	err1 := <-errs
	err2 := <-errs

	// Exactly one should succeed and one should get ErrAlreadyExists
	if err1 == nil && errdefs.IsAlreadyExists(err2) {
		// ok
	} else if err2 == nil && errdefs.IsAlreadyExists(err1) {
		// ok
	} else {
		t.Fatalf("expected one nil and one ErrAlreadyExists, got: %v, %v", err1, err2)
	}

	assert.NoError(t, m.Deactivate(ctx, "task1"))
}

// TODO: Test deactivate
// TODO: Test Sync