8000 Add nodeup commands to rabbit_fifo_prop · rabbitmq/rabbitmq-server@affdbf9 · GitHub
[go: up one dir, main page]

Skip to content

Commit affdbf9

Browse files
committed
Add nodeup commands to rabbit_fifo_prop
So that nodeups also can stand a chance to be tested
1 parent f358b89 commit affdbf9

File tree

1 file changed

+15
-7
lines changed

1 file changed

+15
-7
lines changed

test/rabbit_fifo_prop_SUITE.erl

Lines changed: 15 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -328,8 +328,12 @@ snapshots_prop(Conf, Commands) ->
328328
end.
329329

330330
log_gen(Size) ->
331-
?LET(EPids, vector(2, pid_gen()),
332-
?LET(CPids, vector(2, pid_gen()),
331+
Nodes = [node(),
332+
fakenode@fake,
333+
fakenode@fake2
334+
],
335+
?LET(EPids, vector(2, pid_gen(Nodes)),
336+
?LET(CPids, vector(2, pid_gen(Nodes)),
333337
resize(Size,
334338
list(
335339
frequency(
@@ -342,18 +346,20 @@ log_gen(Size) ->
342346
{2, checkout_gen(oneof(CPids))},
343347
{1, checkout_cancel_gen(oneof(CPids))},
344348
{1, down_gen(oneof(EPids ++ CPids))},
349+
{1, nodeup_gen(Nodes)},
345350
{1, purge}
346351
]))))).
347352

348-
pid_gen() ->
349-
?LET(Node, oneof([atom_to_binary(node(), utf8),
350-
<<"fakenode@fake">>,
351-
<<"fakenode@fake2">>
352-
]), fake_external_pid(Node)).
353+
pid_gen(Nodes) ->
354+
?LET(Node, oneof(Nodes),
355+
fake_external_pid(atom_to_binary(Node, utf8))).
353356

354357
down_gen(Pid) ->
355358
?LET(E, {down, Pid, oneof([noconnection, noproc])}, E).
356359

360+
nodeup_gen(Nodes) ->
361+
{nodeup, oneof(Nodes)}.
362+
357363
enqueue_gen(Pid) ->
358364
?LET(E, {enqueue, Pid,
359365
frequency([{10, enqueue},
@@ -451,6 +457,8 @@ handle_op({down, Pid, Reason} = Cmd, #t{down = Down} = T) ->
451457
%% it is either not down or down with noconnection
452458
do_apply(Cmd, T#t{down = maps:put(Pid, Reason, Down)})
453459
end;
460+
handle_op({nodeup, _} = Cmd, T) ->
461+
do_apply(Cmd, T);
454462
handle_op({input_event, requeue}, #t{effects = Effs} = T) ->
455463
%% this simulates certain settlements arriving out of order
456464
case queue:out(Effs) of

0 commit comments

Comments
 (0)
0