deepen the shared memory metadata buffers to 64k each

avsm · Mar 31, 2012 · 932b14c · 932b14c
1 parent 51c2426
commit 932b14c
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/lib/shm_pipe.ml b/lib/shm_pipe.ml
@@ -36,8 +36,8 @@ let dprintf fmt =
 (* Given a handle, retrieve a pair of input/output streams *)
 let make_flow handle =
   (* Buffered metadata channels *)
-  let ic = Lwt_io.(of_fd ~mode:input handle.fd) in
-  let oc = Lwt_io.(of_fd ~mode:output handle.fd) in
+  let ic = Lwt_io.(of_fd ~buffer_size:65535 ~mode:input handle.fd) in
+  let oc = Lwt_io.(of_fd ~buffer_size:65535 ~mode:output handle.fd) in
   (* Listeners waiting for new incoming extents *)
   let rx_waiters = Lwt_sequence.create () in
   (* Listeners waiting for free space on the transmit queue *)