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

diff --git a/src/toss.go b/src/toss.go
index ebe20fb..d6c74c4 100644
--- a/src/toss.go
+++ b/src/toss.go
@@ -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,