session_move_locator_test.go RawHistoryFolder

1package daemon
2
3import (
4	"fmt"
5	"sync"
6	"testing"
7
8	"github.com/stretchr/testify/require"
9
10	"github.com/bnema/vev/internal/domain"
11)
12
13func TestSessionMoveLocatorSynchronizesMutableNameRead(t *testing.T) {
14	sess := &session{sessionCore: sessionCore{id: domain.SessionID("session-id"),
15		incarnation: domain.IncarnationID{1},
16		name:        "initial"},
17	}
18	start := make(chan struct{})
19	var wg sync.WaitGroup
20	wg.Add(2)
21	go func() {
22		defer wg.Done()
23		<-start
24		for i := range 10_000 {
25			sess.mu.Lock()
26			sess.name = fmt.Sprintf("session-%d", i)
27			sess.mu.Unlock()
28		}
29	}()
30	go func() {
31		defer wg.Done()
32		<-start
33		for range 10_000 {
34			_ = sessionMoveLocator(sess)
35		}
36	}()
37	close(start)
38	wg.Wait()
39
40	locator := sessionMoveLocator(sess)
41	require.Equal(t, sess.id, locator.ID)
42	require.Equal(t, sess.incarnation, locator.Incarnation)
43	require.Equal(t, "session-9999", locator.Name)
44}