test: reach 80% coverage of unixfs/mod
License: MIT Signed-off-by: Jakub Sztandera <kubuxu@protonmail.ch>
Jakub Sztandera committed
Aug 18, 2016 at 17:59 UTC
c56e720d91bdf4dda040b41b3c76379fb2e9d6be
1 file changed
+35
unixfs/mod/dagmodifier_test.go
+35
@@ -644,6 +644,10 @@ func TestReadAndSeek(t *testing.T) {
644
writeBuf := []byte{0, 1, 2, 3, 4, 5, 6, 7}
645
dagmod.Write(writeBuf)
646
647
+ if !dagmod.HasChanges() {
648
+ t.Fatal("there are changes, this should be true")
649
+ }
650
+
651
readBuf := make([]byte, 4)
652
offset, err := dagmod.Seek(0, os.SEEK_SET)
653
if offset != 0 {
@@ -693,6 +697,37 @@ func TestReadAndSeek(t *testing.T) {
697
698
}
699
700
+func TestCtxRead(t *testing.T) {
701
+ dserv := getMockDagServ(t)
702
+
703
+ _, n := getNode(t, dserv, 0)
704
+ ctx, cancel := context.WithCancel(context.Background())
705
+ defer cancel()
706
+
707
+ dagmod, err := NewDagModifier(ctx, n, dserv, sizeSplitterGen(512))
708
+ if err != nil {
709
+ t.Fatal(err)
710
+ }
711
+
712
+ _, err = dagmod.Write([]byte{0, 1, 2, 3, 4, 5, 6, 7})
713
+ if err != nil {
714
+ t.Fatal(err)
715
+ }
716
+ dagmod.Seek(0, os.SEEK_SET)
717
+
718
+ readBuf := make([]byte, 4)
719
+ _, err = dagmod.CtxReadFull(ctx, readBuf)
720
+ if err != nil {
721
+ t.Fatal(err)
722
+ }
723
+ err = arrComp(readBuf, []byte{0, 1, 2, 3})
724
+ if err != nil {
725
+ t.Fatal(err)
726
+ }
727
+ // TODO(Kubuxu): context cancel case, I will do it after I figure out dagreader tests,
728
+ // because this is exacelly the same.
729
+}
730
+
731
func BenchmarkDagmodWrite(b *testing.B) {
732
b.StopTimer()
733
dserv := getMockDagServ(b)