X-Git-Url: http://www.git.cypherpunks.ru/?a=blobdiff_plain;f=src%2Ftoss.go;h=0c27289e2cf55359ed8398f58d086c1b1eb97c88;hb=b47dbfe6687569650fa544a4ecf3e4ea388390cb;hp=7e7ce171661176fa7c4d64a4485f106f40d66639;hpb=6186049fee49895528baa8750b29ef58892f5978;p=nncp.git

diff --git a/src/toss.go b/src/toss.go
index 7e7ce17..0c27289 100644
--- a/src/toss.go
+++ b/src/toss.go
@@ -619,11 +619,11 @@ func jobProcess(
 				if err != nil {
 					panic(err)
 				}
-				if _, err = ctx.Tx(
+				if _, _, err = ctx.Tx(
 					node,
 					pktTrns,
 					nice,
-					int64(pktSize), 0,
+					int64(pktSize), 0, MaxFileSize,
 					pipeR,
 					pktName,
 					nil,
@@ -750,8 +750,14 @@ func jobProcess(
 				}
 				if nodeId != sender.Id && nodeId != pktEnc.Sender {
 					ctx.LogI("rx-area-echo", lesEcho, logMsgNode)
-					if _, err = ctx.Tx(
-						node, &pkt, nice, int64(pktSize), 0, fullPipeR, pktName, nil,
+					if _, _, err = ctx.Tx(
+						node,
+						&pkt,
+						nice,
+						int64(pktSize), 0, MaxFileSize,
+						fullPipeR,
+						pktName,
+						nil,
 					); err != nil {
 						ctx.LogE("rx-area", lesEcho, err, logMsgNode)
 						return err