summaryrefslogtreecommitdiff
path: root/src/message.ml
diff options
context:
space:
mode:
Diffstat (limited to 'src/message.ml')
-rw-r--r--src/message.ml4
1 files changed, 0 insertions, 4 deletions
diff --git a/src/message.ml b/src/message.ml
index d4cc374..5b508eb 100644
--- a/src/message.ml
+++ b/src/message.ml
@@ -13,18 +13,14 @@ 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 (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 (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