X-Git-Url: http://www.git.cypherpunks.ru/?p=nncp.git;a=blobdiff_plain;f=src%2Ftx.go;h=f7f099b39f3239c34979388be784393c694cfda8;hp=e38084e1a7a3c01390987af3da42c8667d2ee4ab;hb=c2b17fd0fc439e420710f53602604e8823c2fb1d;hpb=ffe4b2fbf50c031e9c002f2395957859cb4787cc

diff --git a/src/tx.go b/src/tx.go
index e38084e..f7f099b 100644
--- a/src/tx.go
+++ b/src/tx.go
@@ -388,7 +388,9 @@ func prepareTxFile(srcPath string) (
 				fd.Close()
 				return w.CloseWithError(err)
 			}
-			if _, err = io.Copy(tarWr, bufio.NewReader(fd)); err != nil {
+			if _, err = io.Copy(
+				tarWr, bufio.NewReaderSize(fd, MTHBlockSize),
+			); err != nil {
 				fd.Close()
 				return w.CloseWithError(err)
 			}
@@ -441,7 +443,7 @@ func (ctx *Ctx) TxFile(
 		_, finalSize, pktName, err := ctx.Tx(
 			node, pkt, nice,
 			srcSize, minSize, maxSize,
-			bufio.NewReader(reader), dstPath, areaId,
+			bufio.NewReaderSize(reader, MTHBlockSize), dstPath, areaId,
 		)
 		les := LEs{
 			{"Type", "file"},
@@ -469,7 +471,7 @@ func (ctx *Ctx) TxFile(
 		return err
 	}
 
-	br := bufio.NewReader(reader)
+	br := bufio.NewReaderSize(reader, MTHBlockSize)
 	var sizeFull int64
 	var chunkNum int
 	checksums := [][MTHSize]byte{}