diff --git a/src/rpc/client.rs b/src/rpc/client.rs index d035fce51..95813df9f 100644 --- a/src/rpc/client.rs +++ b/src/rpc/client.rs @@ -199,8 +199,8 @@ impl RpcClient { let read_timeout = Duration::from_secs(30); loop { - // Nasty size - let mut buf = vec![0; 2048 * 10]; + // FIXME: Nasty size. 8M + let mut buf = vec![0; 1024 * 8192]; select! { data = data_recv.recv().fuse() => { diff --git a/src/rpc/server.rs b/src/rpc/server.rs index ed8b61752..24c699661 100644 --- a/src/rpc/server.rs +++ b/src/rpc/server.rs @@ -48,8 +48,8 @@ async fn accept( rh: Arc, ) -> Result<()> { loop { - // Nasty size - let mut buf = vec![0; 8192 * 10]; + // FIXME: Nasty size. 8M + let mut buf = vec![0; 1024 * 8192]; let n = match stream.read(&mut buf).await { Ok(n) if n == 0 => {