test - per_peer_state as write locks

Author: ViktorTigerstrom

lightning/src/ln/channelmanager.rs

@@ -1751,7 +1751,7 @@ impl<M: Deref, T: Deref, K: Deref, F: Deref, L: Deref> ChannelManager<M, T, K, F
 		}
 
 		let channel = {
-			let per_peer_state = self.per_peer_state.read().unwrap();
+			let per_peer_state = self.per_peer_state.write().unwrap();
 			match per_peer_state.get(&their_network_key) {
 				Some(peer_state) => {
 					let outbound_scid_alias = self.create_and_insert_outbound_scid_alias();
@@ -1848,7 +1848,7 @@ impl<M: Deref, T: Deref, K: Deref, F: Deref, L: Deref> ChannelManager<M, T, K, F
 				});
 			}
 		}
-		let per_peer_state = self.per_peer_state.read().unwrap();
+		let per_peer_state = self.per_peer_state.write().unwrap();
 		for chan in res.iter_mut() {
 			if let Some(peer_state) = per_peer_state.get(&chan.counterparty.node_id) {
 				chan.counterparty.features = peer_state.lock().unwrap().latest_features.clone();
@@ -1906,7 +1906,7 @@ impl<M: Deref, T: Deref, K: Deref, F: Deref, L: Deref> ChannelManager<M, T, K, F
 					if *counterparty_node_id != chan_entry.get().get_counterparty_node_id(){
 						return Err(APIError::APIMisuseError { err: "The passed counterparty_node_id doesn't match the channel's counterparty node_id".to_owned() });
 					}
-					let per_peer_state = self.per_peer_state.read().unwrap();
+					let per_peer_state = self.per_peer_state.write().unwrap();
 					let (shutdown_msg, monitor_update, htlcs) = match per_peer_state.get(&counterparty_node_id) {
 						Some(peer_state) => {
 							let peer_state = peer_state.lock().unwrap();