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

Merge pull request 'of_octets: create ring buffer earlier to avoid missing data' (!5) from fix-of-octets into main

Browse source 
Reviewed-on: #5
Reviewed-by: Reynir Björnsson <reynir@reynir.dk>
Reviewed-by: dinosaure <romain.calascibetta@gmail.com>
This commit is contained in:
Reynir Björnsson 2024-11-28 10:16:33 +00:00
commit 992127f2bd
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 =
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