wehub/janestreet--magic-trace
1
0
Fork 0
Code Issues Pull Requests Actions Deployments Models Agent Notes Packages Projects Releases Wiki Activity

chore: import upstream snapshot with attribution
build-deb / build (push) Has been cancelled
Details
build / build (5.2.0+ox, ubuntu_x64_8_cores, 231c88c2e564fdca40e15e750aacad5fb0887435) (push) Has been cancelled
Details

Browse Source
This commit is contained in:
wehub-resource-sync
2026-07-13 12:29:01 +08:00
commit f30f816e96
271 changed files with 286108 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
test/callstack_compression_test.ml
+81
View File
@@ -0,0 +1,81 @@
open Core
open Magic_trace_lib
let compressed_test_string =
{|(
((new_symbols())(callstack()))
((new_symbols())(callstack()))
((new_symbols())(callstack()))
((new_symbols(((From_perf _start)0)))(callstack((0 0))))
((new_symbols((Untraced 1)))(callstack((1 0)(0 0))))
((new_symbols())(callstack((0 0))))
((new_symbols(((From_perf _dl_start)2)))(callstack((2 0)(0 0))))
((new_symbols())(callstack((1 1)(0 0))))
((new_symbols())(callstack((2 1))))
((new_symbols())(callstack((1 2))))
((new_symbols())(callstack((2 1))))
)|}
;;
let decompressed_test_string =
{|(
()
()
()
((From_perf _start))
(Untraced (From_perf _start))
((From_perf _start))
((From_perf _dl_start) (From_perf _start))
(Untraced (From_perf _start) (From_perf _start))
((From_perf _dl_start) (From_perf _start))
(Untraced (From_perf _start) (From_perf _start))
((From_perf _dl_start) (From_perf _start))
)|}
;;
let%expect_test "decompress" =
let compression_events =
[%of_sexp: Callstack_compression.compression_event list]
(Sexp.of_string compressed_test_string)
in
let state = Callstack_compression.init () in
List.iter compression_events ~f:(fun comp_event ->
let callstack = Callstack_compression.decompress_callstack state comp_event in
print_s [%sexp (callstack : Symbol.t list)]);
[%expect
{|
()
()
()
((From_perf _start))
(Untraced (From_perf _start))
((From_perf _start))
((From_perf _dl_start) (From_perf _start))
(Untraced (From_perf _start) (From_perf _start))
((From_perf _dl_start) (From_perf _start))
(Untraced (From_perf _start) (From_perf _start))
((From_perf _dl_start) (From_perf _start))|}]
;;
let%expect_test "compress" =
let compression_events =
[%of_sexp: Symbol.t list list] (Sexp.of_string decompressed_test_string)
in
let state = Callstack_compression.init () in
List.iter compression_events ~f:(fun callstack ->
let comp_event = Callstack_compression.compress_callstack state callstack in
print_s [%sexp (comp_event : Callstack_compression.compression_event)]);
[%expect
{|
((new_symbols ()) (callstack ()))
((new_symbols ()) (callstack ()))
((new_symbols ()) (callstack ()))
((new_symbols (((From_perf _start) 0))) (callstack ((0 0))))
((new_symbols ((Untraced 1))) (callstack ((1 0) (0 0))))
((new_symbols ()) (callstack ((0 0))))
((new_symbols (((From_perf _dl_start) 2))) (callstack ((2 0) (0 0))))
((new_symbols ()) (callstack ((1 1) (0 0))))
((new_symbols ()) (callstack ((2 1))))
((new_symbols ()) (callstack ((1 2))))
((new_symbols ()) (callstack ((2 1))))|}]
;;