Skip to content

Commit

Permalink
[server] display name and timestamp in json string
Browse files Browse the repository at this point in the history
  • Loading branch information
gautierhattenberger committed Nov 2, 2021
1 parent 2afb6b9 commit 1ee926a
Showing 1 changed file with 12 additions and 5 deletions.
17 changes: 12 additions & 5 deletions sw/ground_segment/tmtc/server.ml
Expand Up @@ -141,15 +141,15 @@ let logger = fun () ->
close_out f;
open_out (logs_path // data_name)

let time_of_timestamp = function
| Some x -> x
| None -> U.gettimeofday() -. start_time

let log = fun ?timestamp logging ac_name msg_name values ->
match logging with
Some log ->
let s = string_of_values values in
let t =
match timestamp with
Some x -> x
| None -> U.gettimeofday () -. start_time in
let t = time_of_timestamp timestamp in
fprintf log "%.3f %s %s %s\n" t ac_name msg_name s; flush log
| None -> ()

Expand All @@ -168,7 +168,14 @@ let ac_msg = fun messages_xml logging ac_name ac ->
let msg = Tele_Pprz.message_of_id msg_id in
log ?timestamp logging ac_name msg.PprzLink.name values;
if not !udp_json_stream_disable then begin
let json_msg = sprintf "{ \"%s\": %s }" ac_name (Tele_Pprz.json_of_message msg values) in
let json_name =
try
let a = Hashtbl.find aircrafts ac_name in
sprintf "%s (%s)" a.name ac_name
with _ -> ac_name
in
let t = time_of_timestamp timestamp in
let json_msg = sprintf "{ \"%s\": %s, \"timestamp\": %f }" json_name (Tele_Pprz.json_of_message msg values) t in
let len = String.length json_msg in
let n = Unix.sendto udp_fd (Bytes.of_string json_msg) 0 len [] udp_sockaddr in
assert(n = len)
Expand Down

0 comments on commit 1ee926a

Please sign in to comment.