robur/mirage-monitoring
4
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

record memory metrics as well

Browse source
This commit is contained in:
Hannes Mehnert 2020-12-21 15:36:25 +01:00
parent dd64fdbbb3
commit e9b965a2d2
2 changed files with 16 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
monitoring-experiments.opam
View file

@ -17,9 +17,9 @@ depends: [
"mirage-clock" {>= "3.0.0"} "mirage-clock" {>= "3.0.0"}
"mirage-time" {>= "2.0.0"} "mirage-time" {>= "2.0.0"}
"mirage-stack" {>= "2.2.0"} "mirage-stack" {>= "2.2.0"}
"tcpip" {>= "5.0.99"} "tcpip" {>= "6.0.99"}
"mirage-net-solo5" {>= "0.6.2"} "mirage-net-solo5" {>= "0.6.2"}
"mirage-solo5" {>= "0.6.3"} "mirage-solo5" {>= "0.6.4"}
"ocaml-freestanding" {>= "0.4.5"} "ocaml-freestanding" {>= "0.4.5"}
"bheap" "bheap"
] ]

14
src/monitoring_experiments.ml
View file

@ -29,6 +29,19 @@ let counter_metrics ~f name =
let vmname = Metrics.field ~doc:"name of the virtual machine" "vm" Metrics.String let vmname = Metrics.field ~doc:"name of the virtual machine" "vm" Metrics.String
let memory_metrics ~tags =
let open Metrics in
let doc = "Memory counters" in
let data () =
let stat = OS.Memory.quick_stat () in
Data.v
[ uint "memory heap words" stat.heap_words
; uint "memory live words" stat.live_words
; uint "memory stack words" stat.stack_words
; uint "memory free words" stat.free_words ]
in
Src.v ~doc ~tags ~data "memory"
module Make (T : Mirage_time.S) (S : Mirage_stack.V4V6) = struct module Make (T : Mirage_time.S) (S : Mirage_stack.V4V6) = struct
let timer conn get host stack dst = let timer conn get host stack dst =
@ -79,6 +92,7 @@ module Make (T : Mirage_time.S) (S : Mirage_stack.V4V6) = struct
Metrics.enable_all (); Metrics.enable_all ();
Metrics_lwt.init_periodic (fun () -> T.sleep_ns (Duration.of_sec interval)); Metrics_lwt.init_periodic (fun () -> T.sleep_ns (Duration.of_sec interval));
Metrics_lwt.periodically (OS.MM.malloc_metrics ~tags:Metrics.Tags.[]); Metrics_lwt.periodically (OS.MM.malloc_metrics ~tags:Metrics.Tags.[]);
Metrics_lwt.periodically (memory_metrics ~tags:Metrics.Tags.[]);
let host = match hostname with None -> [] | Some host -> [vmname host] in let host = match hostname with None -> [] | Some host -> [vmname host] in
Lwt.async (timer_loop get_cache host interval stack (dst, port)) Lwt.async (timer_loop get_cache host interval stack (dst, port))
end end