[]string{"arg0", "arg1"},
strings.NewReader("BODY\n"),
1<<15,
+ false,
+ false,
); err != nil {
t.Error(err)
return false
}
for job := range ctx.Jobs(ctx.Self.Id, TTx) {
var buf bytes.Buffer
- _, _, err := PktEncRead(ctx.Self, ctx.Neigh, job.Fd, &buf)
+ fd, err := os.Open(job.Path)
+ if err != nil {
+ t.Error(err)
+ return false
+ }
+ _, _, err = PktEncRead(ctx.Self, ctx.Neigh, fd, &buf)
if err != nil {
t.Error(err)
return false
Magic: MagicNNCPPv3,
Type: PktTypeTrns,
PathLen: blake2b.Size256,
- Path: new([MaxPathSize]byte),
}
copy(pktTrans.Path[:], nodeOur.Id[:])
var dst bytes.Buffer
- if err := PktEncWrite(
+ if _, err := PktEncWrite(
ctx.Self,
ctx.Neigh[*nodeOur.Id],
&pktTrans,