Skip to content
GitLab
Projects
Groups
Snippets
Help
Loading...
Help
What's new
10
Help
Support
Community forum
Keyboard shortcuts
?
Submit feedback
Contribute to GitLab
Sign in
Toggle navigation
Open sidebar
dms3
interface-go-dms3-core
Commits
be8e8d1a
Commit
be8e8d1a
authored
Jan 21, 2019
by
Łukasz Magiera
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
coreapi: add some seeker tests
License: MIT Signed-off-by:
Łukasz Magiera
<
magik6k@gmail.com
>
parent
fbde8e27
Changes
1
Show whitespace changes
Inline
Side-by-side
Showing
1 changed file
with
105 additions
and
0 deletions
+105
-0
tests/unixfs.go
tests/unixfs.go
+105
-0
No files found.
tests/unixfs.go
View file @
be8e8d1a
...
@@ -3,9 +3,11 @@ package tests
...
@@ -3,9 +3,11 @@ package tests
import
(
import
(
"bytes"
"bytes"
"context"
"context"
"fmt"
"io"
"io"
"io/ioutil"
"io/ioutil"
"math"
"math"
"math/rand"
"os"
"os"
"strconv"
"strconv"
"strings"
"strings"
...
@@ -43,6 +45,7 @@ func (tp *provider) TestUnixfs(t *testing.T) {
...
@@ -43,6 +45,7 @@ func (tp *provider) TestUnixfs(t *testing.T) {
t
.
Run
(
"TestLsEmptyDir"
,
tp
.
TestLsEmptyDir
)
t
.
Run
(
"TestLsEmptyDir"
,
tp
.
TestLsEmptyDir
)
t
.
Run
(
"TestLsNonUnixfs"
,
tp
.
TestLsNonUnixfs
)
t
.
Run
(
"TestLsNonUnixfs"
,
tp
.
TestLsNonUnixfs
)
t
.
Run
(
"TestAddCloses"
,
tp
.
TestAddCloses
)
t
.
Run
(
"TestAddCloses"
,
tp
.
TestAddCloses
)
t
.
Run
(
"TestGetSeek"
,
tp
.
TestGetSeek
)
}
}
// `echo -n 'hello, world!' | ipfs add`
// `echo -n 'hello, world!' | ipfs add`
...
@@ -934,5 +937,107 @@ func (tp *provider) TestAddCloses(t *testing.T) {
...
@@ -934,5 +937,107 @@ func (tp *provider) TestAddCloses(t *testing.T) {
t
.
Errorf
(
"dir %d not closed!"
,
i
)
t
.
Errorf
(
"dir %d not closed!"
,
i
)
}
}
}
}
}
func
(
tp
*
provider
)
TestGetSeek
(
t
*
testing
.
T
)
{
ctx
,
cancel
:=
context
.
WithCancel
(
context
.
Background
())
defer
cancel
()
api
,
err
:=
tp
.
makeAPI
(
ctx
)
if
err
!=
nil
{
t
.
Error
(
err
)
}
dataSize
:=
int64
(
100000
)
tf
:=
files
.
NewReaderFile
(
io
.
LimitReader
(
rand
.
New
(
rand
.
NewSource
(
1403768328
)),
dataSize
))
p
,
err
:=
api
.
Unixfs
()
.
Add
(
ctx
,
tf
,
options
.
Unixfs
.
Chunker
(
"size-100"
))
if
err
!=
nil
{
t
.
Fatal
(
err
)
}
r
,
err
:=
api
.
Unixfs
()
.
Get
(
ctx
,
p
)
if
err
!=
nil
{
t
.
Fatal
(
err
)
}
f
:=
files
.
ToFile
(
r
)
if
f
==
nil
{
t
.
Fatal
(
"not a file"
)
}
orig
:=
make
([]
byte
,
dataSize
)
if
_
,
err
:=
f
.
Read
(
orig
);
err
!=
nil
{
t
.
Fatal
(
err
)
}
f
.
Close
()
origR
:=
bytes
.
NewReader
(
orig
)
r
,
err
=
api
.
Unixfs
()
.
Get
(
ctx
,
p
)
if
err
!=
nil
{
t
.
Fatal
(
err
)
}
f
=
files
.
ToFile
(
r
)
if
f
==
nil
{
t
.
Fatal
(
"not a file"
)
}
test
:=
func
(
offset
int64
,
whence
int
,
read
int
,
expect
int64
,
shouldEof
bool
)
{
t
.
Run
(
fmt
.
Sprintf
(
"seek%d+%d-r%d-%d"
,
whence
,
offset
,
read
,
expect
),
func
(
t
*
testing
.
T
)
{
n
,
err
:=
f
.
Seek
(
offset
,
whence
)
if
err
!=
nil
{
t
.
Fatal
(
err
)
}
origN
,
err
:=
origR
.
Seek
(
offset
,
whence
)
if
err
!=
nil
{
t
.
Fatal
(
err
)
}
if
n
!=
origN
{
t
.
Fatalf
(
"offsets didn't match, expected %d, got %d"
,
origN
,
n
)
}
buf
:=
make
([]
byte
,
read
)
origBuf
:=
make
([]
byte
,
read
)
origRead
,
err
:=
origR
.
Read
(
origBuf
)
if
err
!=
nil
{
t
.
Fatalf
(
"orig: %s"
,
err
)
}
r
,
err
:=
f
.
Read
(
buf
)
switch
{
case
shouldEof
&&
err
!=
nil
&&
err
!=
io
.
EOF
:
fallthrough
case
!
shouldEof
&&
err
!=
nil
:
t
.
Fatalf
(
"f: %s"
,
err
)
case
shouldEof
:
_
,
err
:=
f
.
Read
([]
byte
{
0
})
if
err
!=
io
.
EOF
{
t
.
Fatal
(
"expected EOF"
)
}
_
,
err
=
origR
.
Read
([]
byte
{
0
})
if
err
!=
io
.
EOF
{
t
.
Fatal
(
"expected EOF (orig)"
)
}
}
if
int64
(
r
)
!=
expect
{
t
.
Fatal
(
"read wrong amount of data"
)
}
if
r
!=
origRead
{
t
.
Fatal
(
"read different amount of data than bytes.Reader"
)
}
if
!
bytes
.
Equal
(
buf
,
origBuf
)
{
t
.
Fatal
(
"data didn't match"
)
}
})
}
test
(
3
,
io
.
SeekCurrent
,
10
,
10
,
false
)
test
(
3
,
io
.
SeekCurrent
,
10
,
10
,
false
)
test
(
500
,
io
.
SeekCurrent
,
10
,
10
,
false
)
test
(
350
,
io
.
SeekStart
,
100
,
100
,
false
)
test
(
-
123
,
io
.
SeekCurrent
,
100
,
100
,
false
)
test
(
dataSize
-
50
,
io
.
SeekStart
,
100
,
50
,
true
)
test
(
-
5
,
io
.
SeekEnd
,
100
,
5
,
true
)
}
}
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
.
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment