syncfile_test.go RawHistoryFolder

1package syncfile
2
3import (
4	"context"
5	"errors"
6	"os"
7	"testing"
8	"time"
9)
10
11// A pipe stands in for a sync file: readable means signalled.
12func TestWaitReturnsWhenReadable(t *testing.T) {
13	r, w, err := os.Pipe()
14	if err != nil {
15		t.Fatal(err)
16	}
17	defer r.Close()
18	go func() {
19		time.Sleep(10 * time.Millisecond)
20		_, _ = w.Write([]byte{1})
21		w.Close()
22	}()
23	if err := Wait(context.Background(), r); err != nil {
24		t.Fatal(err)
25	}
26}
27
28func TestWaitStopsOnCancel(t *testing.T) {
29	r, w, err := os.Pipe()
30	if err != nil {
31		t.Fatal(err)
32	}
33	defer r.Close()
34	defer w.Close()
35	ctx, cancel := context.WithTimeout(context.Background(), 20*time.Millisecond)
36	defer cancel()
37	if err := Wait(ctx, r); !errors.Is(err, context.DeadlineExceeded) {
38		t.Fatalf("err %v", err)
39	}
40}
41
42// POLLERR alone (a write end whose reader is gone) is not a signal.
43func TestWaitReportsErrorEvents(t *testing.T) {
44	r, w, err := os.Pipe()
45	if err != nil {
46		t.Fatal(err)
47	}
48	defer w.Close()
49	r.Close()
50	if err := Wait(context.Background(), w); err == nil {
51		t.Fatal("POLLERR taken as signalled")
52	}
53}