ctx.NodeName(nodeId), filename,
)
}
+ if _, err = os.Stat(filepath.Join(
+ ctx.Spool,
+ nodeId.String(),
+ string(nncp.TRx),
+ nncp.SeenDir,
+ fiInt.Name(),
+ )); err == nil || !os.IsNotExist(err) {
+ ctx.LogI("xfer-rx-seen", les, func(les nncp.LEs) string {
+ return logMsg(les) + ": packet already seen"
+ })
+ if !*keep {
+ if err = os.Remove(filename); err != nil {
+ ctx.LogE("xfer-rx-remove", les, err, logMsg)
+ isBad = true
+ }
+ }
+ continue
+ }
fd, err := os.Open(filename)
if err != nil {
ctx.LogE("xfer-rx-open", les, err, func(les nncp.LEs) string {
}
r, w := io.Pipe()
go func() {
- _, err := io.CopyN(w, bufio.NewReader(fd), fiInt.Size())
+ _, err := io.CopyN(
+ w, bufio.NewReaderSize(fd, nncp.MTHBlockSize), fiInt.Size(),
+ )
if err == nil {
err = w.Close()
}
})
continue
}
- if _, err = os.Stat(filepath.Join(
- dstPath, nncp.SeenDir, pktName,
- )); err == nil || !os.IsNotExist(err) {
- ctx.LogD("xfer-tx-seen", les, func(les nncp.LEs) string {
- return logMsg(les) + ": already seen"
- })
- continue
- }
tmp, err := nncp.TempFile(dstPath, "xfer")
if err != nil {
ctx.LogE("xfer-tx-mktemp", les, err, func(les nncp.LEs) string {
}
bufW := bufio.NewWriter(tmp)
copied, err := nncp.CopyProgressed(
- bufW, bufio.NewReader(fd), "Tx",
+ bufW, bufio.NewReaderSize(fd, nncp.MTHBlockSize), "Tx",
append(les, nncp.LE{K: "FullSize", V: job.Size}),
ctx.ShowPrgrs,
)