@@ -1233,16 +1233,14 @@ impl<Descriptor: SocketDescriptor, CM: Deref, RM: Deref, OM: Deref, L: Deref, CM
12331233 let mut has_enqueued_announcement = false ;
12341234
12351235 if let Some ( update_a) = update_a_option {
1236- if update_a. contents . timestamp >= min && update_a. contents . timestamp <= max {
1237- if !has_enqueued_announcement {
1238- self . enqueue_message ( peer, & announce) ;
1239- has_enqueued_announcement = true ;
1240- }
1236+ if update_a. contents . timestamp >= min && update_a. contents . timestamp < max {
1237+ self . enqueue_message ( peer, & announce) ;
12411238 self . enqueue_message ( peer, & update_a) ;
1239+ has_enqueued_announcement = true ;
12421240 }
12431241 }
12441242 if let Some ( update_b) = update_b_option {
1245- if update_b. contents . timestamp >= min && update_b. contents . timestamp <= max {
1243+ if update_b. contents . timestamp >= min && update_b. contents . timestamp < max {
12461244 if !has_enqueued_announcement {
12471245 self . enqueue_message ( peer, & announce) ;
12481246 }
@@ -1260,7 +1258,7 @@ impl<Descriptor: SocketDescriptor, CM: Deref, RM: Deref, OM: Deref, L: Deref, CM
12601258 ( f. first_timestamp , f. first_timestamp . saturating_add ( f. timestamp_range ) )
12611259 } ) ;
12621260
1263- if msg. contents . timestamp >= min && msg. contents . timestamp <= max {
1261+ if msg. contents . timestamp >= min && msg. contents . timestamp < max {
12641262 self . enqueue_message ( peer, & msg) ;
12651263 }
12661264
0 commit comments