aboutsummaryrefslogtreecommitdiff
path: root/weed/filer/filechunks_read_test.go
diff options
context:
space:
mode:
authorchrislu <chris.lu@gmail.com>2022-10-28 12:53:19 -0700
committerchrislu <chris.lu@gmail.com>2022-10-28 12:53:19 -0700
commitea2637734a13a08d11d4f26e80c1324664bf7ffc (patch)
tree6708b9a0d07a0518a6fdf151d59bf3fc46053430 /weed/filer/filechunks_read_test.go
parent1e0d64c04883a8d7b09677e9721f9e189743e2f3 (diff)
downloadseaweedfs-ea2637734a13a08d11d4f26e80c1324664bf7ffc.tar.xz
seaweedfs-ea2637734a13a08d11d4f26e80c1324664bf7ffc.zip
refactor filer proto chunk variable from mtime to modified_ts_ns
Diffstat (limited to 'weed/filer/filechunks_read_test.go')
-rw-r--r--weed/filer/filechunks_read_test.go168
1 files changed, 84 insertions, 84 deletions
diff --git a/weed/filer/filechunks_read_test.go b/weed/filer/filechunks_read_test.go
index b3fa52ebd..d4bfca72e 100644
--- a/weed/filer/filechunks_read_test.go
+++ b/weed/filer/filechunks_read_test.go
@@ -11,41 +11,41 @@ func TestReadResolvedChunks(t *testing.T) {
chunks := []*filer_pb.FileChunk{
{
- FileId: "a",
- Offset: 0,
- Size: 100,
- Mtime: 1,
+ FileId: "a",
+ Offset: 0,
+ Size: 100,
+ ModifiedTsNs: 1,
},
{
- FileId: "b",
- Offset: 50,
- Size: 100,
- Mtime: 2,
+ FileId: "b",
+ Offset: 50,
+ Size: 100,
+ ModifiedTsNs: 2,
},
{
- FileId: "c",
- Offset: 200,
- Size: 50,
- Mtime: 3,
+ FileId: "c",
+ Offset: 200,
+ Size: 50,
+ ModifiedTsNs: 3,
},
{
- FileId: "d",
- Offset: 250,
- Size: 50,
- Mtime: 4,
+ FileId: "d",
+ Offset: 250,
+ Size: 50,
+ ModifiedTsNs: 4,
},
{
- FileId: "e",
- Offset: 175,
- Size: 100,
- Mtime: 5,
+ FileId: "e",
+ Offset: 175,
+ Size: 100,
+ ModifiedTsNs: 5,
},
}
visibles := readResolvedChunks(chunks)
for _, visible := range visibles {
- fmt.Printf("[%d,%d) %s %d\n", visible.start, visible.stop, visible.fileId, visible.modifiedTime)
+ fmt.Printf("[%d,%d) %s %d\n", visible.start, visible.stop, visible.fileId, visible.modifiedTsNs)
}
}
@@ -76,8 +76,8 @@ func TestRandomizedReadResolvedChunks(t *testing.T) {
for _, visible := range visibles {
for i := visible.start; i < visible.stop; i++ {
- if array[i] != visible.modifiedTime {
- t.Errorf("position %d expected ts %d actual ts %d", i, array[i], visible.modifiedTime)
+ if array[i] != visible.modifiedTsNs {
+ t.Errorf("position %d expected ts %d actual ts %d", i, array[i], visible.modifiedTsNs)
}
}
}
@@ -92,10 +92,10 @@ func randomWrite(array []int64, start int64, size int64, ts int64) *filer_pb.Fil
}
// fmt.Printf("write [%d,%d) %d\n", start, start+size, ts)
return &filer_pb.FileChunk{
- FileId: "",
- Offset: start,
- Size: uint64(size),
- Mtime: ts,
+ FileId: "",
+ Offset: start,
+ Size: uint64(size),
+ ModifiedTsNs: ts,
}
}
@@ -105,10 +105,10 @@ func TestSequentialReadResolvedChunks(t *testing.T) {
var chunks []*filer_pb.FileChunk
for ts := int64(0); ts < 13; ts++ {
chunks = append(chunks, &filer_pb.FileChunk{
- FileId: "",
- Offset: chunkSize * ts,
- Size: uint64(chunkSize),
- Mtime: 1,
+ FileId: "",
+ Offset: chunkSize * ts,
+ Size: uint64(chunkSize),
+ ModifiedTsNs: 1,
})
}
@@ -122,89 +122,89 @@ func TestActualReadResolvedChunks(t *testing.T) {
chunks := []*filer_pb.FileChunk{
{
- FileId: "5,e7b96fef48",
- Offset: 0,
- Size: 2097152,
- Mtime: 1634447487595823000,
+ FileId: "5,e7b96fef48",
+ Offset: 0,
+ Size: 2097152,
+ ModifiedTsNs: 1634447487595823000,
},
{
- FileId: "5,e5562640b9",
- Offset: 2097152,
- Size: 2097152,
- Mtime: 1634447487595826000,
+ FileId: "5,e5562640b9",
+ Offset: 2097152,
+ Size: 2097152,
+ ModifiedTsNs: 1634447487595826000,
},
{
- FileId: "5,df033e0fe4",
- Offset: 4194304,
- Size: 2097152,
- Mtime: 1634447487595827000,
+ FileId: "5,df033e0fe4",
+ Offset: 4194304,
+ Size: 2097152,
+ ModifiedTsNs: 1634447487595827000,
},
{
- FileId: "7,eb08148a9b",
- Offset: 6291456,
- Size: 2097152,
- Mtime: 1634447487595827000,
+ FileId: "7,eb08148a9b",
+ Offset: 6291456,
+ Size: 2097152,
+ ModifiedTsNs: 1634447487595827000,
},
{
- FileId: "7,e0f92d1604",
- Offset: 8388608,
- Size: 2097152,
- Mtime: 1634447487595828000,
+ FileId: "7,e0f92d1604",
+ Offset: 8388608,
+ Size: 2097152,
+ ModifiedTsNs: 1634447487595828000,
},
{
- FileId: "7,e33cb63262",
- Offset: 10485760,
- Size: 2097152,
- Mtime: 1634447487595828000,
+ FileId: "7,e33cb63262",
+ Offset: 10485760,
+ Size: 2097152,
+ ModifiedTsNs: 1634447487595828000,
},
{
- FileId: "5,ea98e40e93",
- Offset: 12582912,
- Size: 2097152,
- Mtime: 1634447487595829000,
+ FileId: "5,ea98e40e93",
+ Offset: 12582912,
+ Size: 2097152,
+ ModifiedTsNs: 1634447487595829000,
},
{
- FileId: "5,e165661172",
- Offset: 14680064,
- Size: 2097152,
- Mtime: 1634447487595829000,
+ FileId: "5,e165661172",
+ Offset: 14680064,
+ Size: 2097152,
+ ModifiedTsNs: 1634447487595829000,
},
{
- FileId: "3,e692097486",
- Offset: 16777216,
- Size: 2097152,
- Mtime: 1634447487595830000,
+ FileId: "3,e692097486",
+ Offset: 16777216,
+ Size: 2097152,
+ ModifiedTsNs: 1634447487595830000,
},
{
- FileId: "3,e28e2e3cbd",
- Offset: 18874368,
- Size: 2097152,
- Mtime: 1634447487595830000,
+ FileId: "3,e28e2e3cbd",
+ Offset: 18874368,
+ Size: 2097152,
+ ModifiedTsNs: 1634447487595830000,
},
{
- FileId: "3,e443974d4e",
- Offset: 20971520,
- Size: 2097152,
- Mtime: 1634447487595830000,
+ FileId: "3,e443974d4e",
+ Offset: 20971520,
+ Size: 2097152,
+ ModifiedTsNs: 1634447487595830000,
},
{
- FileId: "2,e815bed597",
- Offset: 23068672,
- Size: 2097152,
- Mtime: 1634447487595831000,
+ FileId: "2,e815bed597",
+ Offset: 23068672,
+ Size: 2097152,
+ ModifiedTsNs: 1634447487595831000,
},
{
- FileId: "5,e94715199e",
- Offset: 25165824,
- Size: 1974736,
- Mtime: 1634447487595832000,
+ FileId: "5,e94715199e",
+ Offset: 25165824,
+ Size: 1974736,
+ ModifiedTsNs: 1634447487595832000,
},
}
visibles := readResolvedChunks(chunks)
for _, visible := range visibles {
- fmt.Printf("[%d,%d) %s %d\n", visible.start, visible.stop, visible.fileId, visible.modifiedTime)
+ fmt.Printf("[%d,%d) %s %d\n", visible.start, visible.stop, visible.fileId, visible.modifiedTsNs)
}
}