defer os.RemoveAll(spool)
nodeOur, err := NewNodeGenerate()
if err != nil {
- panic(err)
+ t.Error(err)
+ return false
}
ctx := Ctx{
Spool: spool,
}
our, err := NewNodeGenerate()
if err != nil {
- panic(err)
+ t.Error(err)
+ return false
}
privates[recipient] = our
ctx.Neigh[*our.Id] = our.Their()
[]byte{123},
1<<15,
); err != nil {
- panic(err)
+ t.Error(err)
+ return false
}
}
for _, recipient := range recipients {
defer os.RemoveAll(spool)
nodeOur, err := NewNodeGenerate()
if err != nil {
- panic(err)
+ t.Error(err)
+ return false
}
ctx := Ctx{
Spool: spool,
fileName,
1<<15,
); err != nil {
- panic(err)
+ t.Error(err)
+ return false
}
}
rxPath := filepath.Join(spool, ctx.Self.Id.String(), string(TRx))
defer os.RemoveAll(spool)
nodeOur, err := NewNodeGenerate()
if err != nil {
- panic(err)
+ t.Error(err)
+ return false
}
ctx := Ctx{
Spool: spool,
[]byte("doesnotmatter"),
os.FileMode(0600),
); err != nil {
- panic(err)
+ t.Error(err)
+ return false
}
incomingPath := filepath.Join(spool, "incoming")
for i := 0; i < files; i++ {
"samefile",
1<<15,
); err != nil {
- panic(err)
+ t.Error(err)
+ return false
}
}
rxPath := filepath.Join(spool, ctx.Self.Id.String(), string(TRx))
defer os.RemoveAll(spool)
nodeOur, err := NewNodeGenerate()
if err != nil {
- panic(err)
+ t.Error(err)
+ return false
}
ctx := Ctx{
Spool: spool,
fileName,
1<<15,
); err != nil {
- panic(err)
+ t.Error(err)
+ return false
}
}
rxPath := filepath.Join(spool, ctx.Self.Id.String(), string(TRx))
var buf bytes.Buffer
_, _, err := PktEncRead(ctx.Self, ctx.Neigh, job.Fd, &buf)
if err != nil {
- panic(err)
+ t.Error(err)
+ return false
}
var pkt Pkt
if _, err = xdr.Unmarshal(&buf, &pkt); err != nil {
- panic(err)
+ t.Error(err)
+ return false
}
dst := string(pkt.Path[:int(pkt.PathLen)])
if bytes.Compare(buf.Bytes(), files[dst]) != 0 {
defer os.RemoveAll(spool)
nodeOur, err := NewNodeGenerate()
if err != nil {
- panic(err)
+ t.Error(err)
+ return false
}
ctx := Ctx{
Spool: spool,
bytes.NewReader(data),
&dst,
); err != nil {
- panic(err)
+ t.Error(err)
+ return false
}
checksum := blake2b.Sum256(dst.Bytes())
if err := ioutil.WriteFile(