1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
|
%% -*- erlang -*-
%%
%% %CopyrightBegin%
%%
%% Copyright Ericsson AB 1998-2016. All Rights Reserved.
%%
%% Licensed under the Apache License, Version 2.0 (the "License");
%% you may not use this file except in compliance with the License.
%% You may obtain a copy of the License at
%%
%% http://www.apache.org/licenses/LICENSE-2.0
%%
%% Unless required by applicable law or agreed to in writing, software
%% distributed under the License is distributed on an "AS IS" BASIS,
%% WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
%% See the License for the specific language governing permissions and
%% limitations under the License.
%%
%% %CopyrightEnd%
%%
-mode(compile).
main(_) ->
DisDir = "./dis",
ok = filelib:ensure_dir(filename:join(DisDir, "dummy")),
io:format("Dissambling to ~s\n", [DisDir]),
ok = file:set_cwd(DisDir),
Path = code:get_path() -- ["."],
Beams0 = [filelib:wildcard(filename:join(Dir, "*.beam")) ||
Dir <- Path],
Beams = lists:append(Beams0),
Mods0 = [list_to_atom(filename:rootname(filename:basename(F))) ||
F <- Beams],
Mods = lists:usort(Mods0),
start_sem(),
Ps = [begin
{_,Ref} = spawn_monitor(fun() -> count(M) end),
Ref
end || M <- Mods],
[put(list_to_atom(I), 0) || I <- erts_debug:instructions()],
Res = wait_for_all(Ps, 1),
OutFile = "count",
{ok,Out} = file:open(OutFile, [write]),
[io:format(Out, "~s ~p\n", [I,C]) || {I,C} <- Res],
ok = file:close(Out),
io:format("\nResult written to ~s\n",
[filename:join(DisDir, OutFile)]),
ok.
wait_for_all([], _) ->
lists:reverse(lists:keysort(2, get()));
wait_for_all([_|_]=Ps, I) ->
receive
{'DOWN',Ref,process,_,Result} ->
io:format("\r~p", [I]),
[increment(Key, Count) || {Key,Count} <- Result],
wait_for_all(Ps -- [Ref], I+1)
end.
count(M) ->
down(),
erts_debug:df(M),
{ok,Fd} = file:open(atom_to_list(M) ++ ".dis", [read,raw]),
count_is(Fd),
ok = file:close(Fd),
exit(get()).
count_is(Fd) ->
case file:read_line(Fd) of
{ok,Line} ->
count_instr(Line),
count_is(Fd);
eof ->
ok
end.
count_instr([$\s|T]) ->
count_instr_1(T, []);
count_instr([_|T]) ->
count_instr(T);
count_instr([]) ->
%% Empty line.
ok.
count_instr_1([$\s|_], Acc) ->
Instr = list_to_atom(lists:reverse(Acc)),
increment(Instr, 1);
count_instr_1([H|T], Acc) ->
count_instr_1(T, [H|Acc]).
increment(Key, Inc) ->
case get(Key) of
undefined ->
put(Key, Inc);
Count ->
put(Key, Count+Inc)
end.
%%%
%%% Counting sempahore to limit the number of processes that
%%% can run concurrently.
%%%
down() ->
sem ! {down,self()},
receive
sem_taken -> ok
end.
start_sem() ->
spawn(fun() ->
register(sem, self()),
process_flag(trap_exit, true),
do_sem(erlang:system_info(schedulers)+1) end).
do_sem(0) ->
receive
{'EXIT',_,_} ->
do_sem(1)
end;
do_sem(C) ->
receive
{down,Pid} ->
link(Pid),
Pid ! sem_taken,
do_sem(C-1)
end.
|
