X-Git-Url: http://www.git.cypherpunks.ru/?a=blobdiff_plain;f=src%2Ftoss.go;h=d6c74c405cf069fc5f203525190a3b5315fd3b02;hb=c2b17fd0fc439e420710f53602604e8823c2fb1d;hp=4cc4392a6f2404478b5893ecf34193d6b0149e5d;hpb=8f99a73cf379f046b3bfb0f4a1a715bb5e215106;p=nncp.git diff --git a/src/toss.go b/src/toss.go index 4cc4392..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, @@ -1063,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,