X-Git-Url: http://www.git.cypherpunks.ru/?a=blobdiff_plain;f=src%2Ftoss.go;h=79cc50f496982c96b976c532fc47f327dfcdaf6c;hb=18de9cc50e2f08382295f7a44b5668262a19ec4b;hp=ebe20fbf0dd159c626d7b91801e814ddbc34ce0b;hpb=2e59e1d8da61bc5dee797d351e50e8ed114aa4c7;p=nncp.git diff --git a/src/toss.go b/src/toss.go index ebe20fb..79cc50f 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 {