X-Git-Url: http://www.git.cypherpunks.ru/?p=nncp.git;a=blobdiff_plain;f=src%2Fcmd%2Fnncp-ack%2Fmain.go;h=098218aa356c45583167a5f032305d28e53bcd89;hp=d7e8f0185697ba364298f1d5aba10535c46ac6cc;hb=c2b17fd0fc439e420710f53602604e8823c2fb1d;hpb=ffe4b2fbf50c031e9c002f2395957859cb4787cc diff --git a/src/cmd/nncp-ack/main.go b/src/cmd/nncp-ack/main.go index d7e8f01..098218a 100644 --- a/src/cmd/nncp-ack/main.go +++ b/src/cmd/nncp-ack/main.go @@ -206,7 +206,12 @@ func main() { continue } pipeR, pipeW := io.Pipe() - go nncp.PktEncRead(ctx.Self, ctx.Neigh, bufio.NewReader(fd), pipeW, true, nil) + go nncp.PktEncRead( + ctx.Self, + ctx.Neigh, + bufio.NewReaderSize(fd, nncp.MTHBlockSize), + pipeW, true, nil, + ) var pkt nncp.Pkt _, err = xdr.Unmarshal(pipeR, &pkt) fd.Close()