@@ -1233,16 +1233,14 @@ impl<Descriptor: SocketDescriptor, CM: Deref, RM: Deref, OM: Deref, L: Deref, CM
1233
1233
let mut has_enqueued_announcement = false ;
1234
1234
1235
1235
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) ;
1241
1238
self . enqueue_message ( peer, & update_a) ;
1239
+ has_enqueued_announcement = true ;
1242
1240
}
1243
1241
}
1244
1242
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 {
1246
1244
if !has_enqueued_announcement {
1247
1245
self . enqueue_message ( peer, & announce) ;
1248
1246
}
@@ -1260,7 +1258,7 @@ impl<Descriptor: SocketDescriptor, CM: Deref, RM: Deref, OM: Deref, L: Deref, CM
1260
1258
( f. first_timestamp , f. first_timestamp . saturating_add ( f. timestamp_range ) )
1261
1259
} ) ;
1262
1260
1263
- if msg. contents . timestamp >= min && msg. contents . timestamp <= max {
1261
+ if msg. contents . timestamp >= min && msg. contents . timestamp < max {
1264
1262
self . enqueue_message ( peer, & msg) ;
1265
1263
}
1266
1264
0 commit comments