X-Git-Url: http://www.git.cypherpunks.ru/?a=blobdiff_plain;f=src%2Ftoss.go;h=2d7eeede063884e855cfe119b9f8cb9c2cca64f3;hb=cf9363f956cb2d93a581c11ed65c5b02910d10d5;hp=ebe20fbf0dd159c626d7b91801e814ddbc34ce0b;hpb=835c153195c63c59df9a40a4de1e16fff09c003f;p=nncp.git

diff --git a/src/toss.go b/src/toss.go
index ebe20fb..2d7eeed 100644
--- a/src/toss.go
+++ b/src/toss.go
@@ -1,6 +1,6 @@
 /*
 NNCP -- Node to Node copy, utilities for store-and-forward data exchange
-Copyright (C) 2016-2022 Sergey Matveev <stargrave@stargrave.org>
+Copyright (C) 2016-2023 Sergey Matveev <stargrave@stargrave.org>
 
 This program is free software: you can redistribute it and/or modify
 it under the terms of the GNU General Public License as published by
@@ -621,7 +621,7 @@ func jobProcess(
 				if err != nil {
 					panic(err)
 				}
-				if _, _, err = ctx.Tx(
+				if _, _, _, err = ctx.Tx(
 					node,
 					pktTrns,
 					nice,
@@ -752,7 +752,7 @@ func jobProcess(
 				}
 				if nodeId != sender.Id && nodeId != pktEnc.Sender {
 					ctx.LogI("rx-area-echo", lesEcho, logMsgNode)
-					if _, _, err = ctx.Tx(
+					if _, _, _, err = ctx.Tx(
 						node,
 						&pkt,
 						nice,
@@ -926,6 +926,8 @@ func jobProcess(
 						return logMsg(les) + ": removing packet"
 					})
 					return err
+				} else if ctx.HdrUsage {
+					os.Remove(JobPath2Hdr(pktPath))
 				}
 			}
 		} else {
@@ -1061,7 +1063,7 @@ func (ctx *Ctx) Toss(
 		sharedKey, _, _, err = PktEncRead(
 			ctx.Self,
 			ctx.Neigh,
-			bufio.NewReader(fd),
+			bufio.NewReaderSize(fd, MTHBlockSize),
 			pipeWB,
 			sharedKey == nil,
 			sharedKey,