diff options
| author | Daniil Baturin <daniil@vyos.io> | 2025-09-18 12:32:18 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2025-09-18 12:32:18 +0100 |
| commit | 304e4d2a172fe1baf2c1df7f61b7a0a8e40f7d5d (patch) | |
| tree | 4a415189068819e7914ae1352a69abe08eb45c60 /src/message.ml | |
| parent | 2da0981501a9bec8b69d29f1e52c10db90571aa4 (diff) | |
| parent | bca62a7bd1da4e78497fdce3882421609ce28c00 (diff) | |
| download | vyconf-304e4d2a172fe1baf2c1df7f61b7a0a8e40f7d5d.tar.gz vyconf-304e4d2a172fe1baf2c1df7f61b7a0a8e40f7d5d.zip | |
Merge pull request #31 from jestabro/interstitial-set
T7737: add analogue of configfs for config tree updates during commit
Diffstat (limited to 'src/message.ml')
| -rw-r--r-- | src/message.ml | 4 |
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 |
