-
Notifications
You must be signed in to change notification settings - Fork 0
/
pool_test.go
108 lines (92 loc) · 2.26 KB
/
pool_test.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
package joint_test
import (
"io/fs"
"testing"
"testing/fstest"
jnt "github.com/schwarzlichtbezirk/joint"
)
var jpfiles = []string{
"fox.txt",
"data/рыба.txt",
"data/docs/doc1.txt",
"data/доки/док2.txt",
"disk/internal.iso/fox.txt",
"disk/internal.iso/docs/doc2.txt",
"disk/internal.iso/доки/док1.txt",
}
func TestMakeJoint(t *testing.T) {
var j, err = jnt.MakeJoint("testdata/external.iso/disk/internal.iso")
if err != nil {
t.Fatal(err)
}
defer j.Cleanup()
var f fs.File
if f, err = j.Open("docs/doc2.txt"); err != nil {
t.Fatal(err)
}
defer f.Close()
var b [9]byte // buffer for "totam rem" chunk from file content
if _, err = j.ReadAt(b[:], 99); err != nil {
t.Fatal(err)
}
if string(b[:]) != "totam rem" {
t.Fatal("read string does not match to pattern")
}
// check up joints chain
var ok bool
var j0, j1 *jnt.IsoJoint
if j0, ok = j.(*jnt.IsoJoint); !ok {
t.Fatal("can not cast to ISO joint")
}
if j1, ok = j0.Base.(*jnt.IsoJoint); !ok {
t.Fatal("can not cast base to ISO joint")
}
if _, ok = j1.Base.(*jnt.SysJoint); !ok {
t.Fatal("can not cast primary joint to system joint")
}
}
func TestOpenFile(t *testing.T) {
var jp = jnt.NewJointPool()
defer jp.Close()
var f, err = jp.Open("testdata/external.iso/disk/internal.iso/docs/doc1.txt")
if err != nil {
t.Fatal(err)
}
var jw, ok = f.(jnt.JointWrap)
if !ok {
t.Fatal("can not cast joint to wrapper")
}
var b [11]byte // buffer for "ipsum dolor" chunk from file content
if _, err = jw.ReadAt(b[:], 6); err != nil {
t.Fatal(err)
}
if string(b[:]) != "ipsum dolor" {
t.Fatal("read string does not match to pattern")
}
var jc = jw.GetCache()
if jc == nil {
t.Fatal("joint cache does not set")
}
if jc.Key() != "testdata/external.iso/disk/internal.iso" {
t.Fatalf("joint cache key '%s' does not match to expected", jc.Key())
}
var c1 = jc.Count()
f.Close()
var c2 = jc.Count()
if c2-c1 != 1 {
t.Fatalf("joint cache have %d before close, after %d", c1, c2)
}
}
func TestPoolFS(t *testing.T) {
var err error
var jp = jnt.NewJointPool()
defer jp.Close()
var sp fs.FS
if sp, err = jp.Sub("testdata/external.iso"); err != nil {
t.Fatal(err)
}
// test FS at the end
if err = fstest.TestFS(sp, jpfiles...); err != nil {
t.Fatal(err)
}
}