From bcd49ccfcfc4c031723f97fba16c471966087f5f Mon Sep 17 00:00:00 2001
From: Hannes Mehnert <hannes@mehnert.org>
Date: Wed, 20 Nov 2024 10:32:27 +0100
Subject: [PATCH] of_octets: create ring buffer earlier to avoid missing data

---
 src/git_kv.ml | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/src/git_kv.ml b/src/git_kv.ml
index ef8d57c..ab99b52 100644
--- a/src/git_kv.ml
+++ b/src/git_kv.ml
@@ -278,8 +278,7 @@ let map buf ~pos len =
 let blit_from_string src src_off dst dst_off len =
   Bigstringaf.blit_from_string src ~src_off dst ~dst_off ~len
 
-let read stream =
-  let ke = Ke.Rke.create ~capacity:0x1000 Bigarray.char in
+let read ke stream =
   let rec go filled input =
     match Ke.Rke.N.peek ke with
     | [] -> begin
@@ -302,9 +301,10 @@ let read stream =
 let analyze store stream =
   let tmp = Cstruct.create 0x1000 in
   let buf = Buffer.create 0x1000 in
+  let ke = Ke.Rke.create ~capacity:0x1000 Bigarray.char in
   let read_cstruct tmp =
     let open Lwt.Infix in
-    read stream tmp >>= fun len ->
+    read ke stream tmp >>= fun len ->
     Buffer.add_string buf (Cstruct.to_string ~off:0 ~len tmp);
     Lwt.return len in
   let allocate bits = De.make_window ~bits in