robur/git-kv
4
0
Fork 0
Code Issues Pull requests 1 Projects Releases Packages Wiki Activity Actions

of_octets: create ring buffer earlier to avoid missing data

Browse source
This commit is contained in:
Hannes Mehnert 2024-11-20 10:32:27 +01:00
parent bc190bd054
commit bcd49ccfcf
1 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
src/git_kv.ml
View file

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