From cacc8ee6f2ccb43faa971a75d2c4585c8e1a27fc Mon Sep 17 00:00:00 2001 From: Daniil Baturin Date: Wed, 13 Dec 2017 15:28:52 +0100 Subject: Add debug logging of protobuf messages. --- src/message.ml | 4 ++++ 1 file changed, 4 insertions(+) (limited to 'src/message.ml') diff --git a/src/message.ml b/src/message.ml index 24803fe..3629f0d 100644 --- a/src/message.ml +++ b/src/message.ml @@ -8,14 +8,18 @@ let read ic = let header = Bytes.create 4 in let%lwt () = Lwt_io.read_into_exactly ic header 0 4 in let length = EndianBytes.BigEndian.get_int32 header 0 |> Int32.to_int in + Lwt_log.debug (Printf.sprintf "Read length: %d\n" length) |> Lwt.ignore_result; if length < 0 then failwith (Printf.sprintf "Bad message length: %d" length) else let buffer = Bytes.create length in let%lwt () = Lwt_io.read_into_exactly ic buffer 0 length in + Lwt_log.debug (Util.hexdump buffer |> Printf.sprintf "Read mesage: %s") |> Lwt.ignore_result; Lwt.return buffer let write oc msg = let length = Bytes.length msg in let length' = Int32.of_int length in + Lwt_log.debug (Printf.sprintf "Write length: %d\n" length) |> Lwt.ignore_result; + Lwt_log.debug (Util.hexdump msg |> Printf.sprintf "Write message: %s") |> Lwt.ignore_result; if length' < 0l then failwith (Printf.sprintf "Bad message length: %d" length) else let header = Bytes.create 4 in let () = EndianBytes.BigEndian.set_int32 header 0 length' in -- cgit v1.2.3