@@ -981,7 +981,8 @@ def __is_next_pre_prepare(self, view_no: int, pp_seq_no: int):
981
981
if pp_seq_no - last_pp_seq_no > 1 :
982
982
logger .warning ('{} missing PRE-PREPAREs between {} and {}' .
983
983
format (self , pp_seq_no , last_pp_seq_no ))
984
- self ._request_missing_three_phase_messages (last_pp_seq_no , pp_seq_no , last_pp_view_no )
984
+ self ._request_missing_three_phase_messages (last_pp_seq_no , pp_seq_no ,
985
+ last_pp_view_no , view_no )
985
986
self ._setup_for_non_master ()
986
987
return False
987
988
@@ -1967,9 +1968,10 @@ def can_pp_seq_no_be_in_view(self, view_no, pp_seq_no):
1967
1968
view_no < self .viewNo and self .last_prepared_before_view_change and compare_3PC_keys (
1968
1969
(view_no , pp_seq_no ), self .last_prepared_before_view_change ) >= 0 )
1969
1970
1970
- def _request_missing_three_phase_messages (self , frm : int , to : int , view_no : int ) -> None :
1971
- for i in range (1 , to - frm ):
1972
- request_data = (view_no , frm + i )
1971
+ def _request_missing_three_phase_messages (self , seq_frm : int , seq_to : int , view_frm : int , view_to : int ) -> None :
1972
+ for pp_seq_no in range (seq_frm + 1 , seq_to + 1 ):
1973
+ for view_no in range (view_frm , view_to + 1 ):
1974
+ request_data = (view_no , pp_seq_no )
1973
1975
self ._request_pre_prepare (request_data )
1974
1976
self ._request_prepare (request_data )
1975
1977
0 commit comments