146146-define (SNAPSHOT_INTERVAL , 8192 ). % % the ra default is 4096
147147% -define(UNLIMITED_PREFETCH_COUNT, 2000). %% something large for ra
148148-define (MIN_CHECKPOINT_INTERVAL , 8192 ). % % the ra default is 16384
149- -define (QQ_LEADER_HEALTH_CHECK_TIMEOUT , 1_000 ).
150- -define (QQ_GLOBAL_LEADER_HEALTH_CHECK_TIMEOUT , 60_000 ).
149+ -define (LEADER_HEALTH_CHECK_TIMEOUT , 1_000 ).
150+ -define (GLOBAL_LEADER_HEALTH_CHECK_TIMEOUT , 60_000 ).
151151
152152% %----------- QQ policies ---------------------------------------------------
153153
@@ -2188,7 +2188,7 @@ leader_health_check(QueueNameOrRegEx, VHost, ProcessLimitThreshold) ->
21882188
21892189run_leader_health_check (ClusterName , QResource , HealthCheckRef , From ) ->
21902190 Leader = ra_leaderboard :lookup_leader (ClusterName ),
2191- case ra_server_proc :ping (Leader , ? QQ_LEADER_HEALTH_CHECK_TIMEOUT ) of
2191+ case ra_server_proc :ping (Leader , ? LEADER_HEALTH_CHECK_TIMEOUT ) of
21922192 {pong ,leader } ->
21932193 From ! {ok , HealthCheckRef , QResource };
21942194 _ ->
@@ -2208,7 +2208,7 @@ wait_for_leader_health_checks(Ref, N, UnhealthyAcc) ->
22082208 {error , Ref , QResource } ->
22092209 wait_for_leader_health_checks (Ref , N - 1 , [amqqueue :to_printable (QResource , ? MODULE ) | UnhealthyAcc ])
22102210 after
2211- ? QQ_GLOBAL_LEADER_HEALTH_CHECK_TIMEOUT ->
2211+ ? GLOBAL_LEADER_HEALTH_CHECK_TIMEOUT ->
22122212 UnhealthyAcc
22132213 end .
22142214
0 commit comments