Refactoring: Typo, removed unused flag.

Author: tnull

lightning/src/ln/peer_handler.rs

@@ -1866,8 +1866,6 @@ mod tests {
 	fn test_do_attempt_write_data() {
 		// Create 2 peers with custom TestRoutingMessageHandlers and connect them.
 		let cfgs = create_peermgr_cfgs(2);
-		cfgs[0].routing_handler.request_full_sync.store(true, Ordering::Release);
-		cfgs[1].routing_handler.request_full_sync.store(true, Ordering::Release);
 		let peers = create_network(2, &cfgs);
 
 		// By calling establish_connect, we trigger do_attempt_write_data between
@@ -1879,7 +1877,7 @@ mod tests {
 		let (mut fd_a, mut fd_b) = establish_connection(&peers[0], &peers[1]);
 
 		// Make each peer to read the messages that the other peer just wrote to them. Note that
-		// due to the max-messagse-before-ping limits this may take a few iterations to complete.
+		// due to the max-message-before-ping limits this may take a few iterations to complete.
 		for _ in 0..150/super::BUFFER_DRAIN_MSGS_PER_TICK + 1 {
 			peers[0].process_events();
 			let b_read_data = fd_a.outbound_data.lock().unwrap().split_off(0);
@@ -1909,8 +1907,6 @@ mod tests {
 		// Tests that we time out a peer still waiting on handshake completion after a full timer
 		// tick.
 		let cfgs = create_peermgr_cfgs(2);
-		cfgs[0].routing_handler.request_full_sync.store(true, Ordering::Release);
-		cfgs[1].routing_handler.request_full_sync.store(true, Ordering::Release);
 		let peers = create_network(2, &cfgs);
 
 		let secp_ctx = Secp256k1::new();

lightning/src/util/test_utils.rs

@@ -44,7 +44,7 @@ use io;
 use prelude::*;
 use core::time::Duration;
 use sync::{Mutex, Arc};
-use core::sync::atomic::{AtomicBool, AtomicUsize, Ordering};
+use core::sync::atomic::{AtomicUsize, Ordering};
 use core::{cmp, mem};
 use bitcoin::bech32::u5;
 use chain::keysinterface::{InMemorySigner, Recipient, KeyMaterial};
@@ -341,15 +341,13 @@ fn get_dummy_channel_update(short_chan_id: u64) -> msgs::ChannelUpdate {
 pub struct TestRoutingMessageHandler {
 	pub chan_upds_recvd: AtomicUsize,
 	pub chan_anns_recvd: AtomicUsize,
-	pub request_full_sync: AtomicBool,
 }
 
 impl TestRoutingMessageHandler {
 	pub fn new() -> Self {
 		TestRoutingMessageHandler {
 			chan_upds_recvd: AtomicUsize::new(0),
 			chan_anns_recvd: AtomicUsize::new(0),
-			request_full_sync: AtomicBool::new(false),
 		}
 	}
 }