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
|
%%
%% %CopyrightBegin%
%%
%% Copyright Ericsson AB 2018. 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%
%%
-module(erts_dirty_process_signal_handler).
-export([start/0]).
%%
%% The erts_dirty_process_signal_handler is started at
%% VM boot by the VM. It is a spawned as a system
%% process, i.e, the whole VM will terminate if
%% this process terminates.
%%
start() ->
process_flag(trap_exit, true),
msg_loop().
msg_loop() ->
_ = receive
Request ->
try
handle_request(Request)
catch
_ : _ ->
%% Ignore all failures;
%% someone passed us garbage...
ok
end
end,
msg_loop().
handle_request(Pid) when is_pid(Pid) ->
handle_incoming_signals(Pid, 0);
handle_request({Requester, Target, Prio,
{SysTaskOp, ReqId, Arg} = Op} = Request) ->
case handle_sys_task(Requester, Target, SysTaskOp, ReqId, Arg, 0) of
done ->
ok;
busy ->
self() ! Request;
normal ->
%% Target has stopped executing dirty since the
%% initial request was made. Dispatch the
%% request to target and let it handle it itself...
case erts_internal:request_system_task(Requester,
Target,
Prio,
Op) of
ok ->
ok;
dirty_execution ->
%% Ahh... It began executing dirty again...
handle_request(Request)
end
end;
handle_request(_Garbage) ->
ignore.
%%
%% ----------------------------------------------------------------------------
%%
handle_incoming_signals(Pid, 5) ->
self() ! Pid; %% Work with other requests for a while...
handle_incoming_signals(Pid, N) ->
case erts_internal:dirty_process_handle_signals(Pid) of
more -> handle_incoming_signals(Pid, N+1);
_Res -> ok
end.
handle_sys_task(Requester, Target, check_process_code, ReqId, Module, N) ->
case erts_internal:check_dirty_process_code(Target, Module) of
Bool when Bool == true; Bool == false ->
Requester ! {check_process_code, ReqId, Bool},
done;
busy ->
case N > 5 of
true ->
busy;
false ->
handle_sys_task(Requester, Target, check_process_code,
ReqId, Module, N+1)
end;
Res ->
Res
end.
|
