@@ -655,11 +655,10 @@ state_enter_file_handle_leader_reservation_test(_) ->
655
655
656
656
Resource = {resource , <<" /" >>, queue , <<" test" >>},
657
657
Effects = rabbit_fifo :state_enter (leader , S0 ),
658
- ? assertMatch ([
659
- {mod_call , m , f , [a , the_name ]},
660
- _Timer ,
661
- {mod_call , rabbit_quorum_queue , file_handle_leader_reservation , [Resource ]}
662
- ], Effects ),
658
+ ? assertMatch ([{mod_call , m , f , [a , the_name ]},
659
+ _Timer ,
660
+ {mod_call , rabbit_quorum_queue , file_handle_leader_reservation , [Resource ]}
661
+ | _ ], Effects ),
663
662
ok .
664
663
665
664
state_enter_file_handle_other_reservation_test (_ ) ->
@@ -1161,20 +1160,22 @@ single_active_consumer_state_enter_leader_include_waiting_consumers_test(C) ->
1161
1160
Meta = meta (C , 1 ),
1162
1161
% adding some consumers
1163
1162
AddConsumer = fun ({CTag , ChannelId }, State ) ->
1164
- {NewState , _ , _ } = apply (
1165
- Meta ,
1166
- make_checkout ({CTag , ChannelId },
1167
- {once , 1 , simple_prefetch }, #{}),
1168
- State ),
1169
- NewState
1163
+ {NewState , _ , _ } = apply (
1164
+ Meta ,
1165
+ make_checkout ({CTag , ChannelId },
1166
+ {once , 1 , simple_prefetch }, #{}),
1167
+ State ),
1168
+ NewState
1170
1169
end ,
1171
- State1 = lists :foldl (AddConsumer , State0 ,
1172
- [{<<" ctag1" >>, Pid1 }, {<<" ctag2" >>, Pid2 }, {<<" ctag3" >>, Pid2 }, {<<" ctag4" >>, Pid3 }]),
1170
+ State1 = lists :foldl (AddConsumer , State0 , [{<<" ctag1" >>, Pid1 },
1171
+ {<<" ctag2" >>, Pid2 },
1172
+ {<<" ctag3" >>, Pid2 },
1173
+ {<<" ctag4" >>, Pid3 }]),
1173
1174
1174
1175
Effects = rabbit_fifo :state_enter (leader , State1 ),
1175
1176
% % 2 effects for each consumer process (channel process), 1 effect for the node,
1176
1177
% % 1 effect for file handle reservation
1177
- ? assertEqual (2 * 3 + 1 + 1 + 1 , length (Effects )).
1178
+ ? assertEqual (2 * 3 + 1 + 1 + 1 + 1 , length (Effects )).
1178
1179
1179
1180
single_active_consumer_state_enter_eol_include_waiting_consumers_test (C ) ->
1180
1181
Resource = rabbit_misc :r (" /" , queue , atom_to_binary (? FUNCTION_NAME , utf8 )),
0 commit comments