1 -module(beam_stats_consumer_statsd_SUITE).
3 -include_lib("beam_stats/include/beam_stats.hrl").
4 -include_lib("beam_stats/include/beam_stats_ets_table.hrl").
16 -define(GROUP, beam_stats_consumer_statsd).
18 %% ============================================================================
19 %% Common Test callbacks
20 %% ============================================================================
30 [{?GROUP, Properties, Tests}].
32 %% =============================================================================
34 %% =============================================================================
51 % TODO: Indent #beam_stats as #beam_stats_ets_table
52 BEAMStats = #beam_stats
53 { timestamp = {1, 2, 3}
54 , node_id = 'node_foo@host_bar'
55 , memory = [{mem_type_foo, 1}, {mem_type_bar, 2}, {mem_type_baz, 3}]
58 , context_switches = 5
61 , ets = [ETSTableStatsFoo, ETSTableStatsBar]
64 {ok, ServerSocket} = gen_udp:open(ServerPort, [binary, {active, false}]),
65 BEAMStatsQ = queue:in(BEAMStats, queue:new()),
66 Options = [{dst_port, ServerPort}],
67 {_, State1} = beam_stats_consumer_statsd:init(Options),
68 State2 = beam_stats_consumer_statsd:consume(BEAMStatsQ, State1),
69 {} = beam_stats_consumer_statsd:terminate(State2),
70 ResultOfReceive1 = gen_udp:recv(ServerSocket, 0),
71 {ok, {_, _, PacketReceived1}} = ResultOfReceive1,
72 ResultOfReceive2 = gen_udp:recv(ServerSocket, 0),
73 {ok, {_, _, PacketReceived2}} = ResultOfReceive2,
74 ok = gen_udp:close(ServerSocket),
75 ct:log("PacketReceived1: ~n~s~n", [PacketReceived1]),
76 ct:log("PacketReceived2: ~n~s~n", [PacketReceived2]),
77 PacketsCombined = <<PacketReceived1/binary, PacketReceived2/binary>>,
78 ct:log("PacketsCombined: ~n~s~n", [PacketsCombined]),
80 [ <<"beam_stats.node_foo_host_bar.io.bytes_in:3|g">>
81 , <<"beam_stats.node_foo_host_bar.io.bytes_out:7|g">>
82 , <<"beam_stats.node_foo_host_bar.context_switches:5|g">>
83 , <<"beam_stats.node_foo_host_bar.reductions:9|g">>
84 , <<"beam_stats.node_foo_host_bar.run_queue:17|g">>
85 , <<"beam_stats.node_foo_host_bar.memory.mem_type_foo:1|g">>
86 , <<"beam_stats.node_foo_host_bar.memory.mem_type_bar:2|g">>
87 , <<"beam_stats.node_foo_host_bar.memory.mem_type_baz:3|g">>
88 , <<"beam_stats.node_foo_host_bar.ets_table.size.foo.foo:5|g">>
89 , <<"beam_stats.node_foo_host_bar.ets_table.memory.foo.foo:25|g">>
90 , <<"beam_stats.node_foo_host_bar.ets_table.size.bar.37:8|g">>
91 , <<"beam_stats.node_foo_host_bar.ets_table.memory.bar.37:38|g">>
93 MsgsReceived = binary:split(PacketsCombined, <<"\n">>, [global, trim]),
94 RemoveExpectedFromReceived =
95 fun (Expected, Received) ->
97 "Looking for expected msg ~p in remaining received ~p~n",
100 true = lists:member(Expected, Received),
101 Received -- [Expected]
103 [] = lists:foldl(RemoveExpectedFromReceived, MsgsReceived, MsgsExpected).