X-Git-Url: http://www.git.cypherpunks.ru/?p=nncp.git;a=blobdiff_plain;f=src%2Fcmd%2Fnncp-xfer%2Fmain.go;h=dc522a85dbfc0818e07b79d405a3898d34646c11;hp=9c29b0284b1975b4da44fcd927a3cb5841901a32;hb=c2b17fd0fc439e420710f53602604e8823c2fb1d;hpb=ffe4b2fbf50c031e9c002f2395957859cb4787cc

diff --git a/src/cmd/nncp-xfer/main.go b/src/cmd/nncp-xfer/main.go
index 9c29b02..dc522a8 100644
--- a/src/cmd/nncp-xfer/main.go
+++ b/src/cmd/nncp-xfer/main.go
@@ -293,7 +293,9 @@ func main() {
 			}
 			r, w := io.Pipe()
 			go func() {
-				_, err := io.CopyN(w, bufio.NewReader(fd), fiInt.Size())
+				_, err := io.CopyN(
+					w, bufio.NewReaderSize(fd, nncp.MTHBlockSize), fiInt.Size(),
+				)
 				if err == nil {
 					err = w.Close()
 				}
@@ -477,7 +479,7 @@ Tx:
 			}
 			bufW := bufio.NewWriter(tmp)
 			copied, err := nncp.CopyProgressed(
-				bufW, bufio.NewReader(fd), "Tx",
+				bufW, bufio.NewReaderSize(fd, nncp.MTHBlockSize), "Tx",
 				append(les, nncp.LE{K: "FullSize", V: job.Size}),
 				ctx.ShowPrgrs,
 			)