@@ -723,12 +723,20 @@ handle_ra_event(_QName, _From,
723723 {rejected , {not_leader , _UndefinedMaybe , _Seq }}, State0 ) ->
724724 % TODO: how should these be handled? re-sent on timer or try random
725725 {ok , State0 , []};
726- handle_ra_event (QName , _ , timeout , # state {cfg = # cfg {servers = Servers }} = State0 ) ->
726+ handle_ra_event (QName , _ , timeout , # state {cfg = # cfg {servers = Servers },
727+ leader = OldLeader ,
728+ pending = Pending } = State0 ) ->
727729 case find_leader (Servers ) of
728730 undefined ->
731+ ? LOG_DEBUG (" ~ts : ~s Pending applied Timeout, no leader found, num pend ~b " ,
732+ [rabbit_misc :rs (QName ), ? MODULE , maps :size (Pending )]),
729733 % % still no leader, set the timer again
730734 {ok , set_timer (QName , State0 ), []};
731735 Leader ->
736+ ? LOG_DEBUG (" ~ts : ~s Pending applied Timeout ~w to ~w , "
737+ " resending ~b pending commands" ,
738+ [rabbit_misc :rs (QName ), ? MODULE , OldLeader ,
739+ Leader , maps :size (Pending )]),
732740 State = resend_all_pending (State0 # state {leader = Leader }),
733741 {ok , State , []}
734742 end ;
0 commit comments