From a4afbc4c507419c5fd50c9403bc0bf6a53c92632 Mon Sep 17 00:00:00 2001 From: Matias Goldfeld <2000matu@gmail.com> Date: Tue, 26 Jan 2021 03:33:48 -0500 Subject: Stated incompatability with new versions of decompress in disml.opam and made some small fixes to add compatability with new OCaml versions --- lib/gateway/sharder.ml | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) (limited to 'lib/gateway/sharder.ml') diff --git a/lib/gateway/sharder.ml b/lib/gateway/sharder.ml index ba865a9..14763ca 100644 --- a/lib/gateway/sharder.ml +++ b/lib/gateway/sharder.ml @@ -23,7 +23,7 @@ let decompress src = pos := !pos + len; len) (fun obuf len -> - Buffer.add_subbytes res obuf 0 len; 0xFFFF) + Buffer.add_subbytes res obuf ~pos:0 ~len:len; 0xFFFF) (Zlib_inflate.default ~witness:B.bytes window) |> function | Ok _ -> Buffer.contents res @@ -95,7 +95,7 @@ module Shard = struct let seq = J.(member "s" payload |> to_int) in let t = J.(member "t" payload |> to_string) in let data = J.member "d" payload in - let session = if t = "READY" then begin + let session = if String.equal t "READY" then begin Ivar.fill_if_empty shard.ready (); Clock.after (Core.Time.Span.create ~sec:5 ()) >>> (fun _ -> Mvar.put identify_lock () >>> ignore); -- cgit v1.2.3