wire_metadata_test.go RawHistoryFolder

1package daemon
2
3import (
4	"fmt"
5	"sync"
6	"testing"
7)
8
9func TestServerWelcomeSnapshotsSessionMetadataUnderLock(t *testing.T) {
10	sess := &session{sessionCore: sessionCore{id: "session", name: "initial"}}
11	ac := &attachedClient{resumeToken: 42}
12
13	var wg sync.WaitGroup
14	wg.Go(func() {
15		for i := range 1000 {
16			sess.mu.Lock()
17			sess.name = fmt.Sprintf("session-%d", i)
18			sess.ephemeral = i%2 == 0
19			sess.mu.Unlock()
20		}
21	})
22
23	for range 1000 {
24		welcome, err := serverWelcome(sess, ac.resumeToken)
25		if err != nil {
26			t.Fatalf("serverWelcome() error = %v", err)
27		}
28		if welcome.SessionID != "session" || welcome.SessionName == "" {
29			t.Fatalf("welcome metadata = %+v", welcome)
30		}
31	}
32	wg.Wait()
33}