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
|
%%
%% %CopyrightBegin%
%%
%% Copyright Ericsson AB 2004-2009. All Rights Reserved.
%%
%% The contents of this file are subject to the Erlang Public License,
%% Version 1.1, (the "License"); you may not use this file except in
%% compliance with the License. You should have received a copy of the
%% Erlang Public License along with this software. If not, it can be
%% retrieved online at http://www.erlang.org/.
%%
%% Software distributed under the License is distributed on an "AS IS"
%% basis, WITHOUT WARRANTY OF ANY KIND, either express or implied. See
%% the License for the specific language governing rights and limitations
%% under the License.
%%
%% %CopyrightEnd%
%%
-module(otp_5235).
-export([?MODULE/0]).
-record(commit, {node,
decision, % presume_commit | Decision
ram_copies = [],
disc_copies = [],
disc_only_copies = [],
snmp = [],
schema_ops = [self(),make_ref()]
}).
?MODULE() ->
process_flag(trap_exit, true),
N = 1024,
clone(N),
wait(N).
wait(0) -> ok;
wait(N) ->
receive
{'EXIT',_,normal} ->
wait(N-1);
Other ->
exit(Other)
end.
clone(0) -> ok;
clone(N) ->
spawn_link(fun worker/0),
clone(N-1).
worker() ->
Seq = lists:seq(1, 10),
PidList = [{N,self()} || N <- Seq],
Commit = #commit{ram_copies=PidList,disc_copies=[],
disc_only_copies=[],snmp=[]},
List = lists:duplicate(2, Commit),
verify(run(2, List)).
verify([#commit{node=true,ram_copies=L}|T]) ->
verify_1(L, 1),
verify(T);
verify([]) -> ok.
verify_1([{N,Pid}|T], N) when Pid =:= self() ->
verify_1(T, N+1);
verify_1([], _) -> ok.
run(0, L) -> L;
run(N, L) -> run(N-1, reverse(L)).
reverse([]) -> [];
reverse([H|R]) when record(H, commit) ->
[H#commit{
ram_copies = lists:reverse(H#commit.ram_copies),
disc_copies = lists:reverse(H#commit.disc_copies),
disc_only_copies = lists:reverse(H#commit.disc_only_copies),
snmp = lists:reverse(H#commit.snmp),
node = erlang:yield()
}
| reverse(R)].
|
